metrics

Documentation

Index

• type CarrierFactory
• type EmptyCarrierFactory
  • func (*EmptyCarrierFactory) GetCarrier(label, queueName, address string, priority, workType uint64, group int64) []byte
• type EmptyJobLifecycleWrapper
  • func (*EmptyJobLifecycleWrapper) Dequeue(queueName string, work queue.Work, err error) error
  • func (*EmptyJobLifecycleWrapper) Enqueue(queueName string, work queue.Work, err error) error
  • func (*EmptyJobLifecycleWrapper) Finish(data interface{})
  • func (*EmptyJobLifecycleWrapper) Start(ctx context.Context, work *queue.QueueWork) (context.Context, interface{}, error)
• type JobLifecycleWrapper
• type Metrics

Types

type CarrierFactory

type CarrierFactory interface {
	GetCarrier(label, queueName, address string, priority, workType uint64, group int64) []byte
}

CarrierFactory provides a method for retrieving a byte array of tracing data. This data should be saved/persisted with the job by the queue implementation when work is pushed to the queue; it should also be loaded by the queue implementation when work is retrieved from the queue.

type EmptyCarrierFactory

type EmptyCarrierFactory struct{}

func (*EmptyCarrierFactory) GetCarrier

func (*EmptyCarrierFactory) GetCarrier(label, queueName, address string, priority, workType uint64, group int64) []byte

type EmptyJobLifecycleWrapper

type EmptyJobLifecycleWrapper struct{}

func (*EmptyJobLifecycleWrapper) Dequeue

func (*EmptyJobLifecycleWrapper) Dequeue(queueName string, work queue.Work, err error) error

func (*EmptyJobLifecycleWrapper) Enqueue

func (*EmptyJobLifecycleWrapper) Enqueue(queueName string, work queue.Work, err error) error

func (*EmptyJobLifecycleWrapper) Finish

func (*EmptyJobLifecycleWrapper) Finish(data interface{})

func (*EmptyJobLifecycleWrapper) Start

func (*EmptyJobLifecycleWrapper) Start(ctx context.Context, work *queue.QueueWork) (context.Context, interface{}, error)

type JobLifecycleWrapper

type JobLifecycleWrapper interface {
	Start(ctx context.Context, work *queue.QueueWork) (context.Context, interface{}, error)
	Enqueue(queueName string, work queue.Work, err error) error
	Dequeue(queueName string, work queue.Work, err error) error
	Finish(data interface{})
}

type Metrics

type Metrics interface {
	QueueNotificationMiss(queue, address string)
}