v1alpha1

package

Go to main page

Versions in this module

v0

v0.1.13

Apr 30, 2026

v0.1.12

Apr 22, 2026

v0.1.11

Apr 22, 2026

v0.1.10

Apr 21, 2026

v0.1.9

Apr 19, 2026

v0.1.7

Apr 12, 2026

v0.1.6

Apr 8, 2026

v0.1.5

Apr 8, 2026

v0.1.4

Apr 7, 2026

Changes in this version

+ type CachePolicy struct

+ Enabled *bool

+ Key *string

+ Mode *string

+ Salt *string

+ TTLSeconds *int32

+ func (in *CachePolicy) DeepCopy() *CachePolicy

+ func (in *CachePolicy) DeepCopyInto(out *CachePolicy)

+ type ConcurrencyMode string

+ const ConcurrencyModeCancelPrevious

+ const ConcurrencyModeParallel

+ const ConcurrencyModeSerial

+ type ConcurrencyScope string

+ const ConcurrencyScopeParticipant

+ const ConcurrencyScopeStoryRun

type EngramSpec

+ Transport *EngramTransportSpec

+ Version string

type EngramStatus

+ Triggers int64

+ UsageCount int32

+ ValidationErrors []string

+ ValidationStatus enums.ValidationStatus

+ type EngramTLSSpec struct

+ SecretRef *corev1.LocalObjectReference

+ UseDefaultTLS *bool

+ func (in *EngramTLSSpec) DeepCopy() *EngramTLSSpec

+ func (in *EngramTLSSpec) DeepCopyInto(out *EngramTLSSpec)

+ type EngramTransportSpec struct

+ TLS *EngramTLSSpec

+ func (in *EngramTransportSpec) DeepCopy() *EngramTransportSpec

+ func (in *EngramTransportSpec) DeepCopyInto(out *EngramTransportSpec)

type ExecutionOverrides

+ Cache *CachePolicy

+ Debug *bool

+ MaxInlineSize *int

+ Placement *PlacementPolicy

+ RBAC *RBACRuleOverrides

+ Storage *StoragePolicy

type ExecutionPolicy

+ Cache *CachePolicy

+ MaxRecursionDepth *int

+ Placement *PlacementPolicy

+ Realtime *RealtimePolicy

+ Storage *StoragePolicy

+ type FileStorageProvider struct

+ EmptyDir *corev1.EmptyDirVolumeSource

+ Path string

+ VolumeClaimName string

+ func (in *FileStorageProvider) DeepCopy() *FileStorageProvider

+ func (in *FileStorageProvider) DeepCopyInto(out *FileStorageProvider)

type ImpulseSpec

+ DeliveryPolicy *TriggerDeliveryPolicy

+ Throttle *TriggerThrottlePolicy

+ Version string

type ImpulseStatus

+ LastThrottled *metav1.Time

+ ThrottledTriggers int64

type JobPolicy

+ StoryRunRetentionSeconds *int32

+ type PlacementPolicy struct

+ Affinity *corev1.Affinity

+ NodeSelector map[string]string

+ Tolerations []corev1.Toleration

+ func (in *PlacementPolicy) DeepCopy() *PlacementPolicy

+ func (in *PlacementPolicy) DeepCopyInto(out *PlacementPolicy)

+ type PostExecutionCheck struct

+ Condition string

+ FailureMessage string

+ func (in *PostExecutionCheck) DeepCopy() *PostExecutionCheck

+ func (in *PostExecutionCheck) DeepCopyInto(out *PostExecutionCheck)

+ type RBACRuleOverrides struct

+ Rules []rbacv1.PolicyRule

+ func (in *RBACRuleOverrides) DeepCopy() *RBACRuleOverrides

+ func (in *RBACRuleOverrides) DeepCopyInto(out *RBACRuleOverrides)

+ type RealtimeConcurrency struct

+ Mode ConcurrencyMode

+ Scope ConcurrencyScope

+ func (in *RealtimeConcurrency) DeepCopy() *RealtimeConcurrency

+ func (in *RealtimeConcurrency) DeepCopyInto(out *RealtimeConcurrency)

+ type RealtimePolicy struct

+ TTLSecondsAfterFinished *int32

+ func (in *RealtimePolicy) DeepCopy() *RealtimePolicy

+ func (in *RealtimePolicy) DeepCopyInto(out *RealtimePolicy)

type RetryPolicy

+ Jitter *int32

+ MaxDelay *string

type S3StorageProvider

+ UsePathStyle bool

type Step

+ AllowFailure *bool

+ IdempotencyKeyTemplate *string

+ PostExecution *PostExecutionCheck

+ Requires []string

+ Runtime *runtime.RawExtension

+ SideEffects *bool

+ Transport string

type StoragePolicy

+ File *FileStorageProvider

+ TimeoutSeconds int

type StoryPolicy

+ Priority *int32

+ Queue *string

type StorySpec

+ Compensations []Step

+ Concurrency *RealtimeConcurrency

+ Finally []Step

+ Transports []StoryTransport

+ Version string

type StoryStatus

+ Transports []StoryTransportStatus

+ Triggers int64

+ UsageCount int32

+ ValidationErrors []string

+ ValidationStatus enums.ValidationStatus

+ ValidationWarnings []string

type StoryTimeouts

+ GracefulShutdownTimeout *metav1.Duration

+ type StoryTransport struct

+ Description string

+ Name string

+ Settings *runtime.RawExtension

+ Streaming *transportv1alpha1.TransportStreamingSettings

+ TransportRef string

+ func (in *StoryTransport) DeepCopy() *StoryTransport

+ func (in *StoryTransport) DeepCopyInto(out *StoryTransport)

+ type StoryTransportStatus struct

+ Mode enums.TransportMode

+ ModeReason string

+ Name string

+ TransportRef string

+ func (in *StoryTransportStatus) DeepCopy() *StoryTransportStatus

+ func (in *StoryTransportStatus) DeepCopyInto(out *StoryTransportStatus)

+ type TriggerDedupeMode string

+ const TriggerDedupeKey

+ const TriggerDedupeNone

+ const TriggerDedupeToken

+ type TriggerDedupePolicy struct

+ KeyTemplate *string

+ Mode *TriggerDedupeMode

+ func (in *TriggerDedupePolicy) DeepCopy() *TriggerDedupePolicy

+ func (in *TriggerDedupePolicy) DeepCopyInto(out *TriggerDedupePolicy)

+ type TriggerDeliveryPolicy struct

+ Dedupe *TriggerDedupePolicy

+ Retry *TriggerRetryPolicy

+ func (in *TriggerDeliveryPolicy) DeepCopy() *TriggerDeliveryPolicy

+ func (in *TriggerDeliveryPolicy) DeepCopyInto(out *TriggerDeliveryPolicy)

+ type TriggerRetryPolicy struct

+ Backoff *enums.BackoffStrategy

+ BaseDelay *string

+ MaxAttempts *int32

+ MaxDelay *string

+ func (in *TriggerRetryPolicy) DeepCopy() *TriggerRetryPolicy

+ func (in *TriggerRetryPolicy) DeepCopyInto(out *TriggerRetryPolicy)

+ type TriggerThrottlePolicy struct

+ Burst *int32

+ MaxInFlight *int32

+ RatePerSecond *int32

+ func (in *TriggerThrottlePolicy) DeepCopy() *TriggerThrottlePolicy

+ func (in *TriggerThrottlePolicy) DeepCopyInto(out *TriggerThrottlePolicy)

type WorkloadResources

+ Placement *PlacementPolicy

v0.1.3

Nov 3, 2025

v0.1.2

Oct 16, 2025

v0.1.1

Oct 16, 2025

v0.1.0

Oct 16, 2025

Changes in this version

+ var AddToScheme = SchemeBuilder.AddToScheme

+ var GroupVersion = schema.GroupVersion

+ var SchemeBuilder = &scheme.Builder

+ type Engram struct

+ Spec EngramSpec

+ Status EngramStatus

+ func (in *Engram) DeepCopy() *Engram

+ func (in *Engram) DeepCopyInto(out *Engram)

+ func (in *Engram) DeepCopyObject() runtime.Object

+ type EngramList struct

+ Items []Engram

+ func (in *EngramList) DeepCopy() *EngramList

+ func (in *EngramList) DeepCopyInto(out *EngramList)

+ func (in *EngramList) DeepCopyObject() runtime.Object

+ type EngramSpec struct

+ ExecutionPolicy *ExecutionPolicy

+ Mode enums.WorkloadMode

+ Overrides *ExecutionOverrides

+ Secrets map[string]string

+ TemplateRef refs.EngramTemplateReference

+ With *runtime.RawExtension

+ func (in *EngramSpec) DeepCopy() *EngramSpec

+ func (in *EngramSpec) DeepCopyInto(out *EngramSpec)

+ type EngramStatus struct

+ Conditions []metav1.Condition

+ FailedExecutions int32

+ LastExecutionTime *metav1.Time

+ ObservedGeneration int64

+ Phase enums.Phase

+ ReadyReplicas int32

+ Replicas int32

+ TotalExecutions int32

+ func (in *EngramStatus) DeepCopy() *EngramStatus

+ func (in *EngramStatus) DeepCopyInto(out *EngramStatus)

+ type ExecutionOverrides struct

+ AutomountServiceAccountToken *bool

+ ImagePullPolicy *string

+ Probes *ProbeOverrides

+ Retry *RetryPolicy

+ Security *WorkloadSecurity

+ ServiceAccountName *string

+ Timeout *string

+ func (in *ExecutionOverrides) DeepCopy() *ExecutionOverrides

+ func (in *ExecutionOverrides) DeepCopyInto(out *ExecutionOverrides)

+ type ExecutionPolicy struct

+ Job *JobPolicy

+ Resources *ResourcePolicy

+ Retry *RetryPolicy

+ Security *SecurityPolicy

+ ServiceAccountName *string

+ Timeout *string

+ func (in *ExecutionPolicy) DeepCopy() *ExecutionPolicy

+ func (in *ExecutionPolicy) DeepCopyInto(out *ExecutionPolicy)

+ type Impulse struct

+ Spec ImpulseSpec

+ Status ImpulseStatus

+ func (in *Impulse) DeepCopy() *Impulse

+ func (in *Impulse) DeepCopyInto(out *Impulse)

+ func (in *Impulse) DeepCopyObject() runtime.Object

+ type ImpulseList struct

+ Items []Impulse

+ func (in *ImpulseList) DeepCopy() *ImpulseList

+ func (in *ImpulseList) DeepCopyInto(out *ImpulseList)

+ func (in *ImpulseList) DeepCopyObject() runtime.Object

+ type ImpulseSpec struct

+ Execution *ExecutionOverrides

+ Mapping *runtime.RawExtension

+ Secrets map[string]string

+ Service *ServiceExposure

+ StoryRef refs.StoryReference

+ TemplateRef refs.ImpulseTemplateReference

+ With *runtime.RawExtension

+ Workload *WorkloadSpec

+ func (in *ImpulseSpec) DeepCopy() *ImpulseSpec

+ func (in *ImpulseSpec) DeepCopyInto(out *ImpulseSpec)

+ type ImpulseStatus struct

+ Conditions []metav1.Condition

+ FailedTriggers int64

+ LastSuccess *metav1.Time

+ LastTrigger *metav1.Time

+ ObservedGeneration int64

+ Phase enums.Phase

+ ReadyReplicas int32

+ Replicas int32

+ StoriesLaunched int64

+ TriggersReceived int64

+ func (in *ImpulseStatus) DeepCopy() *ImpulseStatus

+ func (in *ImpulseStatus) DeepCopyInto(out *ImpulseStatus)

+ type JobPolicy struct

+ BackoffLimit *int32

+ RestartPolicy *string

+ TTLSecondsAfterFinished *int32

+ func (in *JobPolicy) DeepCopy() *JobPolicy

+ func (in *JobPolicy) DeepCopyInto(out *JobPolicy)

+ type JobWorkloadConfig struct

+ ActiveDeadlineSeconds *int64

+ BackoffLimit *int32

+ Completions *int32

+ Parallelism *int32

+ TTLSecondsAfterFinished *int32

+ func (in *JobWorkloadConfig) DeepCopy() *JobWorkloadConfig

+ func (in *JobWorkloadConfig) DeepCopyInto(out *JobWorkloadConfig)

+ type ProbeOverrides struct

+ DisableLiveness bool

+ DisableReadiness bool

+ DisableStartup bool

+ func (in *ProbeOverrides) DeepCopy() *ProbeOverrides

+ func (in *ProbeOverrides) DeepCopyInto(out *ProbeOverrides)

+ type ResourceLimits struct

+ CPU *string

+ EphemeralStorage *string

+ Memory *string

+ func (in *ResourceLimits) DeepCopy() *ResourceLimits

+ func (in *ResourceLimits) DeepCopyInto(out *ResourceLimits)

+ type ResourcePolicy struct

+ CPULimit *string

+ CPURequest *string

+ MemoryLimit *string

+ MemoryRequest *string

+ func (in *ResourcePolicy) DeepCopy() *ResourcePolicy

+ func (in *ResourcePolicy) DeepCopyInto(out *ResourcePolicy)

+ type ResourceRequests struct

+ CPU *string

+ EphemeralStorage *string

+ Memory *string

+ func (in *ResourceRequests) DeepCopy() *ResourceRequests

+ func (in *ResourceRequests) DeepCopyInto(out *ResourceRequests)

+ type RetryPolicy struct

+ Backoff *enums.BackoffStrategy

+ Delay *string

+ MaxRetries *int32

+ func (in *RetryPolicy) DeepCopy() *RetryPolicy

+ func (in *RetryPolicy) DeepCopyInto(out *RetryPolicy)

+ type RollingUpdateConfig struct

+ MaxSurge *string

+ MaxUnavailable *string

+ func (in *RollingUpdateConfig) DeepCopy() *RollingUpdateConfig

+ func (in *RollingUpdateConfig) DeepCopyInto(out *RollingUpdateConfig)

+ type S3Authentication struct

+ SecretRef *corev1.LocalObjectReference

+ ServiceAccountAnnotations map[string]string

+ func (in *S3Authentication) DeepCopy() *S3Authentication

+ func (in *S3Authentication) DeepCopyInto(out *S3Authentication)

+ type S3StorageProvider struct

+ Authentication S3Authentication

+ Bucket string

+ Endpoint string

+ Region string

+ func (in *S3StorageProvider) DeepCopy() *S3StorageProvider

+ func (in *S3StorageProvider) DeepCopyInto(out *S3StorageProvider)

+ type SecurityPolicy struct

+ AllowPrivilegeEscalation *bool

+ ReadOnlyRootFilesystem *bool

+ RunAsNonRoot *bool

+ RunAsUser *int64

+ func (in *SecurityPolicy) DeepCopy() *SecurityPolicy

+ func (in *SecurityPolicy) DeepCopyInto(out *SecurityPolicy)

+ type ServiceExposure struct

+ Annotations map[string]string

+ Labels map[string]string

+ Type string

+ func (in *ServiceExposure) DeepCopy() *ServiceExposure

+ func (in *ServiceExposure) DeepCopyInto(out *ServiceExposure)

+ type StatefulSetWorkloadConfig struct

+ PodManagementPolicy *string

+ ServiceName string

+ func (in *StatefulSetWorkloadConfig) DeepCopy() *StatefulSetWorkloadConfig

+ func (in *StatefulSetWorkloadConfig) DeepCopyInto(out *StatefulSetWorkloadConfig)

+ type Step struct

+ Execution *ExecutionOverrides

+ ID string

+ If *string

+ Name string

+ Needs []string

+ Ref *refs.EngramReference

+ Secrets map[string]string

+ Type enums.StepType

+ With *runtime.RawExtension

+ func (in *Step) DeepCopy() *Step

+ func (in *Step) DeepCopyInto(out *Step)

+ type StoragePolicy struct

+ S3 *S3StorageProvider

+ func (in *StoragePolicy) DeepCopy() *StoragePolicy

+ func (in *StoragePolicy) DeepCopyInto(out *StoragePolicy)

+ type Story struct

+ Spec StorySpec

+ Status StoryStatus

+ func (in *Story) DeepCopy() *Story

+ func (in *Story) DeepCopyInto(out *Story)

+ func (in *Story) DeepCopyObject() runtime.Object

+ type StoryList struct

+ Items []Story

+ func (in *StoryList) DeepCopy() *StoryList

+ func (in *StoryList) DeepCopyInto(out *StoryList)

+ func (in *StoryList) DeepCopyObject() runtime.Object

+ type StoryPolicy struct

+ Concurrency *int32

+ Execution *ExecutionPolicy

+ Retries *StoryRetries

+ Storage *StoragePolicy

+ Timeouts *StoryTimeouts

+ With *runtime.RawExtension

+ func (in *StoryPolicy) DeepCopy() *StoryPolicy

+ func (in *StoryPolicy) DeepCopyInto(out *StoryPolicy)

+ type StoryRetries struct

+ ContinueOnStepFailure *bool

+ StepRetryPolicy *RetryPolicy

+ func (in *StoryRetries) DeepCopy() *StoryRetries

+ func (in *StoryRetries) DeepCopyInto(out *StoryRetries)

+ type StorySpec struct

+ InputsSchema *runtime.RawExtension

+ Output *runtime.RawExtension

+ OutputsSchema *runtime.RawExtension

+ Pattern enums.StoryPattern

+ Policy *StoryPolicy

+ Steps []Step

+ StreamingStrategy enums.StreamingStrategy

+ func (in *StorySpec) DeepCopy() *StorySpec

+ func (in *StorySpec) DeepCopyInto(out *StorySpec)

+ type StoryStatus struct

+ Conditions []metav1.Condition

+ ObservedGeneration int64

+ StepsTotal int32

+ func (in *StoryStatus) DeepCopy() *StoryStatus

+ func (in *StoryStatus) DeepCopyInto(out *StoryStatus)

+ type StoryTimeouts struct

+ Step *string

+ Story *string

+ func (in *StoryTimeouts) DeepCopy() *StoryTimeouts

+ func (in *StoryTimeouts) DeepCopyInto(out *StoryTimeouts)

+ type UpdateStrategy struct

+ RollingUpdate *RollingUpdateConfig

+ Type *enums.UpdateStrategyType

+ func (in *UpdateStrategy) DeepCopy() *UpdateStrategy

+ func (in *UpdateStrategy) DeepCopyInto(out *UpdateStrategy)

+ type WorkloadResources struct

+ Limits *ResourceLimits

+ NodeSelector map[string]string

+ Requests *ResourceRequests

+ Tolerations []string

+ func (in *WorkloadResources) DeepCopy() *WorkloadResources

+ func (in *WorkloadResources) DeepCopyInto(out *WorkloadResources)

+ type WorkloadSecurity struct

+ AllowPrivilegeEscalation *bool

+ ReadOnlyRootFilesystem *bool

+ RequiredSecrets []string

+ RunAsNonRoot *bool

+ RunAsUser *int64

+ func (in *WorkloadSecurity) DeepCopy() *WorkloadSecurity

+ func (in *WorkloadSecurity) DeepCopyInto(out *WorkloadSecurity)

+ type WorkloadSpec struct

+ Job *JobWorkloadConfig

+ Mode enums.WorkloadMode

+ Resources *WorkloadResources

+ StatefulSet *StatefulSetWorkloadConfig

+ UpdateStrategy *UpdateStrategy

+ func (in *WorkloadSpec) DeepCopy() *WorkloadSpec

+ func (in *WorkloadSpec) DeepCopyInto(out *WorkloadSpec)

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