agent

Documentation

Index

• type Agent
  • func New(cfg *Config) (*Agent, error)
  • func (a *Agent) ApplyRead(roLevel rkvApi.ConsistencyLevel, fn string, args ...[]byte) (interface{}, error)
  • func (a *Agent) ApplyWrite(fn string, args ...[]byte) (interface{}, error)
  • func (a *Agent) Delete(tab, key []byte) error
  • func (a *Agent) Get(lvl api.ConsistencyLevel, tab, key []byte) ([]byte, error)
  • func (a *Agent) GetApplyFunc(name string) (dbApi.ApplyFunc, bool, error)
  • func (a *Agent) IsLeader() bool
  • func (a *Agent) Leader() (string, string)
  • func (a *Agent) Logger(subSystem string) *log.Logger
  • func (a *Agent) Put(tab, key, value []byte) error
  • func (a *Agent) RegisterApplyRead(name string, fn dbApi.ApplyFunc) error
  • func (a *Agent) RegisterApplyWrite(name string, fn dbApi.ApplyFunc) error
  • func (a *Agent) Shutdown() error
  • func (a *Agent) UnRegisterApply(name string) error
• type Config
  • func (c Config) RPCAddr() (string, error)
  • func (c Config) RaftAddr() (string, error)

Types

type Agent

type Agent struct {
	*Config
	// contains filtered or unexported fields
}

Agent ...

func New

func New(cfg *Config) (*Agent, error)

New returns agent instance

func (*Agent) ApplyRead

func (a *Agent) ApplyRead(
	roLevel rkvApi.ConsistencyLevel,
	fn string,
	args ...[]byte) (interface{}, error)

ApplyRead ...

func (*Agent) ApplyWrite

func (a *Agent) ApplyWrite(
	fn string,
	args ...[]byte) (interface{}, error)

ApplyWrite ...

func (*Agent) Delete

func (a *Agent) Delete(tab, key []byte) error

Delete ...

func (*Agent) Get

func (a *Agent) Get(
	lvl api.ConsistencyLevel, tab, key []byte) ([]byte, error)

Get ...

func (*Agent) GetApplyFunc

func (a *Agent) GetApplyFunc(name string) (dbApi.ApplyFunc, bool, error)

GetApplyFunc ...

func (*Agent) IsLeader

func (a *Agent) IsLeader() bool

IsLeader ...

func (*Agent) Leader

func (a *Agent) Leader() (string, string)

Leader ...

func (*Agent) Logger

func (a *Agent) Logger(subSystem string) *log.Logger

Logger for client use

func (*Agent) Put

func (a *Agent) Put(tab, key, value []byte) error

Put ...

func (*Agent) RegisterApplyRead

func (a *Agent) RegisterApplyRead(name string, fn dbApi.ApplyFunc) error

RegisterApplyRead ...

func (*Agent) RegisterApplyWrite

func (a *Agent) RegisterApplyWrite(name string, fn dbApi.ApplyFunc) error

RegisterApplyWrite ...

func (*Agent) Shutdown

func (a *Agent) Shutdown() error

Shutdown ...

func (*Agent) UnRegisterApply

func (a *Agent) UnRegisterApply(name string) error

UnRegisterApply ...

type Config

type Config struct {
	DataDir  string
	Raft     raft.Config
	BindAddr string // Serf, Raft, RPC address. Serf with port
	RPCPort  int    // rpc API server
	RaftPort int
	BindHTTP string // bind address for HTTP server
	Backend  dbApi.Backend
	NodeName string // Raft server ID
	// Bootstrap should be set to true when starting the first node
	//  of the cluster
	StartJoinAddrs []string
	Bootstrap      bool
	RoutingPolicy  rkvApi.RoutingPolicy
	// Log oprtions: passed configured logger
	Logger log.Logger
	// Or configure options
	// LogLevel: error | warn | info | debug | trace
	LogLevel string
	// LogOutput default - stderr
	LogOutput          io.Writer
	LogIncludeLocation bool
	LogTimeFormat      string
	//
	OnLeaderChangeFn func(isLeader bool)
	//
	Registry rkvApi.ApplyRegistrator
}

Config ...

func (Config) RPCAddr

func (c Config) RPCAddr() (string, error)

RPCAddr returns host:port

func (Config) RaftAddr

func (c Config) RaftAddr() (string, error)

RaftAddr returns host:port