event

Documentation

Index

• Constants
• Variables
• func CreateNats(id string) (*nats.Conn, error)
• type Bus
  • func NewNatsBus(nc *nats.Conn, nr *newrelic.App) Bus
• type NatsBus
  • func (b *NatsBus) Publish(_ context.Context, subject Subject, message interface{}) error
  • func (b *NatsBus) Subscribe(_ context.Context, subject Subject, fn nats.MsgHandler) error
• type Subject

Constants

const DefaultEventQueue = "event_queue"

Variables

var ProviderSet = wire.NewSet(NewNatsBus)

Functions

func CreateNats

func CreateNats(id string) (*nats.Conn, error)

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

func NewNatsBus(nc *nats.Conn, nr *newrelic.App) Bus

type NatsBus

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

func (*NatsBus) Publish

func (b *NatsBus) Publish(_ context.Context, subject Subject, message interface{}) error

func (*NatsBus) Subscribe

func (b *NatsBus) Subscribe(_ context.Context, subject Subject, fn nats.MsgHandler) error

type Subject

type Subject string

const (
	EchoSubject           Subject = "echo"
	RoleChangeExpSubject  Subject = "role_change_exp"
	RoleChangeAttrSubject Subject = "role_change_attr"
	MessageSendSubject    Subject = "message_send"
	WorkflowRunSubject    Subject = "workflow_run"
	MessageTriggerSubject Subject = "message_trigger"
)