sender

Documentation

Index

• Variables
• type Binding
  • func (b *Binding) New(target *event.Target) (event.Sender, error)
• type CreateAddressResolver
• type CreateJobRunner
• type CreateKubeClients

Variables

var (
	// ErrUnsupportedTargetType is an error if user pass unsupported event target
	// type. Only supporting: reachable or addressable.
	ErrUnsupportedTargetType = errors.New("unsupported target type")

	// ErrCouldntBeSent is an error that will be return in case event that suppose
	// to be sent, couldn't be, for whatever technical reason.
	ErrCouldntBeSent = errors.New("event couldn't be sent")
)

Types

type Binding

type Binding struct {
	CreateJobRunner
	CreateAddressResolver
	CreateKubeClients
}

Binding holds injectable dependencies.

func (*Binding) New

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

New creates a new Sender.

type CreateAddressResolver

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

CreateAddressResolver creates a k8s.ReferenceAddressResolver.

type CreateJobRunner

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

CreateJobRunner creates a k8s.JobRunner.

type CreateKubeClients

type CreateKubeClients func(props *event.Properties) (k8s.Clients, error)

CreateKubeClients creates k8s.Clients.