Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

manager

package

Go to main page

Versions in this module

v0

v0.1.11

May 3, 2017

Changes in this version

+ const SWAN_ATOMIC_STORE_NODE_PATH

+ const SWAN_LEADER_ELECTION_NODE_PATH

+ const ZK_FLAG_NONE

+ var ErrNormalExit = errors.New("normal exit 0")

+ var ZK_DEFAULT_ACL = zk.WorldACL(zk.PermAll)

+ type Leadership uint8

+ const LeadershipFollower

+ const LeadershipLeader

+ const LeadershipUnknown

+ func (l Leadership) String() string

v0.1.9

Mar 20, 2017

v0.1.7

Mar 6, 2017

Changes in this version

+ const JoinRetryInterval

type Manager

+ JoinAddrs []string

+ NodeInfo types.Node

+ func (manager *Manager) GetManagers() []types.Node

+ func (manager *Manager) InitAndStart(ctx context.Context) error

+ func (manager *Manager) JoinAndStart(ctx context.Context) error

+ func (manager *Manager) JoinToCluster(nodeInfo types.Node) ([]types.Node, error)

type ManagerApi

+ func (api *ManagerApi) AddNode(request *restful.Request, response *restful.Response)

+ func (api *ManagerApi) GetNodes(request *restful.Request, response *restful.Response)

+ func (api *ManagerApi) RemoveNode(request *restful.Request, response *restful.Response)

+ func (api *ManagerApi) StopNode(request *restful.Request, response *restful.Response)

v0.1.5

Feb 27, 2017

v0.1.3

Feb 17, 2017

Changes in this version

type Manager

+ func (manager *Manager) AddNode(node types.Node) error

+ func (manager *Manager) AddRaftNode(swanNode types.Node) error

+ func (manager *Manager) GetNode(nodeID string) (types.Node, error)

+ func (manager *Manager) GetNodes() []types.Node

+ func (manager *Manager) LoadNodeData() error

+ func (manager *Manager) RemoveAgentAcceptor(agentID string)

+ func (manager *Manager) RemoveNode(node types.Node) error

v0.1.1

Jan 17, 2017

Changes in this version

+ type Manager struct

+ CancelFunc context.CancelFunc

+ func New(db *bolt.DB) (*Manager, error)

+ func (manager *Manager) AddAgent(agent types.Agent) error

+ func (manager *Manager) AddAgentAcceptor(agent types.Agent)

+ func (manager *Manager) DeleteAgent(agentID string) error

+ func (manager *Manager) GetAgent(agentID string) types.Agent

+ func (manager *Manager) GetAgents() map[string]types.Agent

+ func (manager *Manager) LoadAgentData() error

+ func (manager *Manager) SendAgentInitData(agent types.Agent)

+ func (manager *Manager) Start(ctx context.Context) error

+ func (manager *Manager) Stop(cancel context.CancelFunc)

+ func (manager *Manager) UpdateAgent(agent types.Agent) error

+ type ManagerApi struct

+ func (api *ManagerApi) AddAgent(request *restful.Request, response *restful.Response)

+ func (api *ManagerApi) GetAgents(request *restful.Request, response *restful.Response)

+ func (api *ManagerApi) Register(container *restful.Container)

+ type ManagerState struct

+ Cluster string

+ FrameworkId string

+ LeaderId uint64

+ RaftId int