userevent

Documentation

Index

• Variables
• type Event
• type Queue
• type UserEvent
  • func New(pubSub pubsub.PubSub) *UserEvent
  • func (e UserEvent) Created(ctx context.Context, u entity.User) error
  • func (e UserEvent) Deleted(ctx context.Context, u entity.User) error
  • func (e UserEvent) Updated(ctx context.Context, id uint) error

Variables

var UserEvents = []Event{
	UserCreated, UserUpdated, UserDeleted,
}

Types

type Event

type Event string

const (
	UserCreated Event = "user.event.created"
	UserUpdated Event = "user.event.updated"
	UserDeleted Event = "user.event.deleted"
)

type Queue

type Queue string

var QueuePattern Queue = "user.*"

type UserEvent

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

func New

func New(pubSub pubsub.PubSub) *UserEvent

func (UserEvent) Created

func (e UserEvent) Created(ctx context.Context, u entity.User) error

func (UserEvent) Deleted

func (e UserEvent) Deleted(ctx context.Context, u entity.User) error

func (UserEvent) Updated

func (e UserEvent) Updated(ctx context.Context, id uint) error