server

package

Go to main page

Versions in this module

v0

v0.4.9

Mar 31, 2015

Changes in this version

type Server

+ func (s *Server) SnapshotHandler(w http.ResponseWriter, req *http.Request) error

v0.4.6

Jul 29, 2014

v0.4.5

Jul 8, 2014

Changes in this version

+ const DefaultReadTimeout

+ const DefaultWriteTimeout

v0.4.3

Jun 8, 2014

Changes in this version

+ const ActiveMonitorTimeout

+ const ClusterConfigKey

+ const DefaultActiveSize

+ const DefaultRemoveDelay

+ const DefaultSyncInterval

+ const MaxHeartbeatTimeoutBackoff

+ const MinActiveSize

+ const MinRemoveDelay

+ const MinSyncInterval

+ const PeerActivityMonitorTimeout

+ func TLSServerConfig(info *TLSInfo) *tls.Config

+ type Client struct

+ func NewClient(transport http.RoundTripper) *Client

+ func (c *Client) AddMachine(url string, cmd *JoinCommand) (uint64, *etcdErr.Error)

+ func (c *Client) CheckVersion(url string, version int) (bool, *etcdErr.Error)

+ func (c *Client) GetClusterConfig(url string) (*ClusterConfig, *etcdErr.Error)

+ func (c *Client) GetMachines(url string) ([]*machineMessage, *etcdErr.Error)

+ func (c *Client) GetVersion(url string) (int, *etcdErr.Error)

+ type ClusterConfig struct

+ ActiveSize int

+ RemoveDelay float64

+ SyncInterval float64

+ func NewClusterConfig() *ClusterConfig

+ type HEADResponseWriter struct

+ func (w *HEADResponseWriter) Write([]byte) (int, error)

type PeerServer

+ func (s *PeerServer) ClusterConfig() *ClusterConfig

+ func (s *PeerServer) FindCluster(discoverURL string, peers []string) (toStart bool, possiblePeers []string, err error)

+ func (s *PeerServer) InitNewCluster(clusterConfig *ClusterConfig)

+ func (s *PeerServer) RemoveNotify() <-chan bool

+ func (s *PeerServer) SetClusterConfig(c *ClusterConfig)

+ func (s *PeerServer) SetJoinIndex(joinIndex uint64)

+ func (s *PeerServer) SetRegistry(registry *Registry)

+ func (s *PeerServer) SetStore(store store.Store)

type Registry

+ func (r *Registry) Exists(name string) bool

+ func (r *Registry) Names() []string

+ func (r *Registry) PeerHost(name string) (string, bool)

+ func (r *Registry) UpdatePeerURL(name string, peerURL string) error

type Server

+ func (s *Server) PeerHost(name string) (string, bool)

+ func (s *Server) SetRegistry(registry *Registry)

+ func (s *Server) SetStore(store store.Store)

+ type SetClusterConfigCommand struct

+ Config *ClusterConfig

+ func (c *SetClusterConfigCommand) Apply(context raft.Context) (interface{}, error)

+ func (c *SetClusterConfigCommand) CommandName() string

+ type StandbyServer struct

+ Config StandbyServerConfig

+ func NewStandbyServer(config StandbyServerConfig, client *Client) *StandbyServer

+ func (s *StandbyServer) ClientHTTPHandler() http.Handler

+ func (s *StandbyServer) ClusterLeader() *machineMessage

+ func (s *StandbyServer) ClusterSize() int

+ func (s *StandbyServer) ClusterURLs() []string

+ func (s *StandbyServer) IsRunning() bool

+ func (s *StandbyServer) JoinIndex() uint64

+ func (s *StandbyServer) RemoveNotify() <-chan bool

+ func (s *StandbyServer) SetRaftServer(raftServer raft.Server)

+ func (s *StandbyServer) SetSyncInterval(second float64)

+ func (s *StandbyServer) Start()

+ func (s *StandbyServer) Stop()

+ func (s *StandbyServer) SyncCluster(peers []string) error

+ type StandbyServerConfig struct

+ ClientURL string

+ DataDir string

+ Name string

+ PeerScheme string

+ PeerURL string

v0.3.0

Feb 7, 2014

Changes in this version

+ const RegistryKey

+ const ReleaseVersion

+ const ThresholdMonitorTimeout

+ const Version

+ func NewListener(addr string) (net.Listener, error)

+ func NewPackageStats(now time.Time, size int) *packageStats

+ func NewRaftFollowersStats(name string) *raftFollowersStats

+ func NewRaftServerStats(name string) *raftServerStats

+ func NewTLSListener(addr string, cfg *tls.Config) (net.Listener, error)

+ func NewTransporter(followersStats *raftFollowersStats, serverStats *raftServerStats, ...) *transporter

+ func Usage() string

+ type JoinCommand struct

+ EtcdURL string

+ MaxVersion int

+ MinVersion int

+ Name string

+ RaftURL string

+ func NewJoinCommand(minVersion int, maxVersion int, name, raftUrl, etcdUrl string) *JoinCommand

+ func (c *JoinCommand) Apply(context raft.Context) (interface{}, error)

+ func (c *JoinCommand) CommandName() string

+ func (c *JoinCommand) NodeName() string

+ type PeerServer struct

+ Config PeerServerConfig

+ func NewPeerServer(psConfig PeerServerConfig, registry *Registry, store store.Store, ...) *PeerServer

+ func (ps *PeerServer) AppendEntriesHttpHandler(w http.ResponseWriter, req *http.Request)

+ func (ps *PeerServer) EtcdURLHttpHandler(w http.ResponseWriter, req *http.Request)

+ func (ps *PeerServer) GetLogHttpHandler(w http.ResponseWriter, req *http.Request)

+ func (ps *PeerServer) JoinHttpHandler(w http.ResponseWriter, req *http.Request)

+ func (ps *PeerServer) NameHttpHandler(w http.ResponseWriter, req *http.Request)

+ func (ps *PeerServer) RemoveHttpHandler(w http.ResponseWriter, req *http.Request)

+ func (ps *PeerServer) SnapshotHttpHandler(w http.ResponseWriter, req *http.Request)

+ func (ps *PeerServer) SnapshotRecoveryHttpHandler(w http.ResponseWriter, req *http.Request)

+ func (ps *PeerServer) UpgradeHttpHandler(w http.ResponseWriter, req *http.Request)

+ func (ps *PeerServer) VersionCheckHttpHandler(w http.ResponseWriter, req *http.Request)

+ func (ps *PeerServer) VersionHttpHandler(w http.ResponseWriter, req *http.Request)

+ func (ps *PeerServer) VoteHttpHandler(w http.ResponseWriter, req *http.Request)

+ func (s *PeerServer) HTTPHandler() http.Handler

+ func (s *PeerServer) PeerStats() []byte

+ func (s *PeerServer) RaftServer() raft.Server

+ func (s *PeerServer) SetRaftServer(raftServer raft.Server)

+ func (s *PeerServer) SetServer(server *Server)

+ func (s *PeerServer) Start(snapshot bool, cluster []string) error

+ func (s *PeerServer) Stats() []byte

+ func (s *PeerServer) Stop()

+ func (s *PeerServer) Upgradable() error

+ type PeerServerConfig struct

+ MaxClusterSize int

+ Name string

+ RetryInterval float64

+ RetryTimes int

+ Scheme string

+ SnapshotCount int

+ URL string

+ type Registry struct

+ func NewRegistry(s store.Store) *Registry

+ func (r *Registry) ClientURL(name string) (string, bool)

+ func (r *Registry) ClientURLs(leaderName, selfName string) []string

+ func (r *Registry) Count() int

+ func (r *Registry) Invalidate(name string)

+ func (r *Registry) PeerURL(name string) (string, bool)

+ func (r *Registry) PeerURLs(leaderName, selfName string) []string

+ func (r *Registry) Register(name string, peerURL string, machURL string) error

+ func (r *Registry) Unregister(name string) error

+ type RemoveCommand struct

+ Name string

+ func (c *RemoveCommand) Apply(context raft.Context) (interface{}, error)

+ func (c *RemoveCommand) CommandName() string

+ type Server struct

+ Name string

+ func New(name, url string, peerServer *PeerServer, registry *Registry, ...) *Server

+ func (s *Server) ClientURL(name string) (string, bool)

+ func (s *Server) CommitIndex() uint64

+ func (s *Server) Dispatch(c raft.Command, w http.ResponseWriter, req *http.Request) error

+ func (s *Server) EnableTracing()

+ func (s *Server) GetLeaderHandler(w http.ResponseWriter, req *http.Request) error

+ func (s *Server) GetLeaderStatsHandler(w http.ResponseWriter, req *http.Request) error

+ func (s *Server) GetMetricsHandler(w http.ResponseWriter, req *http.Request) error

+ func (s *Server) GetPeersHandler(w http.ResponseWriter, req *http.Request) error

+ func (s *Server) GetStatsHandler(w http.ResponseWriter, req *http.Request) error

+ func (s *Server) GetStoreStatsHandler(w http.ResponseWriter, req *http.Request) error

+ func (s *Server) GetVersionHandler(w http.ResponseWriter, req *http.Request) error

+ func (s *Server) HTTPHandler() http.Handler

+ func (s *Server) Leader() string

+ func (s *Server) PeerURL(name string) (string, bool)

+ func (s *Server) SpeedTestHandler(w http.ResponseWriter, req *http.Request) error

+ func (s *Server) State() string

+ func (s *Server) Store() store.Store

+ func (s *Server) Term() uint64

+ func (s *Server) URL() string

+ type TLSInfo struct

+ CAFile string

+ CertFile string

+ KeyFile string

+ func (info TLSInfo) ClientConfig() (*tls.Config, error)

+ func (info TLSInfo) Scheme() string

+ func (info TLSInfo) ServerConfig() (*tls.Config, error)

v0.2.0-rc4

Dec 23, 2013

v0.2.0-rc3

Dec 16, 2013

v0.2.0-rc2

Dec 6, 2013

v0.2.0-rc1

Nov 14, 2013

v0.2.0-rc0

Oct 17, 2013

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL