diag

Documentation

Index

• func NewInstanceTreeBuilder(db Backend) *instanceTreeBuilder
• func NewServeMux(backend Backend) *http.ServeMux
• type Backend
• type Event
• type WorkflowInstanceInfo
• type WorkflowInstanceRef
• type WorkflowInstanceTree

Functions

func NewInstanceTreeBuilder

func NewInstanceTreeBuilder(db Backend) *instanceTreeBuilder

func NewServeMux

func NewServeMux(backend Backend) *http.ServeMux

NewServeMux returns an *http.ServeMux that serves the diagnostics web app at / and the diagnostics API at /api which is used by the web app.

Types

type Backend

type Backend interface {
	backend.Backend

	GetWorkflowInstance(ctx context.Context, instanceID string) (*WorkflowInstanceRef, error)
	GetWorkflowInstances(ctx context.Context, afterInstanceID string, count int) ([]*WorkflowInstanceRef, error)
	GetWorkflowTree(ctx context.Context, instanceID string) (*WorkflowInstanceTree, error)
}

type Event

type Event struct {
	ID              string      `json:"id,omitempty"`
	SequenceID      int64       `json:"sequence_id,omitempty"`
	Type            string      `json:"type,omitempty"`
	Timestamp       time.Time   `json:"timestamp,omitempty"`
	ScheduleEventID int64       `json:"schedule_event_id,omitempty"`
	Attributes      interface{} `json:"attributes,omitempty"`
	VisibleAt       *time.Time  `json:"visible_at,omitempty"`
}

type WorkflowInstanceInfo

type WorkflowInstanceInfo struct {
	*WorkflowInstanceRef

	History []*Event `json:"history,omitempty"`
}

type WorkflowInstanceRef

type WorkflowInstanceRef struct {
	Instance    *core.WorkflowInstance     `json:"instance,omitempty"`
	CreatedAt   time.Time                  `json:"created_at,omitempty"`
	CompletedAt *time.Time                 `json:"completed_at,omitempty"`
	State       core.WorkflowInstanceState `json:"state"`
}

type WorkflowInstanceTree

type WorkflowInstanceTree struct {
	*WorkflowInstanceRef

	WorkflowName string `json:"workflow_name,omitempty"`

	Children []*WorkflowInstanceTree `json:"children,omitempty"`
}