service

Documentation

Index

• type Service
  • func New(listenForTopic string, publishToTopic string) *Service
  • func (s *Service) GenericMethod(msg *nats.Msg) bool
  • func (s *Service) Publish(msg *nats.Msg) bool
  • func (s *Service) PublishTopic() string
  • func (s *Service) SetPublishToTopic(publishToTopic string)

Types

type Service

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

func New

func New(listenForTopic string, publishToTopic string) *Service

func (*Service) GenericMethod

func (s *Service) GenericMethod(msg *nats.Msg) bool

GenericMethod is any generic async method in a request pipeline It would normally be triggered by nats/kafka. After processing this method would ideally publish to nats/kafka to trigger the next service/stage of the request pipeline

Noop-Testing: Before the final publish operation ->

- add publish `msg` to the context - return if ctx is noop, otherwise publish `msg` to queue

func (*Service) Publish

func (s *Service) Publish(msg *nats.Msg) bool

Publish the actual async method in a request pipeline

func (*Service) PublishTopic

func (s *Service) PublishTopic() string

func (*Service) SetPublishToTopic

func (s *Service) SetPublishToTopic(publishToTopic string)