direktivsource

Documentation

Index

• type EnvConfig
• type EventSourceReceiver
  • func NewEventSourceReceiver(t string) *EventSourceReceiver
  • func (esr *EventSourceReceiver) Client() ceclient.Client
  • func (esr *EventSourceReceiver) Env() EnvConfig
  • func (esr *EventSourceReceiver) ID() string
  • func (esr *EventSourceReceiver) Logger() *zap.SugaredLogger
  • func (esr *EventSourceReceiver) Overrides() *duckv1.CloudEventOverrides
  • func (esr *EventSourceReceiver) OverridesApply(ev *event.Event)

Types

type EnvConfig

type EnvConfig struct {
	// Sink URL where to send heartbeat cloudevents
	Sink string `envconfig:"K_SINK"`

	// CEOverrides are the CloudEvents overrides to be applied to the outbound event.
	CEOverrides string `envconfig:"K_CE_OVERRIDES"`
}

type EventSourceReceiver

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

func NewEventSourceReceiver

func NewEventSourceReceiver(t string) *EventSourceReceiver

func (*EventSourceReceiver) Client

func (esr *EventSourceReceiver) Client() ceclient.Client

func (*EventSourceReceiver) Env

func (esr *EventSourceReceiver) Env() EnvConfig

func (*EventSourceReceiver) ID

func (esr *EventSourceReceiver) ID() string

func (*EventSourceReceiver) Logger

func (esr *EventSourceReceiver) Logger() *zap.SugaredLogger

func (*EventSourceReceiver) Overrides

func (esr *EventSourceReceiver) Overrides() *duckv1.CloudEventOverrides

func (*EventSourceReceiver) OverridesApply

func (esr *EventSourceReceiver) OverridesApply(ev *event.Event)