events

Documentation

Index

• Constants
• func API(handler chan<- cloudevents.Event) *eventAPI
• func ClientWithBackoff(c Client, b backoff.BackOff) *backoffClient
• type Client
• type DiscardClient
  • func (c *DiscardClient) Send(context.Context, cloudevents.Event) error
  • func (c *DiscardClient) SendAsyncAck(context.Context, cloudevents.Event) error
• type HTTPClient
  • func (c *HTTPClient) Send(ctx context.Context, e cloudevents.Event) error
  • func (c *HTTPClient) SendAsyncAck(ctx context.Context, e cloudevents.Event) error

Constants

const (
	TaskCreated   = "media.nagare.engine.v1alpha1.task.created"
	TaskUpdated   = "media.nagare.engine.v1alpha1.task.updated"
	TaskDeleted   = "media.nagare.engine.v1alpha1.task.deleted"
	TaskStarted   = "media.nagare.engine.v1alpha1.task.started"
	TaskStopped   = "media.nagare.engine.v1alpha1.task.stopped"
	TaskSucceeded = "media.nagare.engine.v1alpha1.task.succeeded"
	TaskFailed    = "media.nagare.engine.v1alpha1.task.failed"
)

Functions

func API

func API(handler chan<- cloudevents.Event) *eventAPI

func ClientWithBackoff

func ClientWithBackoff(c Client, b backoff.BackOff) *backoffClient

Types

type Client

type Client interface {
	Send(context.Context, cloudevents.Event) error
	SendAsyncAck(context.Context, cloudevents.Event) error
}

type DiscardClient

type DiscardClient struct{}

DiscardClient will discard all events.

func (*DiscardClient) Send

func (c *DiscardClient) Send(context.Context, cloudevents.Event) error

func (*DiscardClient) SendAsyncAck

func (c *DiscardClient) SendAsyncAck(context.Context, cloudevents.Event) error

type HTTPClient

type HTTPClient struct {
	URL    string
	Client *http.Client
}

HTTPClient will deliver messages using HTTP.

func (*HTTPClient) Send

func (c *HTTPClient) Send(ctx context.Context, e cloudevents.Event) error

func (*HTTPClient) SendAsyncAck

func (c *HTTPClient) SendAsyncAck(ctx context.Context, e cloudevents.Event) error