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 (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, resources <-chan []byte) (uint64, error)
• type FetchResultMessage
• type SourceClient
  • func NewSourceClient(cc grpc.ClientConnInterface) *SourceClient
  • 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<- []byte) 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 (*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, resources <-chan []byte) (uint64, error)

Write writes rows as they are received from the channel to the destination plugin. resources is marshaled schema.Resource. We are not marshalling this inside the function because usually it is alreadun marshalled from the source plugin.

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) 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<- []byte) error

Sync start syncing for the source client per the given spec and returning the results in the given channel. res is marshaled schema.Resource. We are not unmarshalling this for performance reasons as usually this is sent over-the-wire anyway to a destination plugin

func (*SourceClient) Version

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