fake

Documentation

Index

• func NewAgentOptions(protocol options.CloudEventsProtocol, errChan chan error, ...) *options.CloudEventsAgentOptions
• func NewSourceOptions(protocol options.CloudEventsProtocol, sourceID string) *options.CloudEventsSourceOptions
• type CloudEventsFakeOptions
  • func (o *CloudEventsFakeOptions) ErrorChan() <-chan error
  • func (o *CloudEventsFakeOptions) Protocol(ctx context.Context, dataType types.CloudEventsDataType) (options.CloudEventsProtocol, error)
  • func (o *CloudEventsFakeOptions) WithContext(ctx context.Context, evtCtx cloudevents.EventContext) (context.Context, error)

Functions

func NewAgentOptions

func NewAgentOptions(protocol options.CloudEventsProtocol, errChan chan error, clusterName, agentID string) *options.CloudEventsAgentOptions

func NewSourceOptions

func NewSourceOptions(protocol options.CloudEventsProtocol, sourceID string) *options.CloudEventsSourceOptions

Types

type CloudEventsFakeOptions

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

func (*CloudEventsFakeOptions) ErrorChan

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

func (*CloudEventsFakeOptions) Protocol

func (o *CloudEventsFakeOptions) Protocol(ctx context.Context, dataType types.CloudEventsDataType) (options.CloudEventsProtocol, error)

func (*CloudEventsFakeOptions) WithContext

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