process

Documentation

Index

• Constants
• func GetDataRegistry() *data.Register
• func GetLogger() *logger.Logger
• func GetMembershipCoordinator() *membership.Coordinator
• func GetMembershipRegister() *membership.Register
• func GetPropertyAsBoolean(key string) bool
• func GetPropertyAsInteger(key string) int
• func GetPropertyAsString(key string) string
• func GetStorageKeyValueRegister() *storage.KeyValueRegister
• func GetSystemCoordinator() *system.Coordinator
• func Initialize(processID int, processGroupID int, processType string, ...) error
• func SetProperty(key string, value interface{})

Constants

const (
	PrimaryProcessType = "Primary"
	WorkerProcessType  = "Worker"
)

Functions

func GetDataRegistry

func GetDataRegistry() *data.Register

func GetLogger

func GetLogger() *logger.Logger

func GetMembershipCoordinator

func GetMembershipCoordinator() *membership.Coordinator

func GetMembershipRegister

func GetMembershipRegister() *membership.Register

func GetPropertyAsBoolean

func GetPropertyAsBoolean(key string) bool

func GetPropertyAsInteger

func GetPropertyAsInteger(key string) int

func GetPropertyAsString

func GetPropertyAsString(key string) string

func GetStorageKeyValueRegister

func GetStorageKeyValueRegister() *storage.KeyValueRegister

func GetSystemCoordinator

func GetSystemCoordinator() *system.Coordinator

func Initialize

func Initialize(processID int, processGroupID int, processType string, publicInternetAddress string, zookeeperClusterInternetAddresses []string) error

func SetProperty

func SetProperty(key string, value interface{})