plugin

package

v0.0.1 Latest Latest Go to latest Published: Aug 17, 2023 License: MIT Imports: 11 Imported by: 0

Documentation ¶

This section is empty.

View Source

var (
	Version = "development"
)

func Configure(ctx context.Context, logger zerolog.Logger, spec []byte, opts plugin.NewClientOptions) (plugin.Client, error)

func Plugin() *plugin.Plugin

type Client struct {
	plugin.UnimplementedDestination
	// contains filtered or unexported fields
}

func (*Client) Close(_ context.Context) error

func (c *Client) Sync(ctx context.Context, options plugin.SyncOptions, res chan<- message.SyncMessage) error

func (c *Client) Tables(_ context.Context, options plugin.TableOptions) (schema.Tables, error)