event

Documentation

Index

• Variables
• type ChannelQueue
  • func NewChannelQueue() *ChannelQueue
  • func (q ChannelQueue) Pop(events map[EventType]reflect.Type) (Event, error)
  • func (q ChannelQueue) Push(e Event) error
• type Event
• type EventLogger
  • func (e *EventLogger) Context(ctx context.Context) context.Context
  • func (e *EventLogger) WithContext(ctx context.Context)
• type EventType
• type Queue

Variables

var (
	ErrEventTypeNotFound = errors.New("event type not found")
)

Types

type ChannelQueue

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

func NewChannelQueue

func NewChannelQueue() *ChannelQueue

func (ChannelQueue) Pop

func (q ChannelQueue) Pop(events map[EventType]reflect.Type) (Event, error)

func (ChannelQueue) Push

func (q ChannelQueue) Push(e Event) error

type Event

type Event interface {
	Type() EventType
	WithContext(ctx context.Context)
	Context(ctx context.Context) context.Context
}

type EventLogger

type EventLogger struct {
}

func (*EventLogger) Context

func (e *EventLogger) Context(ctx context.Context) context.Context

func (*EventLogger) WithContext

func (e *EventLogger) WithContext(ctx context.Context)

type EventType

type EventType string

type Queue

type Queue interface {
	Push(e Event) error
	Pop(events map[EventType]reflect.Type) (Event, error)
}