events

Documentation

Index

• func GetIngestProjectEventWorkflowID(eid apievent.EventID, pid apiproject.ProjectID) string
• func TopicForEvent(id apievent.EventID) string
• func TopicForProject(id apiproject.ProjectID) string
• type Events
  • func (e *Events) IngestEvent(ctx context.Context, id apievent.EventID, srcid apieventsrc.EventSourceID, ...) (apievent.EventID, error)
  • func (e *Events) Init()
  • func (e *Events) MonitorProjectEvents(ctx context.Context, ch chan<- *apievent.TrackIngestEventUpdate, ...) error
  • func (e *Events) Start() error
  • func (e *Events) TrackIngestEvent(ctx context.Context, ch chan<- *apievent.TrackIngestEventUpdate, ...) error
• type Stores

Functions

func GetIngestProjectEventWorkflowID

func GetIngestProjectEventWorkflowID(eid apievent.EventID, pid apiproject.ProjectID) string

func TopicForEvent

func TopicForEvent(id apievent.EventID) string

func TopicForProject

func TopicForProject(id apiproject.ProjectID) string

Types

type Events

type Events struct {
	Temporal temporalclient.Client
	PubSub   pubsub.PubSub
	Stores   Stores
	Run      func(workflow.Context, *apievent.Event, *apiproject.Project, string) (*apilang.RunSummary, error)

	L L.Nullable
	// contains filtered or unexported fields
}

func (*Events) IngestEvent

func (e *Events) IngestEvent(
	ctx context.Context,
	id apievent.EventID,
	srcid apieventsrc.EventSourceID,
	assoc string,
	originalID string,
	typ string,
	data map[string]*apivalues.Value,
	memo map[string]string,
) (apievent.EventID, error)

func (*Events) Init

func (e *Events) Init()

func (*Events) MonitorProjectEvents

func (e *Events) MonitorProjectEvents(
	ctx context.Context,
	ch chan<- *apievent.TrackIngestEventUpdate,
	pid apiproject.ProjectID,
) error

func (*Events) Start

func (e *Events) Start() error

func (*Events) TrackIngestEvent

func (e *Events) TrackIngestEvent(
	ctx context.Context,
	ch chan<- *apievent.TrackIngestEventUpdate,
	id apievent.EventID,
	srcid apieventsrc.EventSourceID,
	assoc string,
	originalID string,
	typ string,
	data map[string]*apivalues.Value,
	memo map[string]string,
) error

type Stores

type Stores struct {
	Events       eventsstore.Store
	EventSources eventsrcsstore.Store
	Projects     projectsstore.Store
	Accounts     accountsstore.Store
}