coordinator

Documentation

Index

• Constants
• func NewClusterScanKeyWith(cluster string) coordinator.Key
• func NewNodeKeyWith(node cluster.Node) coordinator.Key
• func NewNodeScanKey() coordinator.Key
• func NewNodeWith(obj *NodeObject) (cluster.Node, error)
• type MessageQueue
  • func NewMessageQueue() *MessageQueue
  • func (q *MessageQueue) EnqueueMessage(msg coordinator.Message)
  • func (q *MessageQueue) PopMessage() (coordinator.Message, error)
  • func (q *MessageQueue) PushMessage(msg coordinator.Message)
• type NodeObject
  • func NewNodeObject() *NodeObject
  • func NewNodeObjectWith(node cluster.Node) *NodeObject
• type Service
  • func NewServiceWith(service core.CoordinatorService) Service
• type StateType
  • func (t StateType) String() string

Constants

const (
	DefaultStoreScanInterval = time.Second
)

Functions

func NewClusterScanKeyWith

func NewClusterScanKeyWith(cluster string) coordinator.Key

NewClusterScanKeyWith returns a new scan node key to get all node states with the specified cluster.

func NewNodeKeyWith

func NewNodeKeyWith(node cluster.Node) coordinator.Key

NewNodeKeyWith returns a new node key with the specified node.

func NewNodeScanKey

func NewNodeScanKey() coordinator.Key

NewNodeScanKey returns a new scan node key to get all node states.

func NewNodeWith

func NewNodeWith(obj *NodeObject) (cluster.Node, error)

NewNodeWith returns a new node with the specified node object.

Types

type MessageQueue

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

MessageQueue is a queue for coordinator message.

func NewMessageQueue

func NewMessageQueue() *MessageQueue

NewMessageQueue returns a new messageQueue.

func (*MessageQueue) EnqueueMessage

func (q *MessageQueue) EnqueueMessage(msg coordinator.Message)

EnqueueMessage appends a message to the queue.

func (*MessageQueue) PopMessage

func (q *MessageQueue) PopMessage() (coordinator.Message, error)

PopMessage removes a message from the queue.

func (*MessageQueue) PushMessage

func (q *MessageQueue) PushMessage(msg coordinator.Message)

PushMessage pushes a message to the queue.

type NodeObject

type NodeObject struct {
	ID      string
	Cluster string
	Host    string
	Clock   uint64
	Time    time.Time
	Status  string
}

NodeObject represents a store node state object.

func NewNodeObject

func NewNodeObject() *NodeObject

NewNodeObject returns a new node object.

func NewNodeObjectWith

func NewNodeObjectWith(node cluster.Node) *NodeObject

NewNodeObjectWith returns a new node object with the specified node.

type Service

type Service interface {
	coordinator.Coordinator
	plugins.Service
	// SetNodeState posts the specified node status to the coordinator.
	SetNodeState(node cluster.Node) error
	// GetClusterState gets the current cluster state.
	GetClusterState(cluster string) (cluster.Cluster, error)
}

Service is an interface for the coordinator service.

func NewServiceWith

func NewServiceWith(service core.CoordinatorService) Service

NewService returns a new coordinator service with the specified core coordinator service.

type StateType

type StateType byte

StateType represents a coordinator state type.

const (
	// NodeState represents a node state.
	NodeState StateType = 'N'
)

func (StateType) String

func (t StateType) String() string

String returns the string representation of the state type.