replication

Aug 7, 2022

Changes in this version

type GRPCReplicationServer

+ func NewGRPCReplicationServer() *GRPCReplicationServer

Mar 2, 2022

Changes in this version

+ var ErrRetryable = errors.New("retryable replication error")

+ type Retryer struct

+ func (r *Retryer) Run(ctx context.Context) error

May 15, 2021

Changes in this version

+ func NewRetryer(retryFunc func(ctx context.Context) error, interval time.Duration, ...) *retryer

+ type RetryableError string

+ func (re RetryableError) Error() string

+ func (re RetryableError) Is(err error) bool

Nov 25, 2020

Changes in this version

+ func WTSetToCSM(wtSet *wal.WTSet) (io.ColumnSeriesMap, error)

+ type GRPCClient interface

+ Connect func(ctx context.Context) error

+ Recv func() ([]byte, error)

+ type GRPCReplicationClient struct

+ Client pb.ReplicationClient

+ func NewGRPCReplicationClient(client pb.ReplicationClient) *GRPCReplicationClient

+ func (rc *GRPCReplicationClient) Connect(ctx context.Context) error

+ func (rc *GRPCReplicationClient) Recv() ([]byte, error)

+ type GRPCReplicationServer struct

+ CertFile string

+ CertKeyFile string

+ StreamChannels map[string]chan []byte

+ func NewGRPCReplicationService() *GRPCReplicationServer

+ func (rs *GRPCReplicationServer) GetWALStream(_ *pb.GetWALStreamRequest, stream pb.Replication_GetWALStreamServer) error

+ func (rs *GRPCReplicationServer) SendReplicationMessage(transactionGroup []byte)

+ type Receiver struct

+ func NewReceiver(grpcClient GRPCClient, replayer Replayer) *Receiver

+ func (r *Receiver) Run(ctx context.Context) error

+ type Replayer interface

+ Replay func(transactionGroup []byte) error

+ type ReplayerImpl struct

+ func NewReplayer(...) *ReplayerImpl

+ func (r *ReplayerImpl) Replay(transactionGroup []byte) error

+ type Sender struct

+ func NewSender(service Service) *Sender

+ func (s *Sender) Run(ctx context.Context)

+ func (s *Sender) Send(transactionGroup []byte)

+ type Service interface

+ SendReplicationMessage func(transactionGroup []byte)