cronjobevents

Documentation

Index

• type Adapter
  • func (a *Adapter) Start(ctx context.Context, stopCh <-chan struct{}) 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

	// Name is the name of the Cron Job.
	Name string

	// Namespace is the namespace of the Cron Job.
	Namespace string

	Reporter source.StatsReporter
	// contains filtered or unexported fields
}

Adapter implements the Cron Job adapter to trigger a Sink.

func (*Adapter) Start

func (a *Adapter) Start(ctx context.Context, stopCh <-chan struct{}) error

type Message

type Message struct {
	Body string `json:"body"`
}