Documentation ¶
Index ¶
- func NatsPublish(subj string, msg string, reply *string) bool
- func NatsSubscribe(subj string, cb func(ctx context.Context, msg *nats.Msg) bool)
- func SendHttpNoop(s1, s2, s3, s4 *Service, triggerAll bool)
- func SetNoop(as bool)
- func Setup() (*Service, *Service, *Service, *Service)
- func TriggerAsync(s1, s2, s3, s4 *Service)
- type Service
- type SubCb
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NatsSubscribe ¶
func SendHttpNoop ¶
SendHttpNoop sends http to individually trigger each service in order
func TriggerAsync ¶
func TriggerAsync(s1, s2, s3, s4 *Service)
Types ¶
type Service ¶
func (*Service) GenericMethod ¶
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) TriggerAsyncFromHttp ¶
Click to show internal directories.
Click to hide internal directories.