cluster

Documentation

Index

• Constants
• Variables
• type Conn
  • func NewConn(id uint64, address string, tlsCertFile string) (*Conn, error)
  • func (this *Conn) AddNode(id uint64, address string)
  • func (this *Conn) Address() string
  • func (this *Conn) Close()
  • func (this *Conn) Dial(id uint64) (*grpc.ClientConn, error)
  • func (this *Conn) DialAddress(address string) (*grpc.ClientConn, error)
  • func (this *Conn) Id() uint64
  • func (this *Conn) NodeChangesNotifications() <-chan *nodesChange
  • func (this *Conn) NodeIds() []uint64
  • func (this *Conn) Nodes() map[uint64]string
  • func (this *Conn) RemoveNode(id uint64)

Constants

const (
	NodesChangeAddNode nodesChangeType = iota
	NodesChangeRemoveNode
)

Variables

var (
	NodeAddressNotFoundError error = errors.New("Node address not found")
)

Types

type Conn

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

func NewConn

func NewConn(id uint64, address string, tlsCertFile string) (*Conn, error)

func (*Conn) AddNode

func (this *Conn) AddNode(id uint64, address string)

func (*Conn) Address

func (this *Conn) Address() string

func (*Conn) Close

func (this *Conn) Close()

func (*Conn) Dial

func (this *Conn) Dial(id uint64) (*grpc.ClientConn, error)

func (*Conn) DialAddress

func (this *Conn) DialAddress(address string) (*grpc.ClientConn, error)

func (*Conn) Id

func (this *Conn) Id() uint64

func (*Conn) NodeChangesNotifications

func (this *Conn) NodeChangesNotifications() <-chan *nodesChange

func (*Conn) NodeIds

func (this *Conn) NodeIds() []uint64

func (*Conn) Nodes

func (this *Conn) Nodes() map[uint64]string

func (*Conn) RemoveNode

func (this *Conn) RemoveNode(id uint64)