cloudevent

Apr 29, 2020

Changes in this version

+ func EventForTaskRun(taskRun *v1alpha1.TaskRun) (*cloudevents.Event, error)

type FakeClient

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

type TektonEventType

+ func (t TektonEventType) String() string

Sep 19, 2019

Changes in this version

+ func GetCloudEventDeliveryCompareOptions() []cmp.Option

+ func InitializeCloudEvents(tr *v1alpha1.TaskRun, prs []*v1alpha1.PipelineResource)

+ func NewFakeClient(behaviour *FakeClientBehaviour) client.Client

+ func SendCloudEvent(sinkURI, eventID, eventSourceURI string, data []byte, ...) (cloudevents.Event, error)

+ func SendCloudEvents(tr *v1alpha1.TaskRun, ceclient CEClient, logger *zap.SugaredLogger) error

+ func SendTaskRunCloudEvent(sinkURI string, taskRun *v1alpha1.TaskRun, logger *zap.SugaredLogger, ...) (cloudevents.Event, error)

+ func WithClient(ctx context.Context, behaviour *FakeClientBehaviour) context.Context

+ type CECKey struct

+ type CEClient client.Client

+ func Get(ctx context.Context) CEClient

+ type FakeClient struct

+ func (c FakeClient) Send(ctx context.Context, event cloudevents.Event) (*cloudevents.Event, error)

+ func (c FakeClient) StartReceiver(ctx context.Context, fn interface{}) error

+ type FakeClientBehaviour struct

+ SendSuccessfully bool

+ type TektonCloudEventData struct

+ TaskRun *v1alpha1.TaskRun

+ func NewTektonCloudEventData(taskRun *v1alpha1.TaskRun) TektonCloudEventData

+ type TektonEventType string

+ const TektonTaskRunFailedV1

+ const TektonTaskRunSuccessfulV1

+ const TektonTaskRunUnknownV1