eventpub

type EventSinkFactory interface {
	NewEventSink(ctx RunEventContext) agent.EventSink
}

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

type RunEventContext struct {
	OrgID             uint
	WorkerID          uint
	SessionID         string
	TraceID           string
	RequestID         string
	TaskID            string
	RunID             string
	ParentID          string
	ReplyToMessageIDs []string
}