testing

Documentation

Index

• func ExpectMetrics(t *testing.T, f func() error)
• func ResetBrokerCellMetrics()
• func ResetDeliveryMetrics()
• func ResetIngressMetrics()
• type ExpectDelivery
  • func NewExpectDelivery() ExpectDelivery
  • func (e ExpectDelivery) AddTrigger(t *testing.T, trigger Trigger, expectTags Tags)
  • func (e ExpectDelivery) Expect200(t *testing.T, trigger Trigger)
  • func (e ExpectDelivery) ExpectDelivery(t *testing.T, trigger Trigger, code int)
  • func (e ExpectDelivery) ExpectProcessing(t *testing.T, trigger Trigger)
  • func (e ExpectDelivery) ExpectTimeout(t *testing.T, trigger Trigger)
  • func (e ExpectDelivery) Verify(t *testing.T)
• type Tags
• type Trigger

Functions

func ExpectMetrics

func ExpectMetrics(t *testing.T, f func() error)

func ResetBrokerCellMetrics

func ResetBrokerCellMetrics()

func ResetDeliveryMetrics

func ResetDeliveryMetrics()

func ResetIngressMetrics

func ResetIngressMetrics()

Types

type ExpectDelivery

type ExpectDelivery struct {
	TriggerTags     map[Trigger]Tags
	ProcessingCount map[Trigger]int64
	DeliveryCount   map[deliveryKey]int64
	TimeoutCount    map[Trigger]int64
}

func NewExpectDelivery

func NewExpectDelivery() ExpectDelivery

func (ExpectDelivery) AddTrigger

func (e ExpectDelivery) AddTrigger(t *testing.T, trigger Trigger, expectTags Tags)

func (ExpectDelivery) Expect200

func (e ExpectDelivery) Expect200(t *testing.T, trigger Trigger)

func (ExpectDelivery) ExpectDelivery

func (e ExpectDelivery) ExpectDelivery(t *testing.T, trigger Trigger, code int)

func (ExpectDelivery) ExpectProcessing

func (e ExpectDelivery) ExpectProcessing(t *testing.T, trigger Trigger)

func (ExpectDelivery) ExpectTimeout

func (e ExpectDelivery) ExpectTimeout(t *testing.T, trigger Trigger)

func (ExpectDelivery) Verify

func (e ExpectDelivery) Verify(t *testing.T)

type Tags

type Tags map[string]string

type Trigger

type Trigger struct {
	Namespace string
	Trigger   string
	Broker    string
}