Versions in this module Expand all Collapse all v0 v0.0.2 Apr 3, 2019 Changes in this version + func IsIntType(k reflect.Kind) (size int, okay bool) + type FSM struct + func New(args ...interface{}) (*FSM, error) + func (c *FSM) Apply(l *raft.Log) interface{} + func (c *FSM) Restore(old io.ReadCloser) error + func (c *FSM) Snapshot() (raft.FSMSnapshot, error) + func (c *FSM) State() *Store + type IndexEntry struct + Key string + Value uint64 + type IntFieldIndex struct + Field string + func (u *IntFieldIndex) FromArgs(args ...interface{}) ([]byte, error) + func (u *IntFieldIndex) FromObject(obj interface{}) (bool, []byte, error) + type NodeID int32 + type Restore struct + func (s *Restore) Abort() + func (s *Restore) Commit() + type Snapshot struct + func (s *Snapshot) Close() + func (s *Snapshot) LastIndex() uint64 + type Store struct + func NewStore(args ...interface{}) (*Store, error) + func (s *Store) Abandon() + func (s *Store) AbandonCh() <-chan struct{} + func (s *Store) DeleteGroup(idx uint64, group string) error + func (s *Store) DeleteNode(idx uint64, id int32) error + func (s *Store) DeletePartition(idx uint64, topic string, partition int32) error + func (s *Store) DeleteTopic(idx uint64, id string) error + func (s *Store) EnsureGroup(idx uint64, group *structs.Group) error + func (s *Store) EnsureNode(idx uint64, node *structs.Node) error + func (s *Store) EnsurePartition(idx uint64, partition *structs.Partition) error + func (s *Store) EnsureRegistration(idx uint64, req *structs.RegisterNodeRequest) error + func (s *Store) EnsureTopic(idx uint64, topic *structs.Topic) error + func (s *Store) GetGroup(id string) (uint64, *structs.Group, error) + func (s *Store) GetGroups() (uint64, []*structs.Group, error) + func (s *Store) GetGroupsByCoordinator(coordinator int32) (uint64, []*structs.Group, error) + func (s *Store) GetNode(id int32) (uint64, *structs.Node, error) + func (s *Store) GetNodes() (uint64, []*structs.Node, error) + func (s *Store) GetPartition(topic string, id int32) (uint64, *structs.Partition, error) + func (s *Store) GetPartitions() (uint64, []*structs.Partition, error) + func (s *Store) GetTopic(id string) (uint64, *structs.Topic, error) + func (s *Store) GetTopics() (uint64, []*structs.Topic, error) + func (s *Store) PartitionsByLeader(leader int32) (uint64, []*structs.Partition, error) + func (s *Store) Restore() *Restore + func (s *Store) Snapshot() *Snapshot + type Tracer opentracing.Tracer
Go to main page