mtping

Documentation

Index

• Constants
• func GetNoShutDownAfterValue() int
• func NewAdapter(ctx context.Context, _ adapter.EnvConfigAccessor, ceClient cloudevents.Client) adapter.Adapter
• func NewController(ctx context.Context, adapter adapter.Adapter) *controller.Impl
• func NewCronJobsRunner(ceClient cloudevents.Client, kubeClient kubernetes.Interface, ...) *cronJobsRunner
• func NewDelayingContext(ctx context.Context, afterSecond int) context.Context
• func NewEnvConfig() adapter.EnvConfigAccessor
• type CronJobRunner
• type MTAdapter
• type Message
• type Reconciler
  • func (r *Reconciler) FinalizeKind(ctx context.Context, source *v1beta1.PingSource) reconciler.Event
  • func (r *Reconciler) ReconcileKind(ctx context.Context, source *v1beta1.PingSource) reconciler.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, 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

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

Types

type CronJobRunner

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

type MTAdapter

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 *v1beta1.PingSource)

	// Remove is called when the source has been deleted.
	Remove(ctx context.Context, source *v1beta1.PingSource)
}

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

type Message

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

type Reconciler

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

Reconciler reconciles PingSources

func (*Reconciler) FinalizeKind

func (r *Reconciler) FinalizeKind(ctx context.Context, source *v1beta1.PingSource) reconciler.Event

func (*Reconciler) ReconcileKind

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