eventmanager

Documentation

Index

• Constants
• func NewProjectCreatedEvent(ctx context.Context, ev *internalevent.ProjectCreatedEvent) *internalevent.Event
• func NewTaskCreatedEvent(ctx context.Context, ev *internalevent.TaskCreatedEvent) *internalevent.Event
• func NewUserCreatedEvent(ctx context.Context, ev *internalevent.UserCreatedEvent) *internalevent.Event
• func NewWriteKeyGeneratedEvent(ctx context.Context, ev *internalevent.WriteKeyGeneratedEvent) *internalevent.Event
• type CreateChannelFunc
  • func NewCreateChannelFunc(ca channel.Adapter, mod channel.Mode, bufferSize, maxRetryPolicy int) CreateChannelFunc
• type EventMessage
  • func NewEventMessage(ev *internalevent.Event, ack func() error) EventMessage
• type Manager
  • func New(wg *sync.WaitGroup, done <-chan bool, adapter channel.Adapter, ...) (Manager, error)
  • func (h Manager) Consume(eventTypes ...internalevent.EventName) (<-chan EventMessage, error)
  • func (h Manager) Publish(msg *internalevent.Event) error
• type RegisterEventChannel

Constants

const (
	EventNameWriteKeyGenerated = "manager.write_key.generated"
	EventNameUserCreated       = "manager.user.created"
	EventNameProjectCreated    = "manager.project.created"
	EventNameTaskCreated       = "destination.task.created"
)

event name pattern : PublisherServiceName.EntityName.Trigger.

Functions

func NewProjectCreatedEvent

func NewProjectCreatedEvent(ctx context.Context, ev *internalevent.ProjectCreatedEvent) *internalevent.Event

func NewTaskCreatedEvent

func NewTaskCreatedEvent(ctx context.Context, ev *internalevent.TaskCreatedEvent) *internalevent.Event

func NewUserCreatedEvent

func NewUserCreatedEvent(ctx context.Context, ev *internalevent.UserCreatedEvent) *internalevent.Event

func NewWriteKeyGeneratedEvent

func NewWriteKeyGeneratedEvent(ctx context.Context, ev *internalevent.WriteKeyGeneratedEvent) *internalevent.Event

Types

type CreateChannelFunc

type CreateChannelFunc func(channelName string) error

func NewCreateChannelFunc

func NewCreateChannelFunc(ca channel.Adapter, mod channel.Mode, bufferSize, maxRetryPolicy int) CreateChannelFunc

type EventMessage

type EventMessage struct {
	Event *internalevent.Event
	Ack   func() error
}

func NewEventMessage

func NewEventMessage(ev *internalevent.Event, ack func() error) EventMessage

type Manager

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

func New

func New(wg *sync.WaitGroup, done <-chan bool, adapter channel.Adapter, events map[internalevent.EventName]CreateChannelFunc) (Manager, error)

func (Manager) Consume

func (h Manager) Consume(eventTypes ...internalevent.EventName) (<-chan EventMessage, error)

func (Manager) Publish

func (h Manager) Publish(msg *internalevent.Event) error

type RegisterEventChannel

type RegisterEventChannel func(channelName string) error