Versions in this module Expand all Collapse all v0 v0.0.3 Mar 25, 2015 v0.0.2 Mar 23, 2015 v0.0.1 Mar 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