test

package

v0.47.2 Latest Latest Go to latest Published: Feb 24, 2026 License: Apache-2.0 Imports: 10 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type EventData struct {
	ID   string `json:"id"`
	Type string `json:"type"`
}

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

func NewTestClient() *TestCloudEventsClient

func NewTestClientWithDelay(delay time.Duration) *TestCloudEventsClient

func (c *TestCloudEventsClient) CloseIdleConnections()

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

func (c *TestCloudEventsClient) Request_AppendResult(e *event.Event, r protocol.Result)

Request_AppendResult will enqueue a response for the following Request call. For testing.

func (c *TestCloudEventsClient) Reset()

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

func (c *TestCloudEventsClient) Send_AppendResult(r protocol.Result)

Send_AppendResult will enqueue a response for the following Send call. For testing.

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

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