forwarder

Documentation

Index

• func WithMaxBytes(maxBytes int64) func(f *Forwarder)
• type Forwarder
  • func New(keptnEventAPI api.APIV1Interface, client *http.Client, env config.EnvConfig, ...) *Forwarder
  • func (f *Forwarder) Start(executionContext *utils.ExecutionContext)

Functions

func WithMaxBytes

func WithMaxBytes(maxBytes int64) func(f *Forwarder)

Types

type Forwarder

type Forwarder struct {
	EventChannel chan cloudevents.Event
	// contains filtered or unexported fields
}

Forwarder receives events directly from the Keptn Service and forwards them to the Keptn API

func New

func New(keptnEventAPI api.APIV1Interface, client *http.Client, env config.EnvConfig, opts ...func(f *Forwarder)) *Forwarder

func (*Forwarder) Start

func (f *Forwarder) Start(executionContext *utils.ExecutionContext)