flow

Documentation

Index

• Constants
• Variables
• func GetInodePath(path string) string
• func NoCancelContext(ctx context.Context) context.Context
• func Run(circuit *core.Circuit) error
• type ServiceResponse

Constants

const (
	DirektivActionIDHeader = "Direktiv-ActionID"
)

Variables

var (
	ErrCodeInternal           = "direktiv.internal.error"
	ErrCodeWorkflowUnparsable = "direktiv.workflow.unparsable"
	ErrCodeMultipleErrors     = "direktiv.workflow.multipleErrors"
	ErrCodeCancelledByParent  = "direktiv.cancels.parent"
	ErrCodeSoftTimeout        = "direktiv.cancels.timeout.soft"
	ErrCodeHardTimeout        = "direktiv.cancels.timeout.hard"
	ErrCodeJQBadQuery         = "direktiv.jq.badCommand"
	ErrCodeJQNotObject        = "direktiv.jq.notObject"
	ErrCodeJQNoResults        = "direktiv.jq.badCommand"
	ErrCodeJQManyResults      = "direktiv.jq.badCommand"
)

Functions

func GetInodePath

func GetInodePath(path string) string

GetInodePath returns the exact path to a inode.

func NoCancelContext

func NoCancelContext(ctx context.Context) context.Context

WithoutCancel returns a context that is never canceled.

func Run

func Run(circuit *core.Circuit) error

Types

type ServiceResponse

type ServiceResponse struct {
	ErrorCode    string      `json:"errorCode"`
	ErrorMessage string      `json:"errorMessage"`
	Data         interface{} `json:"data"`
}

ServiceResponse is the response structure for internal knative services.