api

Documentation

Index

• func GetExtraRoutes() []func(*chi.Mux)
• func Initialize(app core.App, db *database.SQLStore, bus *pubsub2.Bus, ...) error
• func RegisterExtraRoute(fn func(*chi.Mux))
• type ActivityEntryContext
• type CoursoredEvent
• type Error
• type Event
• type InstanceData
• type LineageData
• type RouteEntryContext
• type WorkflowEntryContext

Functions

func GetExtraRoutes

func GetExtraRoutes() []func(*chi.Mux)

func Initialize

func Initialize(app core.App, db *database.SQLStore, bus *pubsub2.Bus, instanceManager *instancestore.InstanceManager, wakeByEvents events.WakeEventsWaiter, startByEvents events.WorkflowStart, circuit *core.Circuit) error

func RegisterExtraRoute

func RegisterExtraRoute(fn func(*chi.Mux))

Types

type ActivityEntryContext

type ActivityEntryContext struct {
	ID interface{} `json:"id,omitempty"`
}

type CoursoredEvent

type CoursoredEvent struct {
	Event
	time.Time
}

type Error

type Error struct {
	Code       string            `json:"code"`
	Message    string            `json:"message"`
	Validation map[string]string `json:"validation,omitempty"`
}

type Event

type Event struct {
	ID   string
	Data string
	Type string
}

type InstanceData

type InstanceData struct {
	ID           uuid.UUID      `json:"id"`
	CreatedAt    time.Time      `json:"createdAt"`
	EndedAt      *time.Time     `json:"endedAt"`
	Status       string         `json:"status"`
	WorkflowPath string         `json:"path"`
	ErrorCode    *string        `json:"errorCode"`
	Invoker      string         `json:"invoker"`
	Definition   []byte         `json:"definition,omitempty"`
	ErrorMessage []byte         `json:"errorMessage"`
	Flow         []string       `json:"flow"`
	TraceID      string         `json:"traceId"`
	Lineage      []*LineageData `json:"lineage"`
	Namespace    string         `json:"namespace"`

	InputLength    *int   `json:"inputLength,omitempty"`
	Input          []byte `json:"input,omitempty"`
	OutputLength   *int   `json:"outputLength,omitempty"`
	Output         []byte `json:"output,omitempty"`
	MetadataLength *int   `json:"metadataLength,omitempty"`
	Metadata       []byte `json:"metadata,omitempty"`
}

type LineageData

type LineageData struct {
	Branch int    `json:"branch"`
	ID     string `json:"id"`
	State  string `json:"state"`
	Step   int    `json:"step"`
}

type RouteEntryContext

type RouteEntryContext struct {
	Path interface{} `json:"path,omitempty"`
}

type WorkflowEntryContext

type WorkflowEntryContext struct {
	Status interface{} `json:"status"`

	State    interface{} `json:"state"`
	Branch   interface{} `json:"branch"`
	Path     interface{} `json:"workflow"`
	CalledAs interface{} `json:"calledAs"`
	Instance interface{} `json:"instance"`
}