queue

Documentation

Index

• Constants
• type Consumer
• type ConsumerFunc
• type ErrorHandler
• type Item
• type Notifier
  • func NewNotifier(ctx context.Context, dispatcher pubsub.Dispatcher) *Notifier
  • func (n *Notifier) NotifyRegion(region vm.Region)
  • func (n *Notifier) NotifyVM(ctx context.Context, vmId vm.Id, position int64) error
• type Queue

Constants

const RequestLockDuration = 3 * time.Minute

const RequestLockFmt = "supervisor.requests.%s"

Types

type Consumer

type Consumer interface {
	AddRegions(regions []vm.Region) error
	RemoveRegions(regions []vm.Region) error
	OnError(handler ErrorHandler)
}

type ConsumerFunc

type ConsumerFunc = func(item Item)

type ErrorHandler

type ErrorHandler = func(error)

type Item

type Item interface {
	Request() vm.Request
	Ack(ctx context.Context) error
	Nack(ctx context.Context) error
}

type Notifier

type Notifier struct {
	pubsub.Dispatcher
	// contains filtered or unexported fields
}

func NewNotifier

func NewNotifier(ctx context.Context, dispatcher pubsub.Dispatcher) *Notifier

func (*Notifier) NotifyRegion

func (n *Notifier) NotifyRegion(region vm.Region)

func (*Notifier) NotifyVM

func (n *Notifier) NotifyVM(ctx context.Context, vmId vm.Id, position int64) error

type Queue

type Queue interface {
	Add(ctx context.Context, request vm.Request) error
	CreateConsumer(ctx context.Context, fn ConsumerFunc) (Consumer, error)
}