cluster

Documentation

Index

• type ClusterNode
• type ClusterRegistry
  • func NewClusterRegistry(file string) ClusterRegistry
  • func NewClusterRegistryWithInternal(file string, encoding cio.ParserFormat) ClusterRegistry
  • func NewInMemoryClusterRegistry() ClusterRegistry

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