common

Documentation

Index

• type EventDetails
  • func (e *EventDetails) Encode() string
• type RequestProvider
• type StatusReady
  • func (s *StatusReady) SetNotReady()
  • func (s *StatusReady) SetReady() bool

Types

type EventDetails

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

EventDetails represents the event details.

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)

RequestProvider represents an HTTP request provider.

type StatusReady

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

StatusReady represents the subscription ready status.

func (*StatusReady) SetNotReady

func (s *StatusReady) SetNotReady()

SetNotReady sets the subscription ready status to false.

func (*StatusReady) SetReady

func (s *StatusReady) SetReady() bool

SetReady sets the subscription ready status to true.