test

Documentation

Index

• func NewReceiverHTTPHandler(ctx context.Context, recorder *EventRecorder) (*client.EventReceiver, error)
• type EventRecorder
  • func NewEventRecorder() *EventRecorder
  • func (e *EventRecorder) Clear()
  • func (e *EventRecorder) Events() []cloudevents.Event
  • func (e *EventRecorder) Record(event cloudevents.Event)
  • func (e *EventRecorder) Start()
  • func (e *EventRecorder) Stop()
• type TestReceiver
  • func NewTestReceiver(ctx context.Context) (*TestReceiver, error)
  • func (r *TestReceiver) ClearEvents()
  • func (r *TestReceiver) GetEvents() []cloudevents.Event
  • func (r *TestReceiver) StartRecorder()
  • func (r *TestReceiver) StopRecorder()

Functions

func NewReceiverHTTPHandler

func NewReceiverHTTPHandler(ctx context.Context, recorder *EventRecorder) (*client.EventReceiver, error)

Types

type EventRecorder

type EventRecorder struct {
	// contains filtered or unexported fields
}

func NewEventRecorder

func NewEventRecorder() *EventRecorder

func (*EventRecorder) Clear

func (e *EventRecorder) Clear()

func (*EventRecorder) Events

func (e *EventRecorder) Events() []cloudevents.Event

func (*EventRecorder) Record

func (e *EventRecorder) Record(event cloudevents.Event)

func (*EventRecorder) Start

func (e *EventRecorder) Start()

func (*EventRecorder) Stop

func (e *EventRecorder) Stop()

type TestReceiver

type TestReceiver struct {
	*httptest.Server
	// contains filtered or unexported fields
}

func NewTestReceiver

func NewTestReceiver(ctx context.Context) (*TestReceiver, error)

func (*TestReceiver) ClearEvents

func (r *TestReceiver) ClearEvents()

func (*TestReceiver) GetEvents

func (r *TestReceiver) GetEvents() []cloudevents.Event

func (*TestReceiver) StartRecorder

func (r *TestReceiver) StartRecorder()

func (*TestReceiver) StopRecorder

func (r *TestReceiver) StopRecorder()