signal

package
v0.78.21 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 11, 2026 License: MIT Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type OLAPSignaler 

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

func NewOLAPSignaler 

func NewOLAPSignaler(mq msgqueue.MessageQueue, repo v1.Repository, l *zerolog.Logger, pubBuffer *msgqueue.MQPubBuffer) *OLAPSignaler

func (*OLAPSignaler) SendInternalEvents 

func (s *OLAPSignaler) SendInternalEvents(ctx context.Context, tenantId uuid.UUID, events []v1.InternalTaskEvent) error

func (*OLAPSignaler) SignalCELEvaluationFailures 

func (s *OLAPSignaler) SignalCELEvaluationFailures(ctx context.Context, tenantId uuid.UUID, failures []v1.CELEvaluationFailure) error

func (*OLAPSignaler) SignalDAGsCreated 

func (s *OLAPSignaler) SignalDAGsCreated(ctx context.Context, tenantId uuid.UUID, dags []*v1.DAGWithData) error

func (*OLAPSignaler) SignalEventsCreated 

func (s *OLAPSignaler) SignalEventsCreated(ctx context.Context, tenantId uuid.UUID, eventIdToOpts map[uuid.UUID]v1.EventTriggerOpts, eventIdsToRuns map[uuid.UUID][]*v1.Run) error

func (*OLAPSignaler) SignalTasksCreated 

func (s *OLAPSignaler) SignalTasksCreated(ctx context.Context, tenantId uuid.UUID, tasks []*v1.V1TaskWithPayload) error

func (*OLAPSignaler) SignalTasksReplayed 

func (s *OLAPSignaler) SignalTasksReplayed(ctx context.Context, tenantId uuid.UUID, tasks []v1.TaskIdInsertedAtRetryCount) error

func (*OLAPSignaler) SignalTasksReplayedFromMatch 

func (s *OLAPSignaler) SignalTasksReplayedFromMatch(ctx context.Context, tenantId uuid.UUID, tasks []*v1.V1TaskWithPayload) error

func (*OLAPSignaler) SignalTasksUpdated 

func (s *OLAPSignaler) SignalTasksUpdated(ctx context.Context, tenantId uuid.UUID, tasks []*v1.V1TaskWithPayload) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.