cluster

Documentation

Index

• type Manager
  • func NewManager(opts ...Option) *Manager
  • func (m *Manager) Close()
  • func (m *Manager) Nodes() []*Node
  • func (m *Manager) Update(config *config.Config)
• type Node
  • func NewNode(opts ...Option) *Node
  • func (n *Node) AdminAddr() string
  • func (n *Node) ClusterState() *cluster.State
  • func (n *Node) GossipAddr() string
  • func (n *Node) ProxyAddr() string
  • func (n *Node) RootCAPool() *x509.CertPool
  • func (n *Node) Start()
  • func (n *Node) Stop()
  • func (n *Node) UpstreamAddr() string
• type Option
  • func WithAuthConfig(config auth.Config) Option
  • func WithJoin(join []string) Option
  • func WithLogger(logger log.Logger) Option
  • func WithTLS(tls bool) Option

Types

type Manager

type Manager struct {
	// contains filtered or unexported fields
}

func NewManager

func NewManager(opts ...Option) *Manager

func (*Manager) Close

func (m *Manager) Close()

func (*Manager) Nodes

func (m *Manager) Nodes() []*Node

func (*Manager) Update

func (m *Manager) Update(config *config.Config)

type Node

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

func NewNode

func NewNode(opts ...Option) *Node

func (*Node) AdminAddr

func (n *Node) AdminAddr() string

func (*Node) ClusterState

func (n *Node) ClusterState() *cluster.State

func (*Node) GossipAddr

func (n *Node) GossipAddr() string

func (*Node) ProxyAddr

func (n *Node) ProxyAddr() string

func (*Node) RootCAPool

func (n *Node) RootCAPool() *x509.CertPool

func (*Node) Start

func (n *Node) Start()

func (*Node) Stop

func (n *Node) Stop()

func (*Node) UpstreamAddr

func (n *Node) UpstreamAddr() string

type Option

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

func WithAuthConfig

func WithAuthConfig(config auth.Config) Option

WithAuthConfig configures the upstream authentication config.

func WithJoin

func WithJoin(join []string) Option

WithJoin configures the nodes to join.

func WithLogger

func WithLogger(logger log.Logger) Option

WithLogger configures the logger. Defaults to no output.

func WithTLS

func WithTLS(tls bool) Option

WithTLS configures the node ports to use TLS.