fake

Documentation

Index

• func NewAgentOptions(client *CloudEventsFakeClient, clusterName, agentID string) *options.CloudEventsAgentOptions
• func NewSourceOptions(client *CloudEventsFakeClient, sourceID string) *options.CloudEventsSourceOptions
• type CloudEventsFakeClient
  • func NewCloudEventsFakeClient(receivedEvents ...cloudevents.Event) *CloudEventsFakeClient
  • func (c *CloudEventsFakeClient) GetSentEvents() []cloudevents.Event
  • func (c *CloudEventsFakeClient) Request(ctx context.Context, event event.Event) (*cloudevents.Event, protocol.Result)
  • func (c *CloudEventsFakeClient) Send(ctx context.Context, event cloudevents.Event) protocol.Result
  • func (c *CloudEventsFakeClient) StartReceiver(ctx context.Context, fn interface{}) error
• type CloudEventsFakeOptions
  • func (o *CloudEventsFakeOptions) Client(ctx context.Context) (cloudevents.Client, error)
  • func (o *CloudEventsFakeOptions) ErrorChan() <-chan error
  • func (o *CloudEventsFakeOptions) WithContext(ctx context.Context, evtCtx cloudevents.EventContext) (context.Context, error)

Functions

func NewAgentOptions

func NewAgentOptions(client *CloudEventsFakeClient, clusterName, agentID string) *options.CloudEventsAgentOptions

func NewSourceOptions

func NewSourceOptions(client *CloudEventsFakeClient, sourceID string) *options.CloudEventsSourceOptions

Types

type CloudEventsFakeClient

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

func NewCloudEventsFakeClient

func NewCloudEventsFakeClient(receivedEvents ...cloudevents.Event) *CloudEventsFakeClient

func (*CloudEventsFakeClient) GetSentEvents

func (c *CloudEventsFakeClient) GetSentEvents() []cloudevents.Event

func (*CloudEventsFakeClient) Request

func (c *CloudEventsFakeClient) Request(ctx context.Context, event event.Event) (*cloudevents.Event, protocol.Result)

func (*CloudEventsFakeClient) Send

func (c *CloudEventsFakeClient) Send(ctx context.Context, event cloudevents.Event) protocol.Result

func (*CloudEventsFakeClient) StartReceiver

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

type CloudEventsFakeOptions

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

func (*CloudEventsFakeOptions) Client

func (o *CloudEventsFakeOptions) Client(ctx context.Context) (cloudevents.Client, error)

func (*CloudEventsFakeOptions) ErrorChan

func (o *CloudEventsFakeOptions) ErrorChan() <-chan error

func (*CloudEventsFakeOptions) WithContext

func (o *CloudEventsFakeOptions) WithContext(ctx context.Context, evtCtx cloudevents.EventContext) (context.Context, error)