broker

Documentation

Index

• func Address(ctx context.Context, name string, timings ...time.Duration) (*apis.URL, error)
• func Gvr() schema.GroupVersionResource
• func Install(name string, opts ...manifest.CfgFn) feature.StepFn
• func IsAddressable(name string, timings ...time.Duration) feature.StepFn
• func IsReady(name string, timing ...time.Duration) feature.StepFn
• func WithBrokerClass(class string) manifest.CfgFn
• func WithConfig(name string) manifest.CfgFn
• func WithDeadLetterSink(ref *duckv1.KReference, uri string) manifest.CfgFn
• func WithRetry(count int32, backoffPolicy *eventingv1.BackoffPolicyType, backoffDelay *string) manifest.CfgFn
• type EnvConfig

Functions

func Address

func Address(ctx context.Context, name string, timings ...time.Duration) (*apis.URL, error)

Address returns a broker's address.

func Gvr

func Gvr() schema.GroupVersionResource

func Install

func Install(name string, opts ...manifest.CfgFn) feature.StepFn

Install will create a Broker resource, augmented with the config fn options.

func IsAddressable

func IsAddressable(name string, timings ...time.Duration) feature.StepFn

IsAddressable tests to see if a Broker becomes addressable within the time given.

func IsReady

func IsReady(name string, timing ...time.Duration) feature.StepFn

IsReady tests to see if a Broker becomes ready within the time given.

func WithBrokerClass

func WithBrokerClass(class string) manifest.CfgFn

WithBrokerClass adds the broker class config to a Broker spec.

func WithConfig

func WithConfig(name string) manifest.CfgFn

WithConfig adds the broker class config to a Broker spec.

func WithDeadLetterSink

func WithDeadLetterSink(ref *duckv1.KReference, uri string) manifest.CfgFn

WithDeadLetterSink adds the dead letter sink related config to a Broker spec.

func WithRetry

func WithRetry(count int32, backoffPolicy *eventingv1.BackoffPolicyType, backoffDelay *string) manifest.CfgFn

WithRetry adds the retry related config to a Broker spec.

Types

type EnvConfig

type EnvConfig struct {
	BrokerClass string `envconfig:"BROKER_CLASS" default:"MTChannelBasedBroker" required:"true"`
}

var EnvCfg EnvConfig