events

Documentation

Index

• type Event
• type EventStore
  • func NewEventStore(natsURL string, tracer tracing.Tracer) (*EventStore, error)
  • func (s *EventStore) PublishEvent(ctx context.Context, event Event) error
  • func (s *EventStore) SubscribeToEvents(ctx context.Context, eventType string, handler func(Event)) error

Types

type Event

type Event struct {
	ID        string                 `json:"id"`
	Type      string                 `json:"type"`
	Data      map[string]interface{} `json:"data"`
	Metadata  map[string]interface{} `json:"metadata"`
	Timestamp time.Time              `json:"timestamp"`
}

type EventStore

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

func NewEventStore

func NewEventStore(natsURL string, tracer tracing.Tracer) (*EventStore, error)

func (*EventStore) PublishEvent

func (s *EventStore) PublishEvent(ctx context.Context, event Event) error

func (*EventStore) SubscribeToEvents

func (s *EventStore) SubscribeToEvents(ctx context.Context, eventType string, handler func(Event)) error