mtping

Documentation

Index

• Constants
• func GetNoShutDownAfterValue() int
• func NewAdapter(ctx context.Context, _ adapter.EnvConfigAccessor, ceClient cloudevents.Client) adapter.Adapter
• func NewCronJobsRunner(ceClient cloudevents.Client, kubeClient kubernetes.Interface, ...) *cronJobsRunner
• func NewDelayingContext(ctx context.Context, afterSecond int) context.Context
• func NewEnvConfig() adapter.EnvConfigAccessor
• func Project(i interface{}) interface{}
• type Message
• type PingConfig
• type PingConfigs

Constants

const (
	EnvNoShutdownAfter = "K_NO_SHUTDOWN_AFTER"
)

Functions

func GetNoShutDownAfterValue

func GetNoShutDownAfterValue() int

func NewAdapter

func NewAdapter(ctx context.Context, _ adapter.EnvConfigAccessor, ceClient cloudevents.Client) adapter.Adapter

func NewCronJobsRunner

func NewCronJobsRunner(ceClient cloudevents.Client, kubeClient kubernetes.Interface, logger *zap.SugaredLogger, opts ...cron.Option) *cronJobsRunner

func NewDelayingContext

func NewDelayingContext(ctx context.Context, afterSecond int) context.Context

NewDelayingContext returns a new context delaying the cancellation of the given context.

func NewEnvConfig

func NewEnvConfig() adapter.EnvConfigAccessor

func Project

func Project(i interface{}) interface{}

Project creates a PingConfig for the given source

Types

type Message

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

type PingConfig

type PingConfig struct {
	corev1.ObjectReference `json:",inline"`

	// Schedule is the cronjob schedule. Defaults to `* * * * *`.
	Schedule string `json:"schedule"`

	// JsonData is json encoded data used as the body of the event posted to
	// the sink. Default is empty. If set, datacontenttype will also be set
	// to "application/json".
	// +optional
	JsonData string `json:"jsonData,omitempty"`

	// Extensions specify what attribute are added or overridden on the
	// outbound event. Each `Extensions` key-value pair are set on the event as
	// an attribute extension independently.
	// +optional
	Extensions map[string]string `json:"extensions,omitempty"`

	// SinkURI is the current active sink URI that has been configured for the
	// Source.
	SinkURI string `json:"sinkUri,omitempty"`
}

type PingConfigs

type PingConfigs map[string]PingConfig