Documentation ¶
Index ¶
Constants ¶
View Source
const ( // BroadcastEventTypeCreate is an event type for listening to 'create'. BroadcastEventTypeCreate string = "create" // BroadcastEventTypeUpdate is an event type for listening to 'update'. BroadcastEventTypeUpdate string = "update" // BroadcastEventTypeDelete is an event type for listenting to 'delete'. BroadcastEventTypeDelete string = "delete" BroadcastEventTypeInstanceStarted string = "started" BroadcastEventTypeInstanceFailed string = "failed" BroadcastEventTypeInstanceSuccess string = "success" )
View Source
const ( // BroadcastEventScopeWorkflow is the scope in which you want to listen for events. BroadcastEventScopeWorkflow string = "workflow" // BroadcastEventScopeNamespace is the scope in which you want to listen for events. BroadcastEventScopeNamespace string = "namespace" // BroadcastEventScopeInstance is the scope in which you want to listen for events. BroadcastEventScopeInstance string = "instance" )
View Source
const ( // BroadcastEventPrefixWorkflow is the event prefix that is being broadcasted. BroadcastEventPrefixWorkflow string = "workflow" // BroadcastEventPrefixDirectory is the event prefix that is being broadcasted. BroadcastEventPrefixDirectory string = "directory" // BroadcastEventPrefixVariable is the event prefix that is being broadcasted. BroadcastEventPrefixVariable string = "variable" // BroadcastEventPrefixInstance is the event prefix that is being broadcasted. BroadcastEventPrefixInstance string = "instance" )
View Source
const ( // Direktiv Headers. ServiceHeaderName = "direktiv.io/name" ServiceHeaderNamespaceID = "direktiv.io/namespace-id" ServiceHeaderNamespaceName = "direktiv.io/namespace-name" ServiceHeaderWorkflowID = "direktiv.io/workflow-id" ServiceHeaderPath = "direktiv.io/workflow-name" ServiceHeaderRevision = "direktiv.io/revision" ServiceHeaderSize = "direktiv.io/size" ServiceHeaderScale = "direktiv.io/scale" ServiceTemplateGeneration = "direktiv.io/templateGeneration" ServiceHeaderScope = "direktiv.io/scope" // Serving Headers. ServiceKnativeHeaderName = "serving.knative.dev/service" ServiceKnativeHeaderConfiguration = "serving.knative.dev/configuration" ServiceKnativeHeaderGeneration = "serving.knative.dev/configurationGeneration" ServiceKnativeHeaderRevision = "serving.knative.dev/revision" ServiceKnativeHeaderRolloutDuration = "serving.knative.dev/rolloutDuration" )
NOTE: old constants.
View Source
const ( DirektivActionIDHeader = "Direktiv-ActionID" DirektivInstanceIDHeader = "Direktiv-InstanceID" DirektivExchangeKeyHeader = "Direktiv-ExchangeKey" DirektivPingAddrHeader = "Direktiv-PingAddr" DirektivDeadlineHeader = "Direktiv-Deadline" DirektivTimeoutHeader = "Direktiv-Timeout" DirektivStepHeader = "Direktiv-Step" DirektivIteratorHeader = "Direktiv-Iterator" DirektivResponseHeader = "Direktiv-Response" DirektivNamespaceHeader = "Direktiv-Namespace" DirektivSourceHeader = "Direktiv-Source" DirektivFileHeader = "Direktiv-Files" DirektivErrorCodeHeader = "Direktiv-ErrorCode" DirektivErrorMessageHeader = "Direktiv-ErrorMessage" )
headers for flow->container communication.
View Source
const ( ServiceResponseNoError = "" ServiceErrorInternal = "au.com.direktiv.error.internal" ServiceErrorImage = "au.com.direktiv.error.image" ServiceErrorNetwork = "au.com.direktiv.error.network" ServiceErrorIO = "au.com.direktiv.error.io" )
internal error codes for knative services.
Variables ¶
View Source
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" ErrCodeAllBranchesFailed = "direktiv.parallel.allFailed" ErrCodeNotArray = "direktiv.foreach.badArray" ErrCodeFailedSchemaValidation = "direktiv.schema.failed" ErrCodeJQNotString = "direktiv.jq.notString" ErrCodeInvalidVariableKey = "direktiv.var.invalidKey" )
Functions ¶
func GetInodePath ¶
GetInodePath returns the exact path to a inode.
func NoCancelContext ¶ added in v0.8.2
WithoutCancel returns a context that is never canceled.
func PublishKnativeEvent ¶
func PublishKnativeEvent(ce *cloudevents.Event)
func SanitizeLabel ¶ added in v0.8.1
Types ¶
type EventingCtxKey ¶
type EventingCtxKey string
const EventingCtxKeySource EventingCtxKey = "source"
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.
Source Files ¶
- broadcast.go
- cancel.go
- db-events.go
- engine.go
- errors.go
- eventing.go
- events.go
- grpc-files.go
- grpc-flow.go
- grpc-instance-variables.go
- grpc-instances.go
- grpc-internal.go
- grpc-linters.go
- grpc-mirror.go
- grpc-namespace-variables.go
- grpc-namespaces.go
- grpc-nodes.go
- grpc-refs.go
- grpc-revisions.go
- grpc-secrets.go
- grpc-workflow-variables.go
- grpc-workflow.go
- instance_messages.go
- isolate.go
- jq.go
- memory.go
- metrics.go
- routing.go
- scheduling.go
- secrets.go
- server.go
- state-logic.go
- status.go
- temporary.go
- timeouts.go
- timers.go
- trace.go
Click to show internal directories.
Click to hide internal directories.