streamer

Documentation

Index

• func RegisterMetrics()
• type GrpcStreamer
  • func NewGrpcStreamer(errGrp *errgroup.Group, storageEngines map[string]*dbkernel.Engine, ...) *GrpcStreamer
  • func (s *GrpcStreamer) GetLatestOffset(ctx context.Context, _ *v1.GetLatestOffsetRequest) (*v1.GetLatestOffsetResponse, error)
  • func (s *GrpcStreamer) StreamWalRecords(request *v1.StreamWalRecordsRequest, ...) error
• type GrpcStreamerClient
  • func NewGrpcStreamerClient(gcc *grpc.ClientConn, namespace string, wIO WalIO, offset []byte) *GrpcStreamerClient
  • func (c *GrpcStreamerClient) GetLatestOffset(ctx context.Context) (*dbkernel.Offset, error)
  • 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.UnimplementedWalStreamerServiceServer
	// contains filtered or unexported fields
}

GrpcStreamer implements gRPC-based WalStreamerService.

func NewGrpcStreamer

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

NewGrpcStreamer returns an initialized GrpcStreamer that implements grpc-based WalStreamerService.

func (*GrpcStreamer) GetLatestOffset

func (s *GrpcStreamer) GetLatestOffset(ctx context.Context, _ *v1.GetLatestOffsetRequest) (*v1.GetLatestOffsetResponse, error)

GetLatestOffset returns the latest wal offset of the wal for the provided namespace.

func (*GrpcStreamer) StreamWalRecords

func (s *GrpcStreamer) StreamWalRecords(request *v1.StreamWalRecordsRequest, g grpc.ServerStreamingServer[v1.StreamWalRecordsResponse]) error

StreamWalRecords 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) GetLatestOffset

func (c *GrpcStreamerClient) GetLatestOffset(ctx context.Context) (*dbkernel.Offset, error)

GetLatestOffset returns the latest offset for the provided namespace that upstream has seen.

func (*GrpcStreamerClient) StreamWAL

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

StreamWAL start the wal Streaming for the namespace from the upstream.

type WalIO

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

WalIO provide.