mtping

Documentation

Index

• Constants
• func GetNoShutDownAfterValue() int
• func NewAdapter(ctx context.Context, _ adapter.EnvConfigAccessor, ceClient cloudevents.Client) adapter.Adapter
• func NewController(ctx context.Context, cronRunner *cronJobsRunner) *controller.Impl
• 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
• type Reconciler
  • func (r *Reconciler) FinalizeKind(ctx context.Context, source *v1alpha2.PingSource) pkgreconciler.Event
  • func (r *Reconciler) ReconcileKind(ctx context.Context, source *v1alpha2.PingSource) pkgreconciler.Event

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 NewController

func NewController(ctx context.Context, cronRunner *cronJobsRunner) *controller.Impl

NewController initializes the controller and is called by the generated code. Registers event handlers to enqueue events.

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

type Reconciler

type Reconciler struct {
	// contains filtered or unexported fields
}

Reconciler reconciles PingSources

func (*Reconciler) FinalizeKind

func (r *Reconciler) FinalizeKind(ctx context.Context, source *v1alpha2.PingSource) pkgreconciler.Event

func (*Reconciler) ReconcileKind

func (r *Reconciler) ReconcileKind(ctx context.Context, source *v1alpha2.PingSource) pkgreconciler.Event