server

package

Go to main page

Versions in this module

v0

v0.4.2

Jun 2, 2014

Changes in this version

type StandbyServer

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

v0.4.1

May 21, 2014

v0.4.0

May 21, 2014

Changes in this version

+ const ActiveMonitorTimeout

+ const ClusterConfigKey

+ const DefaultActiveSize

+ const DefaultRemoveDelay

+ const DefaultSyncInterval

+ 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) 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.2.0

Dec 23, 2013

Changes in this version

+ const DefaultSystemConfigPath

+ const RegistryKey

+ const Version

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

+ func Usage() string

+ type Config struct

+ Addr string

+ BindAddr string

+ CAFile string

+ CPUProfileFile string

+ CertFile string

+ CorsOrigins []string

+ DataDir string

+ Force bool

+ KeyFile string

+ MaxClusterSize int

+ MaxResultBuffer int

+ MaxRetryAttempts int

+ Name string

+ Peer struct{ ... }

+ Peers []string

+ PeersFile string

+ ShowHelp bool

+ ShowVersion bool

+ Snapshot bool

+ SnapshotCount int

+ SystemPath string

+ Verbose bool

+ VeryVerbose bool

+ func NewConfig() *Config

+ func (c *Config) DataDirFromName()

+ func (c *Config) Info() (*Info, error)

+ func (c *Config) Load(arguments []string) error

+ func (c *Config) LoadEnv() error

+ func (c *Config) LoadFile(path string) error

+ func (c *Config) LoadFlags(arguments []string) error

+ func (c *Config) LoadPeersFile() error

+ func (c *Config) LoadSystemFile() error

+ func (c *Config) NameFromHostname()

+ func (c *Config) PeerTLSConfig() (TLSConfig, error)

+ func (c *Config) PeerTLSInfo() TLSInfo

+ func (c *Config) Reset() error

+ func (c *Config) Sanitize() error

+ func (c *Config) TLSConfig() (TLSConfig, error)

+ func (c *Config) TLSInfo() TLSInfo

+ type Info struct

+ EtcdListenHost string

+ EtcdTLS TLSInfo

+ EtcdURL string

+ Name string

+ RaftListenHost string

+ RaftTLS TLSInfo

+ RaftURL 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(server raft.Server) (interface{}, error)

+ func (c *JoinCommand) CommandName() string

+ func (c *JoinCommand) NodeName() string

+ type PeerServer struct

+ ElectionTimeout time.Duration

+ HeartbeatTimeout time.Duration

+ MaxClusterSize int

+ RetryTimes int

+ func NewPeerServer(name string, path string, url string, bindAddr string, tlsConf *TLSConfig, ...) *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) Close()

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

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

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

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

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

+ func (s *PeerServer) Upgradable() error

+ 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(server raft.Server) (interface{}, error)

+ func (c *RemoveCommand) CommandName() string

+ type Server struct

+ func New(name string, urlStr string, bindAddr string, tlsConf *TLSConfig, ...) *Server

+ func (s *Server) AllowOrigins(origins []string) error

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

+ func (s *Server) Close()

+ func (s *Server) CommitIndex() uint64

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

+ 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) 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) Leader() string

+ func (s *Server) ListenAndServe() error

+ func (s *Server) OriginAllowed(origin string) bool

+ 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 TLSConfig struct

+ Client tls.Config

+ Scheme string

+ Server tls.Config

+ type TLSInfo struct

+ CAFile string

+ CertFile string

+ KeyFile string

+ func (info TLSInfo) Config() (TLSConfig, error)

v0.2.0-rc4

Dec 23, 2013

v0.2.0-rc3

Dec 16, 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