master

Documentation

Index

• type DKVClusterService
  • func NewDistributedService(kvs storage.KVStore, cp storage.ChangePropagator, br storage.Backupable, ...) DKVClusterService
• type DKVService
  • func NewStandaloneService(store storage.KVStore, cp storage.ChangePropagator, br storage.Backupable, ...) DKVService

Types

type DKVClusterService

type DKVClusterService interface {
	DKVService
	serverpb.DKVClusterServer
}

A DKVClusterService represents a service for serving key value data along with exposing all mutations as a replication stream. Moreover it also provides means to add and remove DKV nodes onto the current cluster.

func NewDistributedService

func NewDistributedService(kvs storage.KVStore, cp storage.ChangePropagator, br storage.Backupable,
	raftRepl nexus_api.RaftReplicator, lgr *zap.Logger, statsCli stats.Client) DKVClusterService

NewDistributedService creates a distributed variant of the DKV service that attempts to replicate data across multiple replicas over Nexus.

type DKVService

type DKVService interface {
	io.Closer
	serverpb.DKVServer
	serverpb.DKVReplicationServer
	serverpb.DKVBackupRestoreServer
}

A DKVService represents a service for serving key value data along with exposing all mutations as a replication stream.

func NewStandaloneService

func NewStandaloneService(store storage.KVStore, cp storage.ChangePropagator, br storage.Backupable, lgr *zap.Logger, statsCli stats.Client) DKVService

NewStandaloneService creates a standalone variant of the DKVService that works only with the local storage.