server

package
v0.0.0-...-8c4f4f5 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 27, 2022 License: MIT Imports: 21 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func BadgerRaftSetup

func BadgerRaftSetup()

func Run

func Run(db *badger.DB, raft *raft.Raft)

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL