processgraph

package
v1.9.6 Latest Latest
Warning

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

Go to latest
Published: Dec 27, 2025 License: MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Controller

type Controller interface {
	SubmitWorkflowSpec(workflowSpec *core.WorkflowSpec, initiatorID string) (*core.ProcessGraph, error)
	GetProcessGraphByID(processGraphID string) (*core.ProcessGraph, error)
	FindWaitingProcessGraphs(colonyName string, count int) ([]*core.ProcessGraph, error)
	FindRunningProcessGraphs(colonyName string, count int) ([]*core.ProcessGraph, error)
	FindSuccessfulProcessGraphs(colonyName string, count int) ([]*core.ProcessGraph, error)
	FindFailedProcessGraphs(colonyName string, count int) ([]*core.ProcessGraph, error)
	RemoveProcessGraph(processGraphID string) error
	RemoveAllProcessGraphs(colonyName string, state int) error
	AddChild(processGraphID string, parentProcessID string, childProcessID string, process *core.Process, initiatorID string, insert bool) (*core.Process, error)
}

type Handlers

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

func NewHandlers

func NewHandlers(server Server) *Handlers

func (*Handlers) HandleAddChild

func (h *Handlers) HandleAddChild(c backends.Context, recoveredID string, payloadType string, jsonString string)

func (*Handlers) HandleGetProcessGraph

func (h *Handlers) HandleGetProcessGraph(c backends.Context, recoveredID string, payloadType string, jsonString string)

func (*Handlers) HandleGetProcessGraphs

func (h *Handlers) HandleGetProcessGraphs(c backends.Context, recoveredID string, payloadType string, jsonString string)

func (*Handlers) HandleRemoveAllProcessGraphs

func (h *Handlers) HandleRemoveAllProcessGraphs(c backends.Context, recoveredID string, payloadType string, jsonString string)

func (*Handlers) HandleRemoveProcessGraph

func (h *Handlers) HandleRemoveProcessGraph(c backends.Context, recoveredID string, payloadType string, jsonString string)

func (*Handlers) HandleSubmitWorkflow

func (h *Handlers) HandleSubmitWorkflow(c backends.Context, recoveredID string, payloadType string, jsonString string)

func (*Handlers) RegisterHandlers

func (h *Handlers) RegisterHandlers(handlerRegistry *registry.HandlerRegistry) error

RegisterHandlers implements the HandlerRegistrar interface

type Server

type Server interface {
	HandleHTTPError(c backends.Context, err error, errorCode int) bool
	SendHTTPReply(c backends.Context, payloadType string, jsonString string)
	SendEmptyHTTPReply(c backends.Context, payloadType string)
	Validator() Validator
	Controller() Controller
}

type Validator

type Validator interface {
	RequireMembership(recoveredID string, colonyName string, executorMayJoin bool) error
	RequireColonyOwner(recoveredID string, colonyName string) error
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL