Documentation ¶
Index ¶
- func BadgerRaftSetup()
- func Run(db *badger.DB, raft *raft.Raft)
- type DKVServerV1
- func (d *DKVServerV1) KVDelete(ctx context.Context, request *proto.KVDeleteRequest) (*emptypb.Empty, error)
- func (d *DKVServerV1) KVGet(ctx context.Context, request *proto.KVGetRequest) (*proto.KVGetResponse, error)
- func (d *DKVServerV1) KVPut(ctx context.Context, request *proto.KVPutRequest) (*emptypb.Empty, error)
- func (d *DKVServerV1) RaftJoin(ctx context.Context, request *proto.RaftJoinRequest) (*emptypb.Empty, error)
- func (d *DKVServerV1) RaftLeave(ctx context.Context, request *proto.RaftLeaveRequest) (*emptypb.Empty, error)
- func (d *DKVServerV1) RaftState(ctx context.Context, _ *emptypb.Empty) (*proto.RaftStateResponse, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func BadgerRaftSetup ¶
func BadgerRaftSetup()
Types ¶
type DKVServerV1 ¶
type DKVServerV1 struct { proto.UnimplementedDKVServer // contains filtered or unexported fields }
func New ¶
func New(db *badger.DB, raft *raft.Raft) *DKVServerV1
func (*DKVServerV1) KVDelete ¶
func (d *DKVServerV1) KVDelete(ctx context.Context, request *proto.KVDeleteRequest) (*emptypb.Empty, error)
func (*DKVServerV1) KVGet ¶
func (d *DKVServerV1) KVGet(ctx context.Context, request *proto.KVGetRequest) (*proto.KVGetResponse, error)
func (*DKVServerV1) KVPut ¶
func (d *DKVServerV1) KVPut(ctx context.Context, request *proto.KVPutRequest) (*emptypb.Empty, error)
func (*DKVServerV1) RaftJoin ¶
func (d *DKVServerV1) RaftJoin(ctx context.Context, request *proto.RaftJoinRequest) (*emptypb.Empty, error)
func (*DKVServerV1) RaftLeave ¶
func (d *DKVServerV1) RaftLeave(ctx context.Context, request *proto.RaftLeaveRequest) (*emptypb.Empty, error)
func (*DKVServerV1) RaftState ¶
func (d *DKVServerV1) RaftState(ctx context.Context, _ *emptypb.Empty) (*proto.RaftStateResponse, error)
Click to show internal directories.
Click to hide internal directories.