Versions in this module Expand all Collapse all v1 v1.0.1 Feb 21, 2024 v1.0.0 Feb 21, 2024 Changes in this version + const AdminTag + const AuditFieldsContextKey + const DefaultProducerID + const EqualExpression + const ErrorKindKey + const Execution + const ExecutionAdminTag + const ExecutionIDLength + const ExecutionStringFormat + const LaunchPlan + const MaxResponseStatusBytes + const NamedEntity + const NamedEntityMetadata + const NodeExecution + const NodeExecutionEvent + const PrincipalContextKey + const Project + const Signal + const Task + const TaskExecution + const Workflow + var ResourceTypeToEntity = map[core.ResourceType]Entity + var RuntimeTypeKey = contextutils.Key("runtime_type") + var RuntimeVersionKey = contextutils.Key("runtime_version") + func GetExecutionName(seed int64) string + func GetInvalidRepeatedValueFilterErr(expression FilterExpression) error + func GetInvalidSingleValueFilterErr(expression FilterExpression) error + func GetNamespaceName(template string, project, domain string) string + func GetUnrecognizedFilterFunctionErr(function string) error + func GetUnsupportedFilterExpressionErr(expression FilterExpression) error + func IsExecutionTerminal(phase core.WorkflowExecution_Phase) bool + func IsNodeExecutionTerminal(phase core.NodeExecution_Phase) bool + func IsTaskExecutionTerminal(phase core.TaskExecution_Phase) bool + func KozmoURLKeyFromNodeExecutionID(nodeExecutionID core.NodeExecutionIdentifier) string + func KozmoURLKeyFromNodeExecutionIDRetry(nodeExecutionID core.NodeExecutionIdentifier, retry int) string + func KozmoURLsFromNodeExecutionID(nodeExecutionID core.NodeExecutionIdentifier, deck bool) *admin.KozmoURLs + func KozmoURLsFromTaskExecutionID(taskExecutionID core.TaskExecutionIdentifier, deck bool) *admin.KozmoURLs + func MatchRegex(reg *regexp.Regexp, input string) map[string]string + func OffloadLiteralMap(ctx context.Context, storageClient *storage.DataStore, ...) (storage.DataReference, error) + func OffloadLiteralMapWithRetryDelayAndAttempts(ctx context.Context, storageClient *storage.DataStore, ...) (storage.DataReference, error) + type ArtifactType int + const ArtifactTypeD + const ArtifactTypeI + const ArtifactTypeO + const ArtifactTypeUndefined + func ArtifactTypeString(s string) (ArtifactType, error) + func ArtifactTypeValues() []ArtifactType + func (i ArtifactType) IsAArtifactType() bool + func (i ArtifactType) String() string + type CloudProvider = string + const AWS + const GCP + const Local + const None + const Sandbox + type Entity = string + type FilterExpression int + const Contains + const Equal + const GreaterThan + const GreaterThanOrEqual + const LessThan + const LessThanOrEqual + const NotEqual + const ValueIn + type GormQueryExpr struct + Args interface{} + Query string + type InlineFilter interface + GetEntity func() Entity + GetField func() string + GetGormJoinTableQueryExpr func(tableName string) (GormQueryExpr, error) + GetGormQueryExpr func() (GormQueryExpr, error) + func NewInlineFilter(entity Entity, function string, field string, value interface{}) (InlineFilter, error) + func NewRepeatedValueFilter(entity Entity, function FilterExpression, field string, ...) (InlineFilter, error) + func NewSingleValueFilter(entity Entity, function FilterExpression, field string, value interface{}) (InlineFilter, error) + func NewWithDefaultValueFilter(defaultValue interface{}, filter InlineFilter) (InlineFilter, error) + type MapFilter interface + GetFilter func() map[string]interface{} + func NewMapFilter(filter map[string]interface{}) MapFilter + type ParsedExecution struct + IOType ArtifactType + LiteralName string + NodeExecID *core.NodeExecutionIdentifier + PartialTaskExecID *core.TaskExecutionIdentifier + func ParseKozmoURLToExecution(kozmoURL string) (ParsedExecution, error) + type RegisterAdditionalGRPCService = func(ctx context.Context, grpcServer *grpc.Server) error + type SortParameter interface + GetGormOrderExpr func() string + func NewSortParameter(sort *admin.Sort, allowed sets.String) (SortParameter, error)