Documentation ¶
Index ¶
Constants ¶
View Source
const DefaultEventQueue = "event_queue"
Variables ¶
View Source
var ProviderSet = wire.NewSet(NewNatsBus)
Functions ¶
func CreateNats ¶
Types ¶
type Bus ¶
type Bus interface { Subscribe(ctx context.Context, subject Subject, fn nats.MsgHandler) error Publish(ctx context.Context, subject Subject, message interface{}) error }
func NewNatsBus ¶ added in v0.0.25
type NatsBus ¶ added in v0.0.25
type NatsBus struct {
// contains filtered or unexported fields
}
type Subject ¶
type Subject string
const ( EchoSubject Subject = "echo" RoleChangeExpSubject Subject = "role_change_exp" RoleChangeAttrSubject Subject = "role_change_attr" MessageSendSubject Subject = "message_send" MessagePushSubject Subject = "message_push" MessageChannelSubject Subject = "message_channel" WorkflowRunSubject Subject = "workflow_run" MessageTriggerSubject Subject = "message_trigger" MessageHandleSubject Subject = "message_handle" )
Click to show internal directories.
Click to hide internal directories.