common

Documentation

Index

• func DefaultRequestProvider(method, url string, body io.Reader) (*http.Request, error)
• type EventDetails
  • func FromPublishRequest(r *api.PublishRequest) *EventDetails
  • func FromSubscriptionSpec(s v1alpha1.SubscriptionSpec) *EventDetails
  • func (e *EventDetails) Encode() string
• type RequestProvider
• type StatusReady
  • func (s *StatusReady) SetNotReady()
  • func (s *StatusReady) SetReady() bool

Functions

func DefaultRequestProvider

func DefaultRequestProvider(method, url string, body io.Reader) (*http.Request, error)

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 delimiter. Period character in a token literal will be escaped with a forward slash (`\.`), ex: `env.prod` will be `env\.prod`. Return value is a string literal composed of the event details tokens as: `sourceID + eventType + eventTypeVersion`.

type RequestProvider

type RequestProvider func(method, url string, body io.Reader) (*http.Request, error)

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