Documentation ¶
Index ¶
- Constants
- func AllEnvVarsExists(vars []string) error
- func CloseNATSConnectionOnForceStop(sc stan.Conn)
- func GetAckWaitDuration() time.Duration
- func NewOrderExpiredNSQConsumer() (*nsq.Consumer, error)
- func OnOrderCreatedStanEvent(sc stan.Conn, cb func(data OrderCreatedStanEventData, m *stan.Msg))
- type OrderCreatedStanEventData
- type OrderExpiredStanEventData
- type OrderExpiredStanEventPublisher
Constants ¶
const OrderExpiredNSQTitle = "order-expired"
OrderExpiredNSQTitle NSQ consumer title
Variables ¶
This section is empty.
Functions ¶
func AllEnvVarsExists ¶
AllEnvVarsExists retrieve nill if all specified variables exists in environment otherwise fulfill error
func CloseNATSConnectionOnForceStop ¶
func CloseNATSConnectionOnForceStop(sc stan.Conn)
CloseNATSConnectionOnForceStop Invoke NATS connection.close on Force stop signals
func GetAckWaitDuration ¶
GetAckWaitDuration Retrive duration from NATS_ACK_WAIT_DURATION environment variable or default '5s' value
func NewOrderExpiredNSQConsumer ¶
func NewOrderExpiredNSQConsumer() (*nsq.Consumer, error)
NewOrderExpiredNSQConsumer Retrive the NSQ consumer
func OnOrderCreatedStanEvent ¶
func OnOrderCreatedStanEvent(sc stan.Conn, cb func(data OrderCreatedStanEventData, m *stan.Msg))
OnOrderCreatedStanEvent Invoke the callback function on associated stan event
Types ¶
type OrderCreatedStanEventData ¶
OrderCreatedStanEventData Associated stan event data
type OrderExpiredStanEventData ¶
type OrderExpiredStanEventData struct {
ID string `json:"id"`
}
OrderExpiredStanEventData Associated stan event data
type OrderExpiredStanEventPublisher ¶
type OrderExpiredStanEventPublisher interface {
Publish(data OrderExpiredStanEventData)
}
OrderExpiredStanEventPublisher NATS publisher
func NewOrderExpiredStanEventPublisher ¶
func NewOrderExpiredStanEventPublisher(sc stan.Conn) OrderExpiredStanEventPublisher
NewOrderExpiredStanEventPublisher Retrive NATS publisher