sender

package
v0.3.0 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

View Source
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")
)

Functions

This section is empty.

Types

type Binding added in v0.3.0

Binding holds injectable dependencies.

func (*Binding) New added in v0.3.0

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

New creates a new Sender.

type CreateAddressResolver added in v0.3.0

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

CreateAddressResolver creates a k8s.ReferenceAddressResolver.

type CreateJobRunner added in v0.3.0

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

CreateJobRunner creates a k8s.JobRunner.

type CreateKubeClients added in v0.3.0

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

CreateKubeClients creates k8s.Clients.

Jump to

Keyboard shortcuts

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