cronjobevents

package
v0.8.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 18, 2019 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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
	// 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"`
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL