event

package
v0.2.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 24, 2021 License: MIT Imports: 11 Imported by: 0

Documentation

Index

Constants

View Source 
const DefaultEventQueue = "event_queue"

Variables

View Source 
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 added in v0.0.25 

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

type NatsBus added in v0.0.25 

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

func (*NatsBus) Publish added in v0.0.25 

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

func (*NatsBus) Subscribe added in v0.0.25 

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"
	MessagePushSubject    Subject = "message_push"
	MessageChannelSubject Subject = "message_channel"
	WorkflowRunSubject    Subject = "workflow_run"
	MessageTriggerSubject Subject = "message_trigger"
	MessageHandleSubject  Subject = "message_handle"
)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.