Versions in this module Expand all Collapse all v0 v0.9.0 Jul 26, 2023 Changes in this version + const GRPCMaxClientRecvSize + const GRPCMaxClientSendSize + const GRPCMaxRetry + func New(c Client, logger log.Logger) plugins.Syncer + type Client interface + Close func() error + Connect func(ctx context.Context, host string) error + type Config struct + Headers map[string]string + Host string + type RequestPayload struct + Email string + Metadata map[string]interface{} + Name string + type Sink struct + func (s *Sink) Close() (err error) + func (s *Sink) Init(ctx context.Context, config plugins.Config) error + func (s *Sink) Sink(ctx context.Context, batch []models.Record) error
Go to main page