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 string, expectTags Tags)
  • func (e ExpectDelivery) Expect200(t *testing.T, trigger string)
  • func (e ExpectDelivery) ExpectDelivery(t *testing.T, trigger string, code int)
  • func (e ExpectDelivery) ExpectProcessing(t *testing.T, trigger string)
  • func (e ExpectDelivery) ExpectTimeout(t *testing.T, trigger string)
  • func (e ExpectDelivery) Verify(t *testing.T)
• type Tags

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[string]Tags
	ProcessingCount map[string]int64
	DeliveryCount   map[deliveryKey]int64
	TimeoutCount    map[string]int64
}

func NewExpectDelivery

func NewExpectDelivery() ExpectDelivery

func (ExpectDelivery) AddTrigger

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

func (ExpectDelivery) Expect200

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

func (ExpectDelivery) ExpectDelivery

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

func (ExpectDelivery) ExpectProcessing

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

func (ExpectDelivery) ExpectTimeout

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

func (ExpectDelivery) Verify

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

type Tags

type Tags map[string]string