test

package

v1.12.0 Latest Latest Go to latest Published: Dec 8, 2021 License: Apache-2.0 Imports: 8 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

FakeCloudEventsClient is an implementation of a test CloudEvents client.

func NewTestClient() *FakeCloudEventsClient

NewTestClient returns a new instance of test client.

func (c *FakeCloudEventsClient) IsReceiverReady() bool

IsReceiverReady returns true if the dispatcher

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

Request is a mock method to send events.

func (c *FakeCloudEventsClient) Reset()

Reset flushes events array.

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

Send is a mock method to send events.

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

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

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

StartReceiver is a mock method to start events receiver.

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

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