diskStore

Documentation

Index

• type MessageValue
• type MessageValue_OPERATION
• type Store
  • func New(storagePath string, raftAddress string, singleMode bool) *Store
  • func (s *Store) CheckNSet(key string, value string, expiration time.Time) (bool, string, error)
  • func (s *Store) Count() int
  • func (s *Store) IsLeader() bool
  • func (s *Store) Join(addr string) error
  • func (s *Store) Open() error
• type UniqueStorage
  • func (f *UniqueStorage) Persist(sink raft.SnapshotSink) error
  • func (f *UniqueStorage) Release()
• type UniqueStorageValue

Types

type MessageValue

type MessageValue struct {
	Operation  MessageValue_OPERATION `json:"operation,omitempty"`
	Key        string                 `json:"key,omitempty"`
	Value      string                 `json:"value,omitempty"`
	Expiration int64                  `json:"expiration,omitempty"`
	// contains filtered or unexported fields
}

type MessageValue_OPERATION

type MessageValue_OPERATION int32

const (
	MessageValue_CAS MessageValue_OPERATION = 0
)

type Store

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

func New

func New(storagePath string, raftAddress string, singleMode bool) *Store

New returns a new Store.

func (*Store) CheckNSet

func (s *Store) CheckNSet(key string, value string, expiration time.Time) (bool, string, error)

func (*Store) Count

func (s *Store) Count() int

func (*Store) IsLeader

func (s *Store) IsLeader() bool

func (*Store) Join

func (s *Store) Join(addr string) error

func (*Store) Open

func (s *Store) Open() error

type UniqueStorage

type UniqueStorage struct {
	Items map[string]*UniqueStorageValue `json:"items,omitempty"`
}

func (*UniqueStorage) Persist

func (f *UniqueStorage) Persist(sink raft.SnapshotSink) error

func (*UniqueStorage) Release

func (f *UniqueStorage) Release()

type UniqueStorageValue

type UniqueStorageValue struct {
	Value      string `json:"value,omitempty"`
	Expiration int64  `json:"expiration,omitempty"`
}