sender

Documentation

Index

• Variables
• type Binding
  • func (b *Binding) New(cfg *k8s.Configurator, target *event.Target) (event.Sender, error)
• type NewAddressResolver
• type NewJobRunner

Variables

var ErrUnsupportedTargetType = errors.New("unsupported target type")

ErrUnsupportedTargetType is an error if user pass unsupported event target type. Only supporting: reachable or reference.

Types

type Binding

type Binding struct {
	NewJobRunner
	NewAddressResolver
	k8s.NewKubeClients
}

Binding holds injectable dependencies.

func (*Binding) New

func (b *Binding) New(cfg *k8s.Configurator, target *event.Target) (event.Sender, error)

New creates a new Sender.

type NewAddressResolver

type NewAddressResolver func(kube k8s.Clients) k8s.ReferenceAddressResolver

NewAddressResolver creates a k8s.ReferenceAddressResolver.

type NewJobRunner

type NewJobRunner func(kube k8s.Clients) k8s.JobRunner

NewJobRunner creates a k8s.JobRunner.