distributed

Documentation

Index

• type Context
  • func NewContext(l logging.Logger) *Context
  • func (c *Context) Apply(l *raft.Log) interface{}
  • func (c *Context) Restore(r io.ReadCloser) error
  • func (c *Context) Snapshot() (raft.FSMSnapshot, error)
• type Message
• type RPCInterface
  • func NewRPCInterface(c *Context, r *raft.Raft, l logging.Logger) *RPCInterface
  • func (r RPCInterface) Clear(ctx context.Context, request *proto.ClearRequest) (*proto.ClearResponse, error)
  • func (r RPCInterface) Get(ctx context.Context, request *proto.GetRequest) (*proto.GetResponse, error)
  • func (r RPCInterface) List(ctx context.Context, request *proto.ListRequest) (*proto.ListResponse, error)
  • func (r RPCInterface) Remove(ctx context.Context, request *proto.RemoveRequest) (*proto.RemoveResponse, error)
  • func (r RPCInterface) Set(ctx context.Context, request *proto.SetRequest) (*proto.SetResponse, error)
• type Snapshot
  • func (s *Snapshot) Persist(sink raft.SnapshotSink) error
  • func (s *Snapshot) Release()
• type Type
  • func (t Type) String() string

Types

type Context

type Context struct {
	// contains filtered or unexported fields
}

Context is a cluster-wide shared, distributed context.

func NewContext

func NewContext(l logging.Logger) *Context

func (*Context) Apply

func (c *Context) Apply(l *raft.Log) interface{}

func (*Context) Restore

func (c *Context) Restore(r io.ReadCloser) error

func (*Context) Snapshot

func (c *Context) Snapshot() (raft.FSMSnapshot, error)

type Message

type Message struct {
	Type   Type     `json:"type"`
	Key    string   `json:"key,omitempty"`
	Value  []byte   `json:"value,omitempty"`
	Filter string   `json:"filter,omitempty"`
	Keys   []string `json:"keys,omitempty"`
	Index  uint64   `json:"index,omitempty"`
}

type RPCInterface

type RPCInterface struct {
	proto.UnimplementedContextServer
	// contains filtered or unexported fields
}

func NewRPCInterface

func NewRPCInterface(c *Context, r *raft.Raft, l logging.Logger) *RPCInterface

func (RPCInterface) Clear

func (r RPCInterface) Clear(ctx context.Context, request *proto.ClearRequest) (*proto.ClearResponse, error)

func (RPCInterface) Get

func (r RPCInterface) Get(ctx context.Context, request *proto.GetRequest) (*proto.GetResponse, error)

func (RPCInterface) List

func (r RPCInterface) List(ctx context.Context, request *proto.ListRequest) (*proto.ListResponse, error)

func (RPCInterface) Remove

func (r RPCInterface) Remove(ctx context.Context, request *proto.RemoveRequest) (*proto.RemoveResponse, error)

func (RPCInterface) Set

func (r RPCInterface) Set(ctx context.Context, request *proto.SetRequest) (*proto.SetResponse, error)

type Snapshot

type Snapshot struct {
	// contains filtered or unexported fields
}

func (*Snapshot) Persist

func (s *Snapshot) Persist(sink raft.SnapshotSink) error

func (*Snapshot) Release

func (s *Snapshot) Release()

type Type

type Type int8

const (
	Get Type = iota
	Set
	Remove
	List
	Clear
)

func (Type) String

func (t Type) String() string