demory

README

Demory is a Cloud-Native Distributed In-Memory Database based on the RAFT Protocol.

Howto Use

Demory is still in progress, will be updated soon

Documentation

Index

• type Demory
  • func New() *Demory
  • func (d *Demory) CacheClear(ctx context.Context, req *proto.CacheClearRequest) (*emptypb.Empty, error)
  • func (d *Demory) CacheGet(ctx context.Context, req *proto.CacheGetRequest) (*proto.CacheGetResponse, error)
  • func (d *Demory) CachePut(ctx context.Context, req *proto.CachePutRequest) (*emptypb.Empty, error)
  • func (d *Demory) CacheRemove(ctx context.Context, req *proto.CacheRemoveRequest) (*emptypb.Empty, error)
  • func (d *Demory) JoinToCluster(ctx context.Context, request *proto.JoinToClusterRequest) (*proto.JoinToClusterResponse, error)
  • func (d *Demory) MapClear(ctx context.Context, req *proto.MapClearRequest) (*emptypb.Empty, error)
  • func (d *Demory) MapGet(ctx context.Context, req *proto.MapGetRequest) (*proto.MapGetResponse, error)
  • func (d *Demory) MapPut(ctx context.Context, req *proto.MapPutRequest) (*emptypb.Empty, error)
  • func (d *Demory) MapPutIfAbsent(ctx context.Context, req *proto.MapPutIfAbsentRequest) (*emptypb.Empty, error)
  • func (d *Demory) MapRemove(ctx context.Context, req *proto.MapRemoveRequest) (*emptypb.Empty, error)
  • func (d *Demory) Run()

Types

type Demory

type Demory struct {
	proto.UnimplementedDemoryServer
	// contains filtered or unexported fields
}

Demory is for representing data structure storage It also has basic api interface for data operations.

func New

func New() *Demory

New for creating new instance of in-memory database.

func (*Demory) CacheClear

func (d *Demory) CacheClear(ctx context.Context, req *proto.CacheClearRequest) (*emptypb.Empty, error)

CacheClear clears all the entries in cache specified with name

func (*Demory) CacheGet

func (d *Demory) CacheGet(ctx context.Context, req *proto.CacheGetRequest) (*proto.CacheGetResponse, error)

CacheGet retrieves data from store.

func (*Demory) CachePut

func (d *Demory) CachePut(ctx context.Context, req *proto.CachePutRequest) (*emptypb.Empty, error)

CachePut saves data into store.

func (*Demory) CacheRemove

func (d *Demory) CacheRemove(ctx context.Context, req *proto.CacheRemoveRequest) (*emptypb.Empty, error)

Remove removes the value at specified key

func (*Demory) JoinToCluster

func (d *Demory) JoinToCluster(ctx context.Context, request *proto.JoinToClusterRequest) (*proto.JoinToClusterResponse,
	error)

JoinToCluster is used by port discovery to allow joining cluster by using leader node.

func (*Demory) MapClear

func (d *Demory) MapClear(ctx context.Context, req *proto.MapClearRequest) (*emptypb.Empty, error)

MapClear clears all the entries in map specified with name

func (*Demory) MapGet

func (d *Demory) MapGet(ctx context.Context, req *proto.MapGetRequest) (*proto.MapGetResponse, error)

MapGet retrieves data from store.

func (*Demory) MapPut

func (d *Demory) MapPut(ctx context.Context, req *proto.MapPutRequest) (*emptypb.Empty, error)

MapPut saves data into store.

func (*Demory) MapPutIfAbsent

func (d *Demory) MapPutIfAbsent(ctx context.Context, req *proto.MapPutIfAbsentRequest) (*emptypb.Empty, error)

MapPutIfAbsent inserts value at specified key if there is no value

func (*Demory) MapRemove

func (d *Demory) MapRemove(ctx context.Context, req *proto.MapRemoveRequest) (*emptypb.Empty, error)

MapRemove removes the value at specified key

func (*Demory) Run

func (d *Demory) Run()