Versions in this module Expand all Collapse all v1 v1.0.5 Aug 24, 2015 v1.0.4 Jul 29, 2015 v1.0.3 Jul 20, 2015 v1.0.2 Jul 14, 2015 v1.0.1 Jun 30, 2015 v1.0.0 Jun 18, 2015 v0 v0.6.2 Jun 17, 2015 v0.6.1 Jun 15, 2015 v0.5.4 Jun 4, 2015 v0.5.3 May 28, 2015 v0.5.2 May 19, 2015 v0.5.1 May 13, 2015 v0.4.4 Apr 23, 2015 Changes in this version + func DecodeLog4(file *os.File) ([]*etcd4pb.LogEntry, error) + func DecodeNextEntry4(r io.Reader) (*etcd4pb.LogEntry, int, error) + func Entries4To2(ents4 []*etcd4pb.LogEntry) ([]raftpb.Entry, error) + func FindLatestFile(dirpath string) (string, error) + func GuessNodeID(nodes map[string]uint64, snap4 *Snapshot4, cfg *Config4, name string) uint64 + func Migrate4To2(dataDir string, name string) error + func NewMember(name string, peerURLs types.URLs, clusterName string) *member + func StorePath(key string) string + func UnixTimeOrPermanent(expireTime time.Time) int64 + type Command4 interface + Data2 func() ([]byte, error) + Type2 func() raftpb.EntryType + func NewCommand4(name string, data []byte, raftMap map[string]uint64) (Command4, error) + type CompareAndDeleteCommand struct + Key string + PrevIndex uint64 + PrevValue string + func (c *CompareAndDeleteCommand) Data2() ([]byte, error) + func (c *CompareAndDeleteCommand) Type2() raftpb.EntryType + type CompareAndSwapCommand struct + ExpireTime time.Time + Key string + PrevIndex uint64 + PrevValue string + Value string + func (c *CompareAndSwapCommand) Data2() ([]byte, error) + func (c *CompareAndSwapCommand) Type2() raftpb.EntryType + type Config4 struct + CommitIndex uint64 + Peers []struct{ ... } + func DecodeConfig4FromFile(cfgPath string) (*Config4, error) + func (c *Config4) HardState2() raftpb.HardState + type CreateCommand struct + Dir bool + ExpireTime time.Time + Key string + Unique bool + Value string + func (c *CreateCommand) Data2() ([]byte, error) + func (c *CreateCommand) Type2() raftpb.EntryType + type DefaultJoinCommand struct + ConnectionString string + Name string + type DefaultLeaveCommand struct + Name string + type DeleteCommand struct + Dir bool + Key string + Recursive bool + func (c *DeleteCommand) Data2() ([]byte, error) + func (c *DeleteCommand) Type2() raftpb.EntryType + type JoinCommand struct + EtcdURL string + Name string + RaftURL string + func (c *JoinCommand) Data2() ([]byte, error) + func (c *JoinCommand) Type2() raftpb.EntryType + type Log4 []*etcd4pb.LogEntry + func DecodeLog4FromFile(logpath string) (Log4, error) + func (l Log4) NodeIDs() map[string]uint64 + type MachineMessage struct + ClientURL string + Name string + PeerURL string + State string + type NOPCommand struct + func (c *NOPCommand) Data2() ([]byte, error) + func (c *NOPCommand) Type2() raftpb.EntryType + func (c NOPCommand) CommandName() string + type RemoveCommand struct + Name string + func (c *RemoveCommand) Data2() ([]byte, error) + func (c *RemoveCommand) Type2() raftpb.EntryType + type SetClusterConfigCommand struct + Config ... + func (c *SetClusterConfigCommand) Data2() ([]byte, error) + func (c *SetClusterConfigCommand) Type2() raftpb.EntryType + type SetCommand struct + Dir bool + ExpireTime time.Time + Key string + Value string + func (c *SetCommand) Data2() ([]byte, error) + func (c *SetCommand) Type2() raftpb.EntryType + type Snapshot4 struct + LastIndex uint64 + LastTerm uint64 + Peers []struct{ ... } + State []byte + func DecodeLatestSnapshot4FromDir(snapdir string) (*Snapshot4, error) + func DecodeSnapshot4(f *os.File) (*Snapshot4, error) + func DecodeSnapshot4FromFile(path string) (*Snapshot4, error) + func (s *Snapshot4) GetNodesFromStore() map[string]uint64 + func (s *Snapshot4) Snapshot2() *raftpb.Snapshot + type SnapshotFileName struct + FileName string + Index uint64 + Term uint64 + func NewSnapshotFileNames(names []string) ([]SnapshotFileName, error) + type SnapshotFileNames []SnapshotFileName + func (n *SnapshotFileNames) Len() int + func (n *SnapshotFileNames) Less(i, j int) bool + func (n *SnapshotFileNames) Swap(i, j int) + type StandbyInfo4 struct + Cluster []*MachineMessage + Running bool + SyncInterval float64 + func DecodeStandbyInfo4FromFile(path string) (*StandbyInfo4, error) + func (si *StandbyInfo4) ClientURLs() []string + func (si *StandbyInfo4) InitialCluster() string + type Store4 struct + CurrentIndex uint64 + CurrentVersion int + Root *node + type SyncCommand struct + Time time.Time + func (c *SyncCommand) Data2() ([]byte, error) + func (c *SyncCommand) Type2() raftpb.EntryType + type UpdateCommand struct + ExpireTime time.Time + Key string + Value string + func (c *UpdateCommand) Data2() ([]byte, error) + func (c *UpdateCommand) Type2() raftpb.EntryType