Documentation ¶
Index ¶
- func KeyToPath(key string) string
- func PathToKey(path string) string
- type Agent
- type Domain
- type Process
- type RuntimeConfig
- type StaticConfig
- type ZkDAO
- func (zkdao ZkDAO) CreateEphemeral(path string, data []byte) (string, error)
- func (zkdao *ZkDAO) GetValue(path string) ([]byte, error)
- func (zkdao *ZkDAO) LoadAgent(key string, recursive bool) (Agent, error)
- func (zkdao *ZkDAO) LoadDomain(key string, recursive bool) (Domain, error)
- func (zkdao *ZkDAO) LoadDomains(key string, recursive bool) ([]Domain, error)
- func (zkdao *ZkDAO) LoadProcess(key string, recursive bool) (Process, error)
- func (zkdao *ZkDAO) LoadRuntimeConfig(key string, recursive bool) (RuntimeConfig, error)
- func (zkdao *ZkDAO) LoadStaticConfig(key string, recursive bool) (StaticConfig, error)
- func (zkdao *ZkDAO) RemoveRecursive(path string) error
- func (zkdao *ZkDAO) SetValue(path string, data []byte) error
- func (zkdao *ZkDAO) UpdateAgent(key string, agent Agent, recursive bool) error
- func (zkdao *ZkDAO) UpdateDomain(key string, domain Domain, recursive bool) error
- func (zkdao *ZkDAO) UpdateProcess(key string, process Process, recursive bool) error
- func (zkdao *ZkDAO) UpdateRuntimeConfig(key string, runtime RuntimeConfig, recursive bool) error
- func (zkdao *ZkDAO) UpdateStaticConfig(key string, config StaticConfig, recursive bool) error
- func (zkdao *ZkDAO) Watch(path string, watchChannel chan<- zk.Event) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Domain ¶
type Domain struct { Name string Key string Runtime RuntimeConfig Config StaticConfig }
type RuntimeConfig ¶
type RuntimeConfig struct {
Agents []Agent
}
type StaticConfig ¶
type ZkDAO ¶
type ZkDAO struct {
// contains filtered or unexported fields
}
func (ZkDAO) CreateEphemeral ¶
Creates an ephemeral node for the given path
func (*ZkDAO) LoadDomain ¶
func (*ZkDAO) LoadDomains ¶
func (*ZkDAO) LoadProcess ¶
func (*ZkDAO) LoadRuntimeConfig ¶
func (zkdao *ZkDAO) LoadRuntimeConfig(key string, recursive bool) (RuntimeConfig, error)
func (*ZkDAO) LoadStaticConfig ¶
func (zkdao *ZkDAO) LoadStaticConfig(key string, recursive bool) (StaticConfig, error)
func (*ZkDAO) RemoveRecursive ¶
func (*ZkDAO) UpdateAgent ¶
func (*ZkDAO) UpdateDomain ¶
func (*ZkDAO) UpdateProcess ¶
func (*ZkDAO) UpdateRuntimeConfig ¶
func (zkdao *ZkDAO) UpdateRuntimeConfig(key string, runtime RuntimeConfig, recursive bool) error
func (*ZkDAO) UpdateStaticConfig ¶
func (zkdao *ZkDAO) UpdateStaticConfig(key string, config StaticConfig, recursive bool) error
Click to show internal directories.
Click to hide internal directories.