The highest tagged major version is v4.

clients

package

v0.0.2 Latest Latest Go to latest Published: Aug 9, 2022 License: MPL-2.0 Imports: 15 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) Configure(ctx context.Context, s specs.DestinationSpec) error

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

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

func (c *DestinationClient) Save(ctx context.Context, msg *FetchResultMessage) error

type FetchResultMessage struct {
	Resource []byte
}

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

func NewSourceClient(cc grpc.ClientConnInterface) *SourceClient

func (c *SourceClient) Configure(ctx context.Context, spec specs.SourceSpec) (*gojsonschema.Result, error)

func (c *SourceClient) Fetch(ctx context.Context, spec specs.SourceSpec, res chan<- *FetchResultMessage) error

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

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