The highest tagged major version is
Documentation
¶
Index ¶
- func WithDirectory(directory string) func(*Client)
- func WithGRPCConnection(userConn *grpc.ClientConn) func(*Client)
- func WithLogger(logger zerolog.Logger) func(*Client)
- func WithNoSentry() func(*Client)
- type Client
- func (c *Client) GetMetrics(ctx context.Context) (*source.Metrics, error)
- func (c *Client) GetProtocolVersion(ctx context.Context) (uint64, error)
- func (c *Client) GetSyncSummary(ctx context.Context) (*schema.SyncSummary, error)
- func (c *Client) GetTables(ctx context.Context) ([]*schema.Table, error)
- func (c *Client) GetTablesForSpec(ctx context.Context, spec *specs.Source) ([]*schema.Table, error)
- func (c *Client) Name(ctx context.Context) (string, error)
- func (c *Client) Sync(ctx context.Context, spec specs.Source, res chan<- []byte) error
- func (c *Client) Sync2(ctx context.Context, spec specs.Source, res chan<- []byte) error
- func (c *Client) Terminate() error
- func (c *Client) Version(ctx context.Context) (string, error)
- type ClientOption
- type FetchResultMessage
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func WithDirectory ¶
func WithGRPCConnection ¶
func WithGRPCConnection(userConn *grpc.ClientConn) func(*Client)
func WithLogger ¶
func WithNoSentry ¶
func WithNoSentry() func(*Client)
Types ¶
type Client ¶
type Client struct {
// contains filtered or unexported fields
}
Client
func NewClient ¶
func NewClient(ctx context.Context, registrySpec specs.Registry, path string, version string, opts ...ClientOption) (*Client, error)
NewClient connect to gRPC server running source plugin and returns a new Client
func (*Client) GetMetrics ¶
func (*Client) GetProtocolVersion ¶
func (*Client) GetSyncSummary ¶
func (*Client) GetTablesForSpec ¶
func (*Client) Sync ¶
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 source plugin
func (*Client) Sync2 ¶
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 source plugin
type ClientOption ¶
type ClientOption func(*Client)
type FetchResultMessage ¶
type FetchResultMessage struct {
Resource []byte
}
Source Files
Click to show internal directories.
Click to hide internal directories.