atomix

package

v0.2.0 Latest Latest Go to latest Published: May 21, 2020 License: Apache-2.0 Imports: 8 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Node struct {
	ID string
	// contains filtered or unexported fields
}

Node is an Atomix node

func NewNode(nodeID string, config *database.DatabaseConfig, protocol node.Protocol, registry *node.Registry, opts ...NodeOption) *Node

NewNode creates a new node running the given protocol

func (n *Node) Start() error

Start starts the node

func (n *Node) Stop() error

Stop stops the node

type NodeOption interface {
	// contains filtered or unexported methods
}

NodeOption is an option for constructing a Node

func WithLocal(lis net.Listener) NodeOption

WithLocal sets the node to local mode for testing

func WithPort(port int) NodeOption

WithPort sets the port on the node