mtping

package
Version: v0.28.0 Latest Latest
Warning

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

Go to latest
Published: Dec 13, 2021 License: Apache-2.0 Imports: 29 Imported by: 0

Documentation

Index

Constants

View Source
const (
	EnvNoShutdownAfter = "K_NO_SHUTDOWN_AFTER"
)

Variables

This section is empty.

Functions

func GetNoShutDownAfterValue added in v0.17.0

func GetNoShutDownAfterValue() int

func NewAdapter added in v0.16.0

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

func NewController

func NewController(ctx context.Context, adapter adapter.Adapter) *controller.Impl

NewController initializes the controller. This is called by the shared adapter Main 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 added in v0.17.0

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

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

func NewEnvConfig added in v0.16.0

func NewEnvConfig() adapter.EnvConfigAccessor

Types

type CronJobRunner added in v0.18.0

type CronJobRunner interface {
	Start(stopCh <-chan struct{})
	Stop()
	AddSchedule(source *sourcesv1.PingSource) cron.EntryID
	RemoveSchedule(id cron.EntryID)
}

type MTAdapter added in v0.18.0

type MTAdapter interface {
	// Update is called when the source is ready and when the specification and/or status has changed.
	Update(ctx context.Context, source *sourcesv1.PingSource)

	// Remove is called when the source has been deleted.
	Remove(source *sourcesv1.PingSource)

	// RemoveAll is called when the adapter stopped leading
	RemoveAll(ctx context.Context)
}

MTAdapter is the interface the multi-tenant PingSource adapter must implement

type Reconciler

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

Reconciler reconciles PingSources

func (*Reconciler) ReconcileKind

func (r *Reconciler) ReconcileKind(ctx context.Context, source *sourcesv1.PingSource) reconciler.Event

Jump to

Keyboard shortcuts

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