test

Documentation

Index

• type FakeCloudEventsClient
  • func NewTestClient() *FakeCloudEventsClient
  • func (c *FakeCloudEventsClient) IsReceiverReady() bool
  • func (c *FakeCloudEventsClient) Request(ctx context.Context, out event.Event) (*event.Event, protocol.Result)
  • func (c *FakeCloudEventsClient) Reset()
  • func (c *FakeCloudEventsClient) Send(ctx context.Context, out event.Event) protocol.Result
  • func (c *FakeCloudEventsClient) Sent() []cloudevents.Event
  • func (c *FakeCloudEventsClient) StartReceiver(ctx context.Context, fn interface{}) error
  • func (c *FakeCloudEventsClient) WaitForReceiverReady(wait time.Duration) error

Types

type FakeCloudEventsClient

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

FakeCloudEventsClient is an implementation of a test CloudEvents client.

func NewTestClient

func NewTestClient() *FakeCloudEventsClient

NewTestClient returns a new instance of test client.

func (*FakeCloudEventsClient) IsReceiverReady

func (c *FakeCloudEventsClient) IsReceiverReady() bool

IsReceiverReady returns true if the dispatcher

func (*FakeCloudEventsClient) Request

func (c *FakeCloudEventsClient) Request(ctx context.Context, out event.Event) (*event.Event, protocol.Result)

Request is a mock method to send events.

func (*FakeCloudEventsClient) Reset

func (c *FakeCloudEventsClient) Reset()

Reset flushes events array.

func (*FakeCloudEventsClient) Send

func (c *FakeCloudEventsClient) Send(ctx context.Context, out event.Event) protocol.Result

Send is a mock method to send events.

func (*FakeCloudEventsClient) Sent

func (c *FakeCloudEventsClient) Sent() []cloudevents.Event

Sent returns the slice of events that were sent with test client.

func (*FakeCloudEventsClient) StartReceiver

func (c *FakeCloudEventsClient) StartReceiver(ctx context.Context, fn interface{}) error

StartReceiver is a mock method to start events receiver.

func (*FakeCloudEventsClient) WaitForReceiverReady

func (c *FakeCloudEventsClient) WaitForReceiverReady(wait time.Duration) error

WaitForReceiverReady will poll the client to check if the receiver dispatcher function is configured.