Documentation
¶
Index ¶
- func ParseAddr(hostPort string) string
- func RegisterGossipHandler(mux *http.ServeMux, cluster *SwimCluster)
- type Member
- type MemberInfo
- type MemberListerAdapter
- type MemberStatus
- type SwimCluster
- func (c *SwimCluster) AliveMembers() []Member
- func (c *SwimCluster) HandleGossip(payload gossipPayload) gossipPayload
- func (c *SwimCluster) Join(ctx context.Context, seedAddrs ...string) error
- func (c *SwimCluster) Leave()
- func (c *SwimCluster) LocalID() string
- func (c *SwimCluster) Members() []Member
- func (c *SwimCluster) Start(ctx context.Context)
- func (c *SwimCluster) UpdateLocal(vmCount int, cpuCap int, memCap int64)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterGossipHandler ¶
func RegisterGossipHandler(mux *http.ServeMux, cluster *SwimCluster)
Types ¶
type MemberInfo ¶
type MemberListerAdapter ¶
type MemberListerAdapter struct {
Cluster *SwimCluster
}
func (*MemberListerAdapter) Members ¶
func (a *MemberListerAdapter) Members() []MemberInfo
type MemberStatus ¶
type MemberStatus string
const ( StatusAlive MemberStatus = "alive" StatusSuspect MemberStatus = "suspect" StatusDead MemberStatus = "dead" StatusLeft MemberStatus = "left" )
type SwimCluster ¶
type SwimCluster struct {
// contains filtered or unexported fields
}
func NewSwimCluster ¶
func NewSwimCluster(addr string, vmCount int, cpuCap int, memCap int64) *SwimCluster
func (*SwimCluster) AliveMembers ¶
func (c *SwimCluster) AliveMembers() []Member
func (*SwimCluster) HandleGossip ¶
func (c *SwimCluster) HandleGossip(payload gossipPayload) gossipPayload
func (*SwimCluster) Join ¶
func (c *SwimCluster) Join(ctx context.Context, seedAddrs ...string) error
func (*SwimCluster) Leave ¶
func (c *SwimCluster) Leave()
func (*SwimCluster) LocalID ¶
func (c *SwimCluster) LocalID() string
func (*SwimCluster) Members ¶
func (c *SwimCluster) Members() []Member
func (*SwimCluster) Start ¶
func (c *SwimCluster) Start(ctx context.Context)
func (*SwimCluster) UpdateLocal ¶
func (c *SwimCluster) UpdateLocal(vmCount int, cpuCap int, memCap int64)
Click to show internal directories.
Click to hide internal directories.