queue

Documentation

Index

• func RegisterQueue(q ObserveQueue)
• type ObserveQueue
  • func GetQueue(name string) ObserveQueue

Functions

func RegisterQueue

func RegisterQueue(q ObserveQueue)

RegisterQueue registers a queue by its name.

Types

type ObserveQueue

type ObserveQueue interface {
	Name() string

	Publish(tasks []*model.WorkflowTaskInstance) error

	Ack(tasks *model.WorkflowTaskInstance) error

	Observe()
}

func GetQueue

func GetQueue(name string) ObserveQueue

GetQueue returns the queue by name.