slave

Documentation

Index

• type DKVService
  • func NewService(store storage.KVStore, ca storage.ChangeApplier, replCli *ctl.DKVClient, ...) (DKVService, error)

Types

type DKVService

type DKVService interface {
	io.Closer
	serverpb.DKVServer
}

A DKVService represents a service for serving key value data.

func NewService

func NewService(store storage.KVStore, ca storage.ChangeApplier, replCli *ctl.DKVClient, replPollInterval time.Duration,
	lgr *zap.Logger, statsCli stats.Client) (DKVService, error)

NewService creates a slave DKVService that periodically polls for changes from master node and replicates them onto its local storage. As a result, it forbids changes to this local storage through any of the other key value mutators.