etcdserver

Mar 18, 2016

Changes in this version

+ var ErrNoLeader = errors.New("etcdserver: no leader")

+ var ErrNotEnoughStartedMembers = errors.New("etcdserver: re-configuration failed due to not enough started members")

+ var ErrRequestTooLarge = errors.New("etcdserver: request is too large")

+ type Authenticator interface

+ AuthEnable func(ctx context.Context, r *pb.AuthEnableRequest) (*pb.AuthEnableResponse, error)

type EtcdServer

+ func (s *EtcdServer) AuthEnable(ctx context.Context, r *pb.AuthEnableRequest) (*pb.AuthEnableResponse, error)

+ func (s *EtcdServer) AuthStore() auth.AuthStore

+ func (s *EtcdServer) Backend() backend.Backend

+ func (s *EtcdServer) Compact(ctx context.Context, r *pb.CompactionRequest) (*pb.CompactionResponse, error)

+ func (s *EtcdServer) DeleteRange(ctx context.Context, r *pb.DeleteRangeRequest) (*pb.DeleteRangeResponse, error)

+ func (s *EtcdServer) Hash(ctx context.Context, r *pb.HashRequest) (*pb.HashResponse, error)

+ func (s *EtcdServer) IsPprofEnabled() bool

+ func (s *EtcdServer) LeaseCreate(ctx context.Context, r *pb.LeaseCreateRequest) (*pb.LeaseCreateResponse, error)

+ func (s *EtcdServer) LeaseRenew(id lease.LeaseID) (int64, error)

+ func (s *EtcdServer) LeaseRevoke(ctx context.Context, r *pb.LeaseRevokeRequest) (*pb.LeaseRevokeResponse, error)

+ func (s *EtcdServer) Lessor() lease.Lessor

+ func (s *EtcdServer) Put(ctx context.Context, r *pb.PutRequest) (*pb.PutResponse, error)

+ func (s *EtcdServer) Range(ctx context.Context, r *pb.RangeRequest) (*pb.RangeResponse, error)

+ func (s *EtcdServer) Txn(ctx context.Context, r *pb.TxnRequest) (*pb.TxnResponse, error)

+ func (s *EtcdServer) Watchable() dstorage.Watchable

+ type Lessor interface

+ LeaseCreate func(ctx context.Context, r *pb.LeaseCreateRequest) (*pb.LeaseCreateResponse, error)

+ LeaseRenew func(id lease.LeaseID) (int64, error)

+ LeaseRevoke func(ctx context.Context, r *pb.LeaseRevokeRequest) (*pb.LeaseRevokeResponse, error)

type Member

+ func (m *Member) IsStarted() bool

+ type RaftKV interface

+ Compact func(ctx context.Context, r *pb.CompactionRequest) (*pb.CompactionResponse, error)

+ DeleteRange func(ctx context.Context, r *pb.DeleteRangeRequest) (*pb.DeleteRangeResponse, error)

+ Hash func(ctx context.Context, r *pb.HashRequest) (*pb.HashResponse, error)

+ Put func(ctx context.Context, r *pb.PutRequest) (*pb.PutResponse, error)

+ Range func(ctx context.Context, r *pb.RangeRequest) (*pb.RangeResponse, error)

+ Txn func(ctx context.Context, r *pb.TxnRequest) (*pb.TxnResponse, error)

type ServerConfig

+ AutoCompactionRetention int

+ BootstrapTimeout time.Duration

+ EnablePprof bool

+ PeerTLSInfo transport.TLSInfo

+ StrictReconfigCheck bool

type Storage

+ DBFilePath func(id uint64) (string, error)

Nov 19, 2015

Changes in this version

+ type DiscoveryError struct

+ Err error

+ Op string

+ func (e DiscoveryError) Error() string

Sep 10, 2015

Changes in this version

+ var ErrTimeoutDueToConnectionLost = errors.New("etcdserver: request timed out, possibly due to connection lost")

+ func MustDetectDowngrade(cv *semver.Version)

type EtcdServer

+ func (s *EtcdServer) V3DemoDo(ctx context.Context, r pb.InternalRaftRequest) proto.Message

type ServerConfig

+ DedicatedWALDir string

+ V3demo bool

+ func (c *ServerConfig) ReqTimeout() time.Duration

+ type V3DemoServer interface

+ V3DemoDo func(ctx context.Context, r pb.InternalRaftRequest) proto.Message

Aug 21, 2015

Changes in this version

+ var ErrTimeoutDueToLeaderFail = errors.New("etcdserver: request timed out, possibly due to previous leader failure")

Jul 21, 2015

Changes in this version

+ const StoreClusterPrefix

type Cluster

+ Version func() *semver.Version

type EtcdServer

+ func (s *EtcdServer) ClusterVersion() *semver.Version

+ func (s *EtcdServer) IsIDRemoved(id uint64) bool

+ func (s *EtcdServer) ReportSnapshot(id uint64, status raft.SnapshotStatus)

+ func (s *EtcdServer) ReportUnreachable(id uint64)

+ type MembersByID []*Member

+ func (ms MembersByID) Len() int

+ func (ms MembersByID) Less(i, j int) bool

+ func (ms MembersByID) Swap(i, j int)

+ type MembersByPeerURLs []*Member

+ func (ms MembersByPeerURLs) Len() int

+ func (ms MembersByPeerURLs) Less(i, j int) bool

+ func (ms MembersByPeerURLs) Swap(i, j int)

type Server

+ ClusterVersion func() *semver.Version

type ServerConfig

+ InitialClusterToken string

+ InitialPeerURLsMap types.URLsMap

Mar 25, 2015

Changes in this version

type ServerConfig

+ func (c *ServerConfig) VerifyBootstrap() error

+ func (c *ServerConfig) VerifyJoinExisting() error

Feb 27, 2015

Changes in this version

type Cluster

+ func GetClusterFromRemotePeers(urls []string, tr *http.Transport) (*Cluster, error)

+ func (c *Cluster) UpdateIndex(index uint64)

Feb 13, 2015

Changes in this version

type Cluster

+ func (c *Cluster) Validate() error

Feb 12, 2015

Changes in this version

type ServerConfig

+ func (c *ServerConfig) MemberDir() string

Jan 28, 2015

Changes in this version

+ const DefaultSnapCount

+ const StoreAdminPrefix

+ const StoreKeysPrefix

+ var ErrCanceled = errors.New("etcdserver: request cancelled")

+ var ErrIDExists = errors.New("etcdserver: ID exists")

+ var ErrIDNotFound = errors.New("etcdserver: ID not found")

+ var ErrIDRemoved = errors.New("etcdserver: ID removed")

+ var ErrPeerURLexists = errors.New("etcdserver: peerURL exists")

+ var ErrStopped = errors.New("etcdserver: server stopped")

+ var ErrTimeout = errors.New("etcdserver: request timed out")

+ var ErrUnknownMethod = errors.New("etcdserver: unknown method")

+ func MemberAttributesStorePath(id types.ID) string

+ func ValidateClusterAndAssignIDs(local *Cluster, existing *Cluster) error

+ type Attributes struct

+ ClientURLs []string

+ Name string

+ type Cluster struct

+ func GetClusterFromPeers(urls []string, tr *http.Transport) (*Cluster, error)

+ func NewClusterFromMembers(token string, id types.ID, membs []*Member) *Cluster

+ func NewClusterFromStore(token string, st store.Store) *Cluster

+ func NewClusterFromString(token string, cluster string) (*Cluster, error)

+ func (c *Cluster) AddMember(m *Member)

+ func (c *Cluster) ClientURLs() []string

+ func (c *Cluster) ID() types.ID

+ func (c *Cluster) IsIDRemoved(id types.ID) bool

+ func (c *Cluster) Member(id types.ID) *Member

+ func (c *Cluster) MemberByName(name string) *Member

+ func (c *Cluster) MemberIDs() []types.ID

+ func (c *Cluster) Members() []*Member

+ func (c *Cluster) PeerURLs() []string

+ func (c *Cluster) Recover()

+ func (c *Cluster) RemoveMember(id types.ID)

+ func (c *Cluster) SetID(id types.ID)

+ func (c *Cluster) SetStore(st store.Store)

+ func (c *Cluster) String() string

+ func (c *Cluster) UpdateAttributes(id types.ID, attr Attributes)

+ func (c *Cluster) UpdateRaftAttributes(id types.ID, raftAttr RaftAttributes)

+ func (c *Cluster) ValidateConfigurationChange(cc raftpb.ConfChange) error

+ type ClusterInfo interface

+ ClientURLs func() []string

+ ID func() types.ID

+ IsIDRemoved func(id types.ID) bool

+ Member func(id types.ID) *Member

+ Members func() []*Member

+ type EtcdServer struct

+ Cluster *Cluster

+ SyncTicker <-chan time.Time

+ func NewServer(cfg *ServerConfig) (*EtcdServer, error)

+ func (s *EtcdServer) AddMember(ctx context.Context, memb Member) error

+ func (s *EtcdServer) Do(ctx context.Context, r pb.Request) (Response, error)

+ func (s *EtcdServer) ID() types.ID

+ func (s *EtcdServer) Index() uint64

+ func (s *EtcdServer) Lead() uint64

+ func (s *EtcdServer) Leader() types.ID

+ func (s *EtcdServer) LeaderStats() []byte

+ func (s *EtcdServer) PauseSending()

+ func (s *EtcdServer) Process(ctx context.Context, m raftpb.Message) error

+ func (s *EtcdServer) RaftHandler() http.Handler

+ func (s *EtcdServer) RemoveMember(ctx context.Context, id uint64) error

+ func (s *EtcdServer) ResumeSending()

+ func (s *EtcdServer) SelfStats() []byte

+ func (s *EtcdServer) Start()

+ func (s *EtcdServer) Stop()

+ func (s *EtcdServer) StopNotify() <-chan struct{}

+ func (s *EtcdServer) StoreStats() []byte

+ func (s *EtcdServer) Term() uint64

+ func (s *EtcdServer) UpdateMember(ctx context.Context, memb Member) error

+ type Member struct

+ ID types.ID

+ func NewMember(name string, peerURLs types.URLs, clusterName string, now *time.Time) *Member

+ func (m *Member) Clone() *Member

+ func (m *Member) PickPeerURL() string

+ type RaftAttributes struct

+ PeerURLs []string

+ type RaftTimer interface

+ Index func() uint64

+ Term func() uint64

+ type Response struct

+ Event *store.Event

+ Watcher store.Watcher

+ type Server interface

+ AddMember func(ctx context.Context, memb Member) error

+ Do func(ctx context.Context, r pb.Request) (Response, error)

+ ID func() types.ID

+ Leader func() types.ID

+ Process func(ctx context.Context, m raftpb.Message) error

+ RemoveMember func(ctx context.Context, id uint64) error

+ Start func()

+ Stop func()

+ UpdateMember func(ctx context.Context, updateMemb Member) error

+ type ServerConfig struct

+ ClientURLs types.URLs

+ Cluster *Cluster

+ DataDir string

+ DiscoveryProxy string

+ DiscoveryURL string

+ ElectionTicks int

+ ForceNewCluster bool

+ MaxSnapFiles uint

+ MaxWALFiles uint

+ Name string

+ NewCluster bool

+ PeerURLs types.URLs

+ SnapCount uint64

+ TickMs uint

+ Transport *http.Transport

+ func (c *ServerConfig) Print()

+ func (c *ServerConfig) PrintWithInitial()

+ func (c *ServerConfig) ShouldDiscover() bool

+ func (c *ServerConfig) SnapDir() string

+ func (c *ServerConfig) VerifyBootstrapConfig() error

+ func (c *ServerConfig) WALDir() string

+ type SortableMemberSlice []*Member

+ func (s SortableMemberSlice) Len() int

+ func (s SortableMemberSlice) Less(i, j int) bool

+ func (s SortableMemberSlice) Swap(i, j int)

+ type SortableMemberSliceByPeerURLs []*Member

+ func (p SortableMemberSliceByPeerURLs) Len() int

+ func (p SortableMemberSliceByPeerURLs) Less(i, j int) bool

+ func (p SortableMemberSliceByPeerURLs) Swap(i, j int)

+ type Storage interface

+ Close func() error

+ Cut func() error

+ Save func(st raftpb.HardState, ents []raftpb.Entry) error

+ SaveSnap func(snap raftpb.Snapshot) error

+ func NewStorage(w *wal.WAL, s *snap.Snapshotter) Storage