mongo

Documentation

Index

• type NodeGroupStore
  • func NewNodeGroupStore(client *mgo.DbClient, clusterKey interface{}) *NodeGroupStore
  • func (store NodeGroupStore) ReadNodeGroup(ctx context.Context) (*cluster.NodeGroup, error)
  • func (store NodeGroupStore) SaveNodes(ctx context.Context, group *cluster.NodeGroup) error
• type NodeMessageQueue
  • func NewNodeEventQueue(client *mgo.DbClient) *NodeMessageQueue
  • func (store *NodeMessageQueue) Close() error
  • func (store *NodeMessageQueue) PushNodeTransaction(ctx context.Context, transaction cluster.Transaction) error
  • func (store *NodeMessageQueue) WaitMessages(ctx context.Context) ([]cluster.NodeMessage, error)
• type ScheduleQueue
  • func NewScheduleQueue(nodeID string, client *mgo.DbClient) *ScheduleQueue
  • func (queue *ScheduleQueue) Ack(ctx context.Context, node cluster.Node) error
  • func (queue *ScheduleQueue) Close() error
  • func (queue *ScheduleQueue) WaitEvent(ctx context.Context) (*cluster.NodeScheduleEvent, error)

Types

type NodeGroupStore

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

func NewNodeGroupStore

func NewNodeGroupStore(client *mgo.DbClient, clusterKey interface{}) *NodeGroupStore

func (NodeGroupStore) ReadNodeGroup

func (store NodeGroupStore) ReadNodeGroup(ctx context.Context) (*cluster.NodeGroup, error)

func (NodeGroupStore) SaveNodes

func (store NodeGroupStore) SaveNodes(ctx context.Context, group *cluster.NodeGroup) error

type NodeMessageQueue

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

func NewNodeEventQueue

func NewNodeEventQueue(client *mgo.DbClient) *NodeMessageQueue

func (*NodeMessageQueue) Close

func (store *NodeMessageQueue) Close() error

func (*NodeMessageQueue) PushNodeTransaction

func (store *NodeMessageQueue) PushNodeTransaction(ctx context.Context, transaction cluster.Transaction) error

func (*NodeMessageQueue) WaitMessages

func (store *NodeMessageQueue) WaitMessages(ctx context.Context) ([]cluster.NodeMessage, error)

type ScheduleQueue

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

func NewScheduleQueue

func NewScheduleQueue(nodeID string, client *mgo.DbClient) *ScheduleQueue

func (*ScheduleQueue) Ack

func (queue *ScheduleQueue) Ack(ctx context.Context, node cluster.Node) error

func (*ScheduleQueue) Close

func (queue *ScheduleQueue) Close() error

func (*ScheduleQueue) WaitEvent

func (queue *ScheduleQueue) WaitEvent(ctx context.Context) (*cluster.NodeScheduleEvent, error)