adapter

type Adapter ¶

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

func NewAdapter(c *auth.OpenTelekomCloudClient, cqc CtsQuerierConfig, sbc SinkBindingConfig, debug bool) (*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 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.