commands

Documentation

Index

• Constants
• type DeleteIngressACPCommand
  • func NewDeleteIngressACPCommand(k8sClientSet clientset.Interface, traefikClientSet traefikclientset.Interface) *DeleteIngressACPCommand
  • func (c *DeleteIngressACPCommand) Handle(ctx context.Context, id string, requestedAt time.Time, data json.RawMessage) *platform.CommandExecutionReport
• type Handler
• type SetIngressACPCommand
  • func NewSetIngressACPCommand(k8sClientSet clientset.Interface, traefikClientSet traefikclientset.Interface) *SetIngressACPCommand
  • func (c *SetIngressACPCommand) Handle(ctx context.Context, id string, requestedAt time.Time, data json.RawMessage) *platform.CommandExecutionReport
• type Store
• type Watcher
  • func NewWatcher(interval time.Duration, store Store, k8sClientSet clientset.Interface, ...) *Watcher
  • func (w *Watcher) Start(ctx context.Context)

Constants

const AnnotationLastPatchRequestedAt = "hub.traefik.io/last-patch-requested-at"

AnnotationLastPatchRequestedAt is specifies the date at which an update has been requested in the RFC-3339 format.

Types

type DeleteIngressACPCommand

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

DeleteIngressACPCommand removes the ACP of a given Ingress.

func NewDeleteIngressACPCommand

func NewDeleteIngressACPCommand(k8sClientSet clientset.Interface, traefikClientSet traefikclientset.Interface) *DeleteIngressACPCommand

NewDeleteIngressACPCommand creates a new DeleteIngressACPCommand.

func (*DeleteIngressACPCommand) Handle

func (c *DeleteIngressACPCommand) Handle(ctx context.Context, id string, requestedAt time.Time, data json.RawMessage) *platform.CommandExecutionReport

Handle handles the ACP deletion on the given Ingress.

type Handler

type Handler interface {
	Handle(ctx context.Context, id string, requestedAt time.Time, data json.RawMessage) *platform.CommandExecutionReport
}

Handler can handle a command.

type SetIngressACPCommand

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

SetIngressACPCommand sets the given ACP on a specific Ingress.

func NewSetIngressACPCommand

func NewSetIngressACPCommand(
	k8sClientSet clientset.Interface,
	traefikClientSet traefikclientset.Interface,
) *SetIngressACPCommand

NewSetIngressACPCommand creates a new SetIngressACPCommand.

func (*SetIngressACPCommand) Handle

func (c *SetIngressACPCommand) Handle(ctx context.Context, id string, requestedAt time.Time, data json.RawMessage) *platform.CommandExecutionReport

Handle sets an ACP on an Ingress.

type Store

type Store interface {
	ListPendingCommands(ctx context.Context) ([]platform.Command, error)
	SubmitCommandReports(ctx context.Context, reports []platform.CommandExecutionReport) error
}

Store is capable of fetching commands and sending command reports.

type Watcher

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

Watcher watches and applies the patch commands from the platform.

func NewWatcher

func NewWatcher(interval time.Duration, store Store, k8sClientSet clientset.Interface, traefikClientSet traefikclientset.Interface) *Watcher

NewWatcher creates a Watcher.

func (*Watcher) Start

func (w *Watcher) Start(ctx context.Context)

Start starts watching commands.