nats

Documentation

Index

• Variables
• func BuildArgoEvent(workflowName, action, msg string) string
• func MockServer() func()

Variables

var NewJetStreamMsg = func(subject string, data []byte) *jetStreamMsg {
	return &jetStreamMsg{
		msg: &nats.Msg{
			Subject: subject,
			Data:    data,
		},
	}
}

Functions

func BuildArgoEvent

func BuildArgoEvent(workflowName, action, msg string) string

func MockServer

func MockServer() func()