cronjobevents

Documentation

Index

• type Adapter
  • func (a *Adapter) Start(ctx context.Context) error
• type Message

Types

type Adapter

type Adapter struct {
	// Schedule is a cron format string such as 0 * * * * or @hourly
	Schedule string

	// Data is the data to be posted to the target.
	Data string

	// SinkURI is the URI messages will be forwarded on to.
	SinkURI string
}

Adapter implements the Cron Job adapter to trigger a Sink.

func (*Adapter) Start

func (a *Adapter) Start(ctx context.Context) error

type Message

type Message struct {
	ID        string
	EventTime time.Time
	Body      string
}