runtime

Documentation

Index

• func NewRuntime(nodeMngr pkg.NodeManager, parser pkg.CliParser) *runtime
• type GlobalRegistryInterface
  • func GlobalRegistry() GlobalRegistryInterface
• type Hook
• type HookHandler
• type NodePool
• type NodeStatus
• type ServiceEndpoint
• type ServiceLocator

Functions

func NewRuntime

func NewRuntime(nodeMngr pkg.NodeManager, parser pkg.CliParser) *runtime

Types

type GlobalRegistryInterface

type GlobalRegistryInterface interface {
	Runtime() rt.Runtime
	SetRuntime(rt.Runtime)
	App() pkg.App
	SetApp(pkg.App)
	RegisterHook(Hook, HookHandler)
	InvokeHooks(Hook, ...interface{}) error
	ServiceLocator(string) ServiceLocator
}

func GlobalRegistry

func GlobalRegistry() GlobalRegistryInterface

type Hook

type Hook int

const (
	ServiceInitHook Hook = iota + 1
	CmdCreateDbHook
	CmdMigrateDbHook
)

type HookHandler

type HookHandler func(...interface{}) error

type NodePool

type NodePool interface {
	Add(pkg.Node)
	Remove(i.NodeId)
	FindById(i.NodeId) pkg.Node
	FilterByStatus(NodeStatus) NodePool
	Len() int
}

type NodeStatus

type NodeStatus int

const (
	Available NodeStatus = iota + 1
)

type ServiceEndpoint

type ServiceEndpoint interface {
	Address() net.Addr
	EncKey() []byte
}

type ServiceLocator

type ServiceLocator interface {
	FindByMethodName(string) NodePool
	ServiceNameByMethod(string) string
}