clients

Documentation

Overview

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

Index

• type DestinationClient
  • func NewDestinationClient(cc grpc.ClientConnInterface) *DestinationClient
  • func NewLocalDestinationClient(p plugins.DestinationPlugin) *DestinationClient
  • func (c *DestinationClient) GetExampleConfig(ctx context.Context) (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 FetchResultMessage
• type SourceClient
  • func NewSourceClient(cc grpc.ClientConnInterface) *SourceClient
  • func (c *SourceClient) ExampleConfig(ctx context.Context) (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)

Types

type DestinationClient

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

func NewDestinationClient

func NewDestinationClient(cc grpc.ClientConnInterface) *DestinationClient

func NewLocalDestinationClient

func NewLocalDestinationClient(p plugins.DestinationPlugin) *DestinationClient

func (*DestinationClient) GetExampleConfig

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

func (*DestinationClient) Initialize

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

func (*DestinationClient) Migrate

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

func (*DestinationClient) Name

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

func (*DestinationClient) Version

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

func (*DestinationClient) Write

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

type FetchResultMessage

type FetchResultMessage struct {
	Resource []byte
}

type SourceClient

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

SourceClient

func NewSourceClient

func NewSourceClient(cc grpc.ClientConnInterface) *SourceClient

func (*SourceClient) ExampleConfig

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

func (*SourceClient) GetTables

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

func (*SourceClient) Name

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

func (*SourceClient) Sync

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

func (*SourceClient) Version

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