@@ -15,13 +15,7 @@ import (
1515type DestinationClient struct {
1616 pbClient pb.DestinationClient
1717 // this can be used if we have a plugin which is compiled in, so we don't need to do any grpc requests
18- localClient * plugins.DestinationPlugin
19- }
20-
21- // DestinationExampleConfigOptions can be used to override default example values.
22- type DestinationExampleConfigOptions struct {
23- Path string
24- Registry specs.Registry
18+ localClient plugins.DestinationPlugin
2519}
2620
2721func NewDestinationClient (cc grpc.ClientConnInterface ) * DestinationClient {
@@ -30,7 +24,7 @@ func NewDestinationClient(cc grpc.ClientConnInterface) *DestinationClient {
3024 }
3125}
3226
33- func NewLocalDestinationClient (p * plugins.DestinationPlugin ) * DestinationClient {
27+ func NewLocalDestinationClient (p plugins.DestinationPlugin ) * DestinationClient {
3428 return & DestinationClient {
3529 localClient : p ,
3630 }
@@ -58,6 +52,17 @@ func (c *DestinationClient) Version(ctx context.Context) (string, error) {
5852 return res .Version , nil
5953}
6054
55+ func (c * DestinationClient ) GetExampleConfig (ctx context.Context ) (string , error ) {
56+ if c .localClient != nil {
57+ return c .localClient .ExampleConfig (), nil
58+ }
59+ res , err := c .pbClient .GetExampleConfig (ctx , & pb.GetExampleConfig_Request {})
60+ if err != nil {
61+ return "" , err
62+ }
63+ return res .Config , nil
64+ }
65+
6166func (c * DestinationClient ) Initialize (ctx context.Context , spec specs.Destination ) error {
6267 if c .localClient != nil {
6368 return c .localClient .Initialize (ctx , spec )
@@ -75,23 +80,6 @@ func (c *DestinationClient) Initialize(ctx context.Context, spec specs.Destinati
7580 return nil
7681}
7782
78- func (c * DestinationClient ) GetExampleConfig (ctx context.Context , opts DestinationExampleConfigOptions ) (string , error ) {
79- if c .localClient != nil {
80- return c .localClient .ExampleConfig (plugins.DestinationExampleConfigOptions {
81- Registry : opts .Registry ,
82- Path : opts .Path ,
83- })
84- }
85- res , err := c .pbClient .GetExampleConfig (ctx , & pb.GetDestinationExampleConfig_Request {
86- Registry : opts .Registry .String (),
87- Path : opts .Path ,
88- })
89- if err != nil {
90- return "" , err
91- }
92- return res .Config , nil
93- }
94-
9583func (c * DestinationClient ) Migrate (ctx context.Context , tables []* schema.Table ) error {
9684 if c .localClient != nil {
9785 return c .localClient .Migrate (ctx , tables )
0 commit comments