adapter

Documentation

Index

• type Adapter
  • func NewAdapter(c *auth.OpenTelekomCloudClient, cqc CtsQuerierConfig, sbc SinkBindingConfig, ...) (*Adapter, error)
  • func (a *Adapter) GetEvents() ([]cloudevents.Event, error)
  • func (a *Adapter) GetEventsStream(eventsStream chan<- cloudevents.Event, done chan<- interface{})
  • func (a *Adapter) SendEvents(events []cloudevents.Event) (int, error)
  • func (a *Adapter) SendEventsStream(eventStream <-chan cloudevents.Event)
  • func (a *Adapter) TraceToCloudEvent(trace traces.Traces) (*cloudevents.Event, error)
• type CtsQuerierConfig
• type SinkBindingConfig

Types

type Adapter

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

func NewAdapter

func NewAdapter(c *auth.OpenTelekomCloudClient, cqc CtsQuerierConfig, sbc SinkBindingConfig, debug bool) (*Adapter, error)

func (*Adapter) GetEvents

func (a *Adapter) GetEvents() ([]cloudevents.Event, error)

func (*Adapter) GetEventsStream

func (a *Adapter) GetEventsStream(eventsStream chan<- cloudevents.Event, done chan<- interface{})

func (*Adapter) SendEvents

func (a *Adapter) SendEvents(events []cloudevents.Event) (int, error)

func (*Adapter) SendEventsStream

func (a *Adapter) SendEventsStream(eventStream <-chan cloudevents.Event)

func (*Adapter) TraceToCloudEvent

func (a *Adapter) TraceToCloudEvent(trace traces.Traces) (*cloudevents.Event, error)

type CtsQuerierConfig

type CtsQuerierConfig struct {
	ProjectId   string
	TrackerName string
	From        uint
}

type SinkBindingConfig

type SinkBindingConfig struct {
	// The URL of the resolved sink (K_SINK)
	SinkUrl string

	// A JSON object that specifies overrides to the outbound event (K_CE_OVERRIDES)
	CeOverrides string
}

SinkBindingConfig The SinkBinding object supports decoupling event production from delivery addressing. You can use sink binding to direct a subject to a sink. A subject is a Kubernetes resource that embeds a PodSpec template and produces events. A sink is an addressable Kubernetes object that can receive events. The SinkBinding object injects environment variables into the PodTemplateSpec of the sink. Because of this, the application code does not need to interact directly with the Kubernetes API to locate the event destination.