cluster

Documentation

Index

• Constants
• func DecodeMessage(buf []byte, out interface{}) error
• func EncodeMessage(msg interface{}) ([]byte, error)
• type Cluster
  • func NewMockCluster() Cluster
  • func NewSerfCluster(serf *serf.Serf, logger *log.Logger) Cluster
• type MockCluster
  • func (c MockCluster) RegisterService(ss *api.AppService) error
  • func (c MockCluster) UnregisterService(addr string) error
• type SerfCluster
  • func (c *SerfCluster) GetSerf() *serf.Serf
  • func (c *SerfCluster) RegisterService(ss *api.AppService) error
  • func (c *SerfCluster) UnregisterService(addr string) error

Constants

const (
	RSCommand  = "rs"
	URSCommand = "us"
)

Functions

func DecodeMessage

func DecodeMessage(buf []byte, out interface{}) error

func EncodeMessage

func EncodeMessage(msg interface{}) ([]byte, error)

Types

type Cluster

type Cluster interface {
	RegisterService(ss *api.AppService) error
	UnregisterService(addr string) error
}

func NewMockCluster

func NewMockCluster() Cluster

func NewSerfCluster

func NewSerfCluster(serf *serf.Serf, logger *log.Logger) Cluster

type MockCluster

type MockCluster struct {
}

func (MockCluster) RegisterService

func (c MockCluster) RegisterService(ss *api.AppService) error

func (MockCluster) UnregisterService

func (c MockCluster) UnregisterService(addr string) error

type SerfCluster

type SerfCluster struct {
	// contains filtered or unexported fields
}

func (*SerfCluster) GetSerf

func (c *SerfCluster) GetSerf() *serf.Serf

func (*SerfCluster) RegisterService

func (c *SerfCluster) RegisterService(ss *api.AppService) error

func (*SerfCluster) UnregisterService

func (c *SerfCluster) UnregisterService(addr string) error