Versions in this module Expand all Collapse all v0 v0.44.2 Feb 3, 2025 v0.44.1 Jan 22, 2025 v0.44.0 Jan 20, 2025 Changes in this version + const ExecutionModeEnvVar + const IntegrationSinkConditionAddressable + const IntegrationSinkConditionDeploymentReady + const IntegrationSinkConditionEventPoliciesReady + const IntegrationSinkConditionReady + var IntegrationSinkCondSet = apis.NewLivingConditionSet(IntegrationSinkConditionAddressable, IntegrationSinkConditionDeploymentReady, ...) + type Aws struct + Auth *v1alpha1.Auth + S3 *v1alpha1.AWSS3 + SNS *v1alpha1.AWSSNS + SQS *v1alpha1.AWSSQS + func (in *Aws) DeepCopy() *Aws + func (in *Aws) DeepCopyInto(out *Aws) + type ExecutionMode string + const ExecutionModeBatch + type IntegrationSink struct + Spec IntegrationSinkSpec + Status IntegrationSinkStatus + func (*IntegrationSink) GetConditionSet() apis.ConditionSet + func (*IntegrationSink) GetGroupVersionKind() schema.GroupVersionKind + func (c *IntegrationSink) GetStatus() *duckv1.Status + func (c *IntegrationSink) GetUntypedSpec() interface{} + func (in *IntegrationSink) DeepCopy() *IntegrationSink + func (in *IntegrationSink) DeepCopyInto(out *IntegrationSink) + func (in *IntegrationSink) DeepCopyObject() runtime.Object + func (sink *IntegrationSink) ConvertFrom(ctx context.Context, obj apis.Convertible) error + func (sink *IntegrationSink) ConvertTo(ctx context.Context, obj apis.Convertible) error + func (sink *IntegrationSink) SetDefaults(ctx context.Context) + func (sink *IntegrationSink) Validate(ctx context.Context) *apis.FieldError + type IntegrationSinkList struct + Items []IntegrationSink + func (in *IntegrationSinkList) DeepCopy() *IntegrationSinkList + func (in *IntegrationSinkList) DeepCopyInto(out *IntegrationSinkList) + func (in *IntegrationSinkList) DeepCopyObject() runtime.Object + type IntegrationSinkSpec struct + Aws *Aws + Log *Log + func (in *IntegrationSinkSpec) DeepCopy() *IntegrationSinkSpec + func (in *IntegrationSinkSpec) DeepCopyInto(out *IntegrationSinkSpec) + func (sink *IntegrationSinkSpec) SetDefaults(ctx context.Context) + func (spec *IntegrationSinkSpec) Validate(ctx context.Context) *apis.FieldError + type IntegrationSinkStatus struct + func (in *IntegrationSinkStatus) DeepCopy() *IntegrationSinkStatus + func (in *IntegrationSinkStatus) DeepCopyInto(out *IntegrationSinkStatus) + func (ps *IntegrationSinkStatus) GetTopLevelCondition() *apis.Condition + func (s *IntegrationSinkStatus) GetCondition(t apis.ConditionType) *apis.Condition + func (s *IntegrationSinkStatus) InitializeConditions() + func (s *IntegrationSinkStatus) IsReady() bool + func (s *IntegrationSinkStatus) MarkAddressableReady() + func (s *IntegrationSinkStatus) MarkEventPoliciesFailed(reason, messageFormat string, messageA ...interface{}) + func (s *IntegrationSinkStatus) MarkEventPoliciesTrue() + func (s *IntegrationSinkStatus) MarkEventPoliciesTrueWithReason(reason, messageFormat string, messageA ...interface{}) + func (s *IntegrationSinkStatus) MarkEventPoliciesUnknown(reason, messageFormat string, messageA ...interface{}) + func (s *IntegrationSinkStatus) PropagateDeploymentStatus(d *appsv1.DeploymentStatus) + func (s *IntegrationSinkStatus) SetAddress(address *duckv1.Addressable) + type Log struct + Level string + LogMask bool + LoggerName string + Marker string + Multiline bool + ShowAllProperties bool + ShowBody bool + ShowBodyType bool + ShowCachedStreams bool + ShowExchangePattern bool + ShowHeaders bool + ShowProperties bool + ShowStreams bool + func (in *Log) DeepCopy() *Log + func (in *Log) DeepCopyInto(out *Log) v0.43.3 Nov 21, 2024 v0.43.2 Nov 19, 2024 v0.43.1 Nov 4, 2024 v0.43.0 Oct 22, 2024 Changes in this version + func RegisterDefaults(scheme *runtime.Scheme) error + func SetObjectDefaults_JobSink(in *JobSink) v0.42.5 Nov 21, 2024 v0.42.4 Nov 4, 2024 v0.42.3 Oct 10, 2024 v0.42.2 Sep 23, 2024 v0.42.1 Aug 26, 2024 v0.42.0 Jul 23, 2024 Changes in this version + const JobSinkConditionAddressable + const JobSinkConditionEventPoliciesReady + const JobSinkConditionReady + var AddToScheme = SchemeBuilder.AddToScheme + var JobSinkCondSet = apis.NewLivingConditionSet(JobSinkConditionAddressable, JobSinkConditionEventPoliciesReady) + var SchemeBuilder = runtime.NewSchemeBuilder(addKnownTypes) + var SchemeGroupVersion = schema.GroupVersion + func Kind(kind string) schema.GroupKind + func Resource(resource string) schema.GroupResource + type JobSink struct + Spec JobSinkSpec + Status JobSinkStatus + func (*JobSink) GetConditionSet() apis.ConditionSet + func (e *JobSink) SetJobStatusSelector() + func (in *JobSink) DeepCopy() *JobSink + func (in *JobSink) DeepCopyInto(out *JobSink) + func (in *JobSink) DeepCopyObject() runtime.Object + func (sink *JobSink) ConvertFrom(ctx context.Context, obj apis.Convertible) error + func (sink *JobSink) ConvertTo(ctx context.Context, obj apis.Convertible) error + func (sink *JobSink) GetGroupVersionKind() schema.GroupVersionKind + func (sink *JobSink) GetStatus() *duckv1.Status + func (sink *JobSink) GetUntypedSpec() interface{} + func (sink *JobSink) SetDefaults(ctx context.Context) + func (sink *JobSink) Validate(ctx context.Context) *apis.FieldError + type JobSinkList struct + Items []JobSink + func (in *JobSinkList) DeepCopy() *JobSinkList + func (in *JobSinkList) DeepCopyInto(out *JobSinkList) + func (in *JobSinkList) DeepCopyObject() runtime.Object + type JobSinkSpec struct + Job *batchv1.Job + func (in *JobSinkSpec) DeepCopy() *JobSinkSpec + func (in *JobSinkSpec) DeepCopyInto(out *JobSinkSpec) + func (sink *JobSinkSpec) Validate(ctx context.Context) *apis.FieldError + type JobSinkStatus struct + JobStatus JobStatus + func (in *JobSinkStatus) DeepCopy() *JobSinkStatus + func (in *JobSinkStatus) DeepCopyInto(out *JobSinkStatus) + func (ps *JobSinkStatus) GetTopLevelCondition() *apis.Condition + func (s *JobSinkStatus) GetCondition(t apis.ConditionType) *apis.Condition + func (s *JobSinkStatus) InitializeConditions() + func (s *JobSinkStatus) IsReady() bool + func (s *JobSinkStatus) MarkAddressableReady() + func (s *JobSinkStatus) MarkEventPoliciesFailed(reason, messageFormat string, messageA ...interface{}) + func (s *JobSinkStatus) MarkEventPoliciesTrue() + func (s *JobSinkStatus) MarkEventPoliciesTrueWithReason(reason, messageFormat string, messageA ...interface{}) + func (s *JobSinkStatus) MarkEventPoliciesUnknown(reason, messageFormat string, messageA ...interface{}) + func (s *JobSinkStatus) SetAddress(address *duckv1.Addressable) + type JobStatus struct + Selector string + func (in *JobStatus) DeepCopy() *JobStatus + func (in *JobStatus) DeepCopyInto(out *JobStatus)
Go to main page