common

Documentation

Index

• Constants
• func Namespace() string
• func NamespaceTopic(topic string) string
• func SetNamespace(ns string)
• type ConsumptionCode
• type DeliverySemantics
• type GroupId
• type Header
  • func (h Header) CreateTopic(topic string) string

Constants

const (
	NamespaceSep = "."
)

Functions

func Namespace

func Namespace() string

Namespace returns the current global fxapp namespace.

func NamespaceTopic

func NamespaceTopic(topic string) string

func SetNamespace

func SetNamespace(ns string)

SetNamespace sets the global fxapp namespace.

Types

type ConsumptionCode

type ConsumptionCode int32

const (
	// ConsumeAck "Success, let's keep going!"
	ConsumeAck ConsumptionCode = iota

	// ConsumeAckFinal "Success, but I'm done consuming!"
	ConsumeAckFinal

	// ConsumeNackTransientFailure "Failure, but I'd like to try again! Send me that message again."
	ConsumeNackTransientFailure

	// ConsumeNackPersistentFailure "Failure, I give up on this message! Let's move on."
	ConsumeNackPersistentFailure
)

type DeliverySemantics

type DeliverySemantics string

const (
	AtLeastOnce DeliverySemantics = "at-least-once"
	AtMostOnce  DeliverySemantics = "at-most-once"
	Unset       DeliverySemantics = ""
)

type GroupId

type GroupId string

const (
	DefaultId GroupId = ""
)

type Header

type Header string

const (
	KafkaHeader Header = "kafka://"
	NatsHeader  Header = "nats://"
	NsqHeader   Header = "nsq://"
	LocalHeader Header = "local://"
)

func (Header) CreateTopic

func (h Header) CreateTopic(topic string) string