streamer

Documentation

Index

• func RegisterMetrics()
• type GrpcStreamer
  • func NewGrpcStreamer(errGrp *errgroup.Group, storageEngines map[string]*dbengine.Engine, ...) *GrpcStreamer
  • func (s *GrpcStreamer) StreamWAL(request *v1.StreamWALRequest, ...) error
• type GrpcStreamerClient
  • func NewGrpcStreamerClient(gcc *grpc.ClientConn, namespace string, wIO WalIO, offset []byte) *GrpcStreamerClient
  • func (c *GrpcStreamerClient) StreamWAL(ctx context.Context) error
• type WalIO

Functions

func RegisterMetrics

func RegisterMetrics()

RegisterMetrics registers the Prometheus metrics.

Types

type GrpcStreamer

type GrpcStreamer struct {
	v1.UnimplementedWALReplicationServiceServer
	// contains filtered or unexported fields
}

GrpcStreamer implements gRPC-based WALReplicationService.

func NewGrpcStreamer

func NewGrpcStreamer(errGrp *errgroup.Group, storageEngines map[string]*dbengine.Engine, dynamicTimeout time.Duration) *GrpcStreamer

func (*GrpcStreamer) StreamWAL

func (s *GrpcStreamer) StreamWAL(request *v1.StreamWALRequest, g grpc.ServerStreamingServer[v1.StreamWALResponse]) error

StreamWAL stream the underlying WAL record on the connection stream.

type GrpcStreamerClient

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

func NewGrpcStreamerClient

func NewGrpcStreamerClient(gcc *grpc.ClientConn, namespace string, wIO WalIO, offset []byte) *GrpcStreamerClient

func (*GrpcStreamerClient) StreamWAL

func (c *GrpcStreamerClient) StreamWAL(ctx context.Context) error

type WalIO

type WalIO interface {
	Write(data *v1.WALRecord) error
}

WalIO provide.