role

Documentation

Index

• type Role
  • func (r *Role) GetRole() RoleType
  • func (r *Role) IsMaster() bool
  • func (r *Role) SetRole(role RoleType)
  • func (r *Role) WatchRole(zkAddr string, path string) error
• type RoleInterface
  • func NewRoleController(localIP string, metricPort uint, zkAddr string, watchPath string) (RoleInterface, error)
• type RoleType

Types

type Role

type Role struct {
	CurrentRole RoleType
	// contains filtered or unexported fields
}

func (*Role) GetRole

func (r *Role) GetRole() RoleType

func (*Role) IsMaster

func (r *Role) IsMaster() bool

func (*Role) SetRole

func (r *Role) SetRole(role RoleType)

func (*Role) WatchRole

func (r *Role) WatchRole(zkAddr string, path string) error

type RoleInterface

type RoleInterface interface {
	IsMaster() bool
}

func NewRoleController

func NewRoleController(localIP string, metricPort uint, zkAddr string, watchPath string) (RoleInterface, error)

type RoleType

type RoleType string

const (
	MasterRole RoleType = "Master"
	SlaveRole  RoleType = "Slave"
)