Versions in this module Expand all Collapse all v0 v0.1.0 Jul 14, 2023 Changes in this version + var Connector = sdk.Connector + func AttachPositionIndex(p sdk.Position, index uint32) sdk.Position + func NewDestination() sdk.Destination + func NewDestinationWithDialer(dialer func(ctx context.Context, _ string) (net.Conn, error)) sdk.Destination + func Specification() sdk.Specification + type AckManager struct + func NewAckManager(sm *StreamManager) *AckManager + func (am *AckManager) Expect(expected []sdk.Position) error + func (am *AckManager) Got() int + func (am *AckManager) Run(ctx context.Context) error + func (am *AckManager) Wait(ctx context.Context) (int, error) + type Config struct + MTLS MTLSConfig + MaxDowntime time.Duration + RateLimit int + ReconnectDelay time.Duration + URL string + type DestConfig struct + func (DestConfig) Parameters() map[string]sdk.Parameter + type Destination struct + func (d *Destination) Configure(ctx context.Context, cfg map[string]string) error + func (d *Destination) Open(ctx context.Context) error + func (d *Destination) Parameters() map[string]sdk.Parameter + func (d *Destination) Teardown(ctx context.Context) error + func (d *Destination) Write(ctx context.Context, records []sdk.Record) (int, error) + type MTLSConfig struct + CACertPath string + ClientCertPath string + ClientKeyPath string + Disabled bool + func (mc *MTLSConfig) ParseMTLSFiles() (tls.Certificate, *x509.CertPool, error) + type Position struct + Index uint32 + Original []byte + func ToRecordPosition(p sdk.Position) Position + type StreamManager struct + func NewStreamManager(ctx context.Context, conn *grpc.ClientConn, ...) (*StreamManager, error) + func (sm *StreamManager) Get(ctx context.Context) (pb.SourceService_StreamClient, error) + func (sm *StreamManager) Run(ctx context.Context) (err error) + func (sm *StreamManager) StreamDone(ctx context.Context) (chan struct{}, error)
Go to main page