replication

type GRPCClient interface {
	Connect(ctx context.Context) error
	Recv() ([]byte, error)
}

type GRPCReplicationClient struct {
	Client pb.ReplicationClient
	// contains filtered or unexported fields
}

type GRPCReplicationServer struct {
	pb.UnimplementedReplicationServer
	CertFile    string
	CertKeyFile string
	// Key: IPAddr (e.g. "192.125.18.1:25"), Value: channel for messages sent to each gRPC stream
	StreamChannels map[string]chan []byte
}

type Receiver struct {
	// contains filtered or unexported fields
}

type Replayer interface {
	Replay(transactionGroup []byte) error
}

type ReplayerImpl struct {
	// contains filtered or unexported fields
}

type Retryer struct {
	// contains filtered or unexported fields
}

type Sender struct {
	// contains filtered or unexported fields
}

type Service interface {
	SendReplicationMessage(transactionGroup []byte)
}