membership

Documentation

Index

• type Coordinator
• type Register
  • func New(coordinator Coordinator) (*Register, error)
  • func (obj *Register) AddProcessCPUUtilization(publicInternetAddress string, utilization int)
  • func (obj *Register) GetGroupAmount() int
  • func (obj *Register) GetSpecifiedWorkerProcessPublicInternetAddressesForRPC(groupId int, processIds []int, rpcBasePort int) ([]string, error)
  • func (obj *Register) GetWorkerProcessIDs(groupId int) []int
  • func (obj *Register) GetWorkerProcessPublicInternetAddressesForRPC(groupId int, rpcBasePort int) ([]string, error)

Types

type Coordinator

type Coordinator interface {
	WaitUntilProcessMembershipChanges() error
	GetProcessMembershipTable() (map[int]map[int]string, error)
	RegisterNewWorkerProcess(processId int, processGroupId int, processPublicInternetAddress string) error
}

type Register

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

func New

func New(coordinator Coordinator) (*Register, error)

func (*Register) AddProcessCPUUtilization

func (obj *Register) AddProcessCPUUtilization(publicInternetAddress string, utilization int)

func (*Register) GetGroupAmount

func (obj *Register) GetGroupAmount() int

func (*Register) GetSpecifiedWorkerProcessPublicInternetAddressesForRPC

func (obj *Register) GetSpecifiedWorkerProcessPublicInternetAddressesForRPC(groupId int, processIds []int, rpcBasePort int) ([]string, error)

func (*Register) GetWorkerProcessIDs

func (obj *Register) GetWorkerProcessIDs(groupId int) []int

func (*Register) GetWorkerProcessPublicInternetAddressesForRPC

func (obj *Register) GetWorkerProcessPublicInternetAddressesForRPC(groupId int, rpcBasePort int) ([]string, error)