queue

Documentation

Index

• type CloseListener
• type Confirmation
• type Delivery
• type DestinationConfig
• type FilterConfiguration
• type FilterFieldsConfig
• type FilterOperation
  • func (op *FilterOperation) UnmarshalJSON(data []byte) error
• type FilterSpec
  • func (fc *FilterSpec) UnmarshalJSON(data []byte) error
• type Monitor
• type RouterConfig

Types

type CloseListener

type CloseListener interface {
	OnClose() error
}

type Confirmation

type Confirmation interface {
	Confirm() error
	Reject() error
}

type Delivery

type Delivery struct {
	Redelivered bool
}

type DestinationConfig

type DestinationConfig struct {
	RoutingKey string                `json:"name"`
	QueueName  string                `json:"queue"`
	Exchange   string                `json:"exchange"`
	Attributes []string              `json:"attributes"`
	Filters    []FilterConfiguration `json:"filters"`
}

type FilterConfiguration

type FilterConfiguration struct {
	Metadata FilterSpec `json:"metadata"`
	Message  FilterSpec `json:"message"`
}

type FilterFieldsConfig

type FilterFieldsConfig struct {
	FieldName     string
	ExpectedValue string
	Operation     FilterOperation
}

type FilterOperation

type FilterOperation string

const (
	Equal    FilterOperation = "EQUAL"
	NotEqual FilterOperation = "NOT_EQUAL"
	Empty    FilterOperation = "EMPTY"
	NotEmpty FilterOperation = "NOT_EMPTY"
	Wildcard FilterOperation = "WILDCARD"
)

func (*FilterOperation) UnmarshalJSON

func (op *FilterOperation) UnmarshalJSON(data []byte) error

type FilterSpec

type FilterSpec struct {
	Filters []FilterFieldsConfig
}

func (*FilterSpec) UnmarshalJSON

func (fc *FilterSpec) UnmarshalJSON(data []byte) error

type Monitor

type Monitor interface {
	Unsubscribe() error
}

type RouterConfig

type RouterConfig struct {
	Queues map[string]DestinationConfig `json:"queues"`
}