queue

Documentation

Index

• type Manager
  • func NewQueueManager(conf config.Config, name string) (Manager, error)
• type RunReceipt
• type SQSManager
  • func (qm *SQSManager) Enqueue(qURL string, run state.Run) error
  • func (qm *SQSManager) Initialize(conf config.Config, engine string) error
  • func (qm *SQSManager) List() ([]string, error)
  • func (qm *SQSManager) Name() string
  • func (qm *SQSManager) QurlFor(name string, prefixed bool) (string, error)
  • func (qm *SQSManager) ReceiveCloudTrail(qURL string) (state.CloudTrailS3File, error)
  • func (qm *SQSManager) ReceiveEMREvent(qURL string) (state.EmrEvent, error)
  • func (qm *SQSManager) ReceiveKubernetesEvent(qURL string) (state.KubernetesEvent, error)
  • func (qm *SQSManager) ReceiveKubernetesRun(queue string) (string, error)
  • func (qm *SQSManager) ReceiveRun(qURL string) (RunReceipt, error)
  • func (qm *SQSManager) ReceiveStatus(qURL string) (StatusReceipt, error)
• type StatusReceipt

Types

type Manager

type Manager interface {
	Name() string
	QurlFor(name string, prefixed bool) (string, error)
	Initialize(config.Config, string) error
	Enqueue(qURL string, run state.Run) error
	ReceiveRun(qURL string) (RunReceipt, error)
	ReceiveStatus(qURL string) (StatusReceipt, error)
	ReceiveCloudTrail(qURL string) (state.CloudTrailS3File, error)
	ReceiveKubernetesEvent(qURL string) (state.KubernetesEvent, error)
	ReceiveEMREvent(qURL string) (state.EmrEvent, error)
	ReceiveKubernetesRun(queue string) (string, error)
	List() ([]string, error)
}

Manager wraps operations on a queue

func NewQueueManager

func NewQueueManager(conf config.Config, name string) (Manager, error)

NewQueueManager returns the Manager configured via `queue_manager`

type RunReceipt

type RunReceipt struct {
	Run  *state.Run
	Done func() error
}

RunReceipt wraps a Run and a callback to use when Run is finished processing

type SQSManager

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

SQSManager - queue manager implementation for sqs

func (*SQSManager) Enqueue

func (qm *SQSManager) Enqueue(qURL string, run state.Run) error

Enqueue queues run

func (*SQSManager) Initialize

func (qm *SQSManager) Initialize(conf config.Config, engine string) error

Initialize new sqs queue manager

func (*SQSManager) List

func (qm *SQSManager) List() ([]string, error)

List lists all the queue URLS available

func (*SQSManager) Name

func (qm *SQSManager) Name() string

Name of queue manager - matches value in configuration

func (*SQSManager) QurlFor

func (qm *SQSManager) QurlFor(name string, prefixed bool) (string, error)

QurlFor returns the queue url that corresponds to the given name * if the queue does not exist it is created

func (*SQSManager) ReceiveCloudTrail

func (qm *SQSManager) ReceiveCloudTrail(qURL string) (state.CloudTrailS3File, error)

func (*SQSManager) ReceiveEMREvent

func (qm *SQSManager) ReceiveEMREvent(qURL string) (state.EmrEvent, error)

func (*SQSManager) ReceiveKubernetesEvent

func (qm *SQSManager) ReceiveKubernetesEvent(qURL string) (state.KubernetesEvent, error)

func (*SQSManager) ReceiveKubernetesRun

func (qm *SQSManager) ReceiveKubernetesRun(queue string) (string, error)

func (*SQSManager) ReceiveRun

func (qm *SQSManager) ReceiveRun(qURL string) (RunReceipt, error)

Receive receives a new run to operate on

func (*SQSManager) ReceiveStatus

func (qm *SQSManager) ReceiveStatus(qURL string) (StatusReceipt, error)

type StatusReceipt

type StatusReceipt struct {
	StatusUpdate *string
	Done         func() error
}

StatusReceipt wraps a StatusUpdate and a callback to use when StatusUpdate is finished applying