The highest tagged major version is v4.

clients

package

v0.2.3 Latest Latest Go to latest Published: Sep 7, 2022 License: MPL-2.0 Imports: 9 Imported by: 0

Details

package clients is a wrapper around grpc clients so clients can work with non protobuf structs and handle unmarshaling

This section is empty.

This section is empty.

This section is empty.

type DestinationClient struct {
	// contains filtered or unexported fields
}

func NewDestinationClient(cc grpc.ClientConnInterface) *DestinationClient

func NewLocalDestinationClient(p *plugins.DestinationPlugin) *DestinationClient

func (c *DestinationClient) GetExampleConfig(ctx context.Context, opts DestinationExampleConfigOptions) (string, error)

func (c *DestinationClient) Initialize(ctx context.Context, spec specs.Destination) error

func (c *DestinationClient) Migrate(ctx context.Context, tables []*schema.Table) error

func (c *DestinationClient) Name(ctx context.Context) (string, error)

func (c *DestinationClient) Version(ctx context.Context) (string, error)

func (c *DestinationClient) Write(ctx context.Context, table string, data map[string]interface{}) error

type DestinationExampleConfigOptions struct {
	Path     string
	Registry specs.Registry
}

DestinationExampleConfigOptions can be used to override default example values.

type FetchResultMessage struct {
	Resource []byte
}

type SourceClient struct {
	// contains filtered or unexported fields
}

func NewSourceClient(cc grpc.ClientConnInterface) *SourceClient

func (c *SourceClient) ExampleConfig(ctx context.Context, opts SourceExampleConfigOptions) (string, error)

func (c *SourceClient) GetTables(ctx context.Context) ([]*schema.Table, error)

func (c *SourceClient) Name(ctx context.Context) (string, error)

func (c *SourceClient) Sync(ctx context.Context, spec specs.Source, res chan<- *schema.Resource) error

func (c *SourceClient) Version(ctx context.Context) (string, error)

type SourceExampleConfigOptions struct {
	Path     string
	Registry specs.Registry
}

SourceExampleConfigOptions can be used to override default example values.