common

Documentation

Index

• type EventDetails
  • func FromPublishRequest(r *api.PublishRequest) *EventDetails
  • func FromSubscriptionSpec(s v1alpha1.SubscriptionSpec) *EventDetails
  • func (e *EventDetails) Encode() string
• type StatusReady
  • func (s *StatusReady) SetNotReady()
  • func (s *StatusReady) SetReady() bool

Types

type EventDetails

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

func FromPublishRequest

func FromPublishRequest(r *api.PublishRequest) *EventDetails

func FromSubscriptionSpec

func FromSubscriptionSpec(s v1alpha1.SubscriptionSpec) *EventDetails

func (*EventDetails) Encode

func (e *EventDetails) Encode() string

Encode formats the event details into a NATS streaming compliant subject name literal. Encoded subject is constructed by using the Period (`.`) character be added between tokens as a delimeter. Period character in a token literal will be escaped with a forward slash (`\.`), ex: `env.prod` will be `env\.prod`. Return value is astring literal composed of the event details tokens as: `sourceEnvironment + sourceNamespace + sourceType + eventType + eventTypeVersion`.

type StatusReady

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

func (*StatusReady) SetNotReady

func (s *StatusReady) SetNotReady()

func (*StatusReady) SetReady

func (s *StatusReady) SetReady() bool