Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ClusterNode ¶
type ClusterNode interface { Listen(ip string, port int32) error Command(n *types.Node, command types.Command) error Aknoledge(n *types.Node) error Discover(network *net.IPNet, ports types.Ports) Stop() error List() []types.Node UsedFormat() cio.ParserFormat EnableRegistryPersistence(registryFile string) error DisableRegistryPersistence() error EnablePlugins(pluginFolder string, pluginExtension string) error DisablePlugins() error DumpConfigToFile(configFile string) }
type ClusterRegistry ¶
type ClusterRegistry interface { Register(n *types.Node) error Update(field string, filter regexp.Regexp, n types.Node) error Recover(field string, filter regexp.Regexp) ([]*types.Node, error) List() []types.Node EnablePersistence(registryFile string) error DisablePersistence() error IsPersistenceEnabled() bool RegistryFilePath() string RegistryFileEncodingFormat() cio.ParserFormat ChangeEncodingFormat(encodingFormat cio.ParserFormat) error }
func NewClusterRegistry ¶
func NewClusterRegistry(file string) ClusterRegistry
func NewClusterRegistryWithInternal ¶
func NewClusterRegistryWithInternal(file string, encoding cio.ParserFormat) ClusterRegistry
func NewInMemoryClusterRegistry ¶
func NewInMemoryClusterRegistry() ClusterRegistry
Click to show internal directories.
Click to hide internal directories.