rpc

Documentation

Index

• type ReplicaHandler
  • func NewReplicaHandler(walMgr replica.WriteAheadLogManager) *ReplicaHandler
  • func (r *ReplicaHandler) GetReplicaAckIndex(_ context.Context, request *protoReplicaV1.GetReplicaAckIndexRequest) (*protoReplicaV1.GetReplicaAckIndexResponse, error)
  • func (r *ReplicaHandler) Replica(server protoReplicaV1.ReplicaService_ReplicaServer) error
  • func (r *ReplicaHandler) Reset(_ context.Context, request *protoReplicaV1.ResetIndexRequest) (*protoReplicaV1.ResetIndexResponse, error)
• type WriteHandler
  • func NewWriteHandler(walMgr replica.WriteAheadLogManager) *WriteHandler
  • func (r *WriteHandler) Write(server protoWriteV1.WriteService_WriteServer) error

Types

type ReplicaHandler

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

ReplicaHandler implements replica.ReplicaServiceServer interface for handling replica rpc request.

func NewReplicaHandler

func NewReplicaHandler(
	walMgr replica.WriteAheadLogManager,
) *ReplicaHandler

NewReplicaHandler creates a replica handler.

func (*ReplicaHandler) GetReplicaAckIndex

func (r *ReplicaHandler) GetReplicaAckIndex(_ context.Context,
	request *protoReplicaV1.GetReplicaAckIndexRequest,
) (*protoReplicaV1.GetReplicaAckIndexResponse, error)

GetReplicaAckIndex returns current replica ack index.

func (*ReplicaHandler) Replica

func (r *ReplicaHandler) Replica(server protoReplicaV1.ReplicaService_ReplicaServer) error

Replica does replica request, and writes data.

func (*ReplicaHandler) Reset

func (r *ReplicaHandler) Reset(_ context.Context,
	request *protoReplicaV1.ResetIndexRequest,
) (*protoReplicaV1.ResetIndexResponse, error)

Reset resets replica index.

type WriteHandler

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

WriteHandler implements protoWriteV1.WriteServiceServer interface for handling write rpc request.

func NewWriteHandler

func NewWriteHandler(
	walMgr replica.WriteAheadLogManager,
) *WriteHandler

NewWriteHandler creates a write handler.

func (*WriteHandler) Write

func (r *WriteHandler) Write(server protoWriteV1.WriteService_WriteServer) error

Write does metric write request.