messagequeue

Documentation

Index

• type MessageQueueManager
  • func NewMessageQueueManager(client actions.ActionsService, session *types.RunnerScaleSetSession) *MessageQueueManager
  • func (m *MessageQueueManager) AcquireJobs(ctx context.Context, requestIds []int64) ([]int64, error)
  • func (m *MessageQueueManager) Close() error
  • func (m *MessageQueueManager) DeleteMessage(ctx context.Context, messageId int64) error
  • func (m *MessageQueueManager) ReceiveNextMessage(ctx context.Context, lastMessageId int64) (*types.RunnerScaleSetMessage, error)
• type MessageQueueManagerInterface

Types

type MessageQueueManager

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

func NewMessageQueueManager

func NewMessageQueueManager(client actions.ActionsService, session *types.RunnerScaleSetSession) *MessageQueueManager

func (*MessageQueueManager) AcquireJobs

func (m *MessageQueueManager) AcquireJobs(ctx context.Context, requestIds []int64) ([]int64, error)

func (*MessageQueueManager) Close

func (m *MessageQueueManager) Close() error

func (*MessageQueueManager) DeleteMessage

func (m *MessageQueueManager) DeleteMessage(ctx context.Context, messageId int64) error

func (*MessageQueueManager) ReceiveNextMessage

func (m *MessageQueueManager) ReceiveNextMessage(ctx context.Context, lastMessageId int64) (*types.RunnerScaleSetMessage, error)

type MessageQueueManagerInterface

type MessageQueueManagerInterface interface {
	ReceiveNextMessage(ctx context.Context, lastMessageId int64) (*types.RunnerScaleSetMessage, error)
	DeleteMessage(ctx context.Context, messageId int64) error
	AcquireJobs(ctx context.Context, requestIds []int64) ([]int64, error)
	io.Closer
}