Documentation ¶
Overview ¶
Package v1alpha1 is the v1alpha1 version of the API. +groupName=argoproj.io +k8s:deepcopy-gen=package,register +k8s:openapi-gen=true
Index ¶
- Constants
- Variables
- func GetOpenAPIDefinitions(ref common.ReferenceCallback) map[string]common.OpenAPIDefinition
- func Kind(kind string) schema.GroupKind
- func Resource(resource string) schema.GroupResource
- type AWSLambdaTrigger
- func (in *AWSLambdaTrigger) DeepCopy() *AWSLambdaTrigger
- func (in *AWSLambdaTrigger) DeepCopyInto(out *AWSLambdaTrigger)
- func (*AWSLambdaTrigger) Descriptor() ([]byte, []int)
- func (m *AWSLambdaTrigger) Marshal() (dAtA []byte, err error)
- func (m *AWSLambdaTrigger) MarshalTo(dAtA []byte) (int, error)
- func (m *AWSLambdaTrigger) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*AWSLambdaTrigger) ProtoMessage()
- func (m *AWSLambdaTrigger) Reset()
- func (m *AWSLambdaTrigger) Size() (n int)
- func (this *AWSLambdaTrigger) String() string
- func (m *AWSLambdaTrigger) Unmarshal(dAtA []byte) error
- func (m *AWSLambdaTrigger) XXX_DiscardUnknown()
- func (m *AWSLambdaTrigger) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AWSLambdaTrigger) XXX_Merge(src proto.Message)
- func (m *AWSLambdaTrigger) XXX_Size() int
- func (m *AWSLambdaTrigger) XXX_Unmarshal(b []byte) error
- type ArgoWorkflowOperation
- type ArgoWorkflowTrigger
- func (in *ArgoWorkflowTrigger) DeepCopy() *ArgoWorkflowTrigger
- func (in *ArgoWorkflowTrigger) DeepCopyInto(out *ArgoWorkflowTrigger)
- func (*ArgoWorkflowTrigger) Descriptor() ([]byte, []int)
- func (m *ArgoWorkflowTrigger) Marshal() (dAtA []byte, err error)
- func (m *ArgoWorkflowTrigger) MarshalTo(dAtA []byte) (int, error)
- func (m *ArgoWorkflowTrigger) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ArgoWorkflowTrigger) ProtoMessage()
- func (m *ArgoWorkflowTrigger) Reset()
- func (m *ArgoWorkflowTrigger) Size() (n int)
- func (this *ArgoWorkflowTrigger) String() string
- func (m *ArgoWorkflowTrigger) Unmarshal(dAtA []byte) error
- func (m *ArgoWorkflowTrigger) XXX_DiscardUnknown()
- func (m *ArgoWorkflowTrigger) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ArgoWorkflowTrigger) XXX_Merge(src proto.Message)
- func (m *ArgoWorkflowTrigger) XXX_Size() int
- func (m *ArgoWorkflowTrigger) XXX_Unmarshal(b []byte) error
- type ArtifactLocation
- func (in *ArtifactLocation) DeepCopy() *ArtifactLocation
- func (in *ArtifactLocation) DeepCopyInto(out *ArtifactLocation)
- func (*ArtifactLocation) Descriptor() ([]byte, []int)
- func (a *ArtifactLocation) HasLocation() bool
- func (m *ArtifactLocation) Marshal() (dAtA []byte, err error)
- func (m *ArtifactLocation) MarshalTo(dAtA []byte) (int, error)
- func (m *ArtifactLocation) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ArtifactLocation) ProtoMessage()
- func (m *ArtifactLocation) Reset()
- func (m *ArtifactLocation) Size() (n int)
- func (this *ArtifactLocation) String() string
- func (m *ArtifactLocation) Unmarshal(dAtA []byte) error
- func (m *ArtifactLocation) XXX_DiscardUnknown()
- func (m *ArtifactLocation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ArtifactLocation) XXX_Merge(src proto.Message)
- func (m *ArtifactLocation) XXX_Size() int
- func (m *ArtifactLocation) XXX_Unmarshal(b []byte) error
- type Comparator
- type CustomTrigger
- func (in *CustomTrigger) DeepCopy() *CustomTrigger
- func (in *CustomTrigger) DeepCopyInto(out *CustomTrigger)
- func (*CustomTrigger) Descriptor() ([]byte, []int)
- func (m *CustomTrigger) Marshal() (dAtA []byte, err error)
- func (m *CustomTrigger) MarshalTo(dAtA []byte) (int, error)
- func (m *CustomTrigger) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CustomTrigger) ProtoMessage()
- func (m *CustomTrigger) Reset()
- func (m *CustomTrigger) Size() (n int)
- func (this *CustomTrigger) String() string
- func (m *CustomTrigger) Unmarshal(dAtA []byte) error
- func (m *CustomTrigger) XXX_DiscardUnknown()
- func (m *CustomTrigger) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CustomTrigger) XXX_Merge(src proto.Message)
- func (m *CustomTrigger) XXX_Size() int
- func (m *CustomTrigger) XXX_Unmarshal(b []byte) error
- type DataFilter
- func (in *DataFilter) DeepCopy() *DataFilter
- func (in *DataFilter) DeepCopyInto(out *DataFilter)
- func (*DataFilter) Descriptor() ([]byte, []int)
- func (m *DataFilter) Marshal() (dAtA []byte, err error)
- func (m *DataFilter) MarshalTo(dAtA []byte) (int, error)
- func (m *DataFilter) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*DataFilter) ProtoMessage()
- func (m *DataFilter) Reset()
- func (m *DataFilter) Size() (n int)
- func (this *DataFilter) String() string
- func (m *DataFilter) Unmarshal(dAtA []byte) error
- func (m *DataFilter) XXX_DiscardUnknown()
- func (m *DataFilter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DataFilter) XXX_Merge(src proto.Message)
- func (m *DataFilter) XXX_Size() int
- func (m *DataFilter) XXX_Unmarshal(b []byte) error
- type DependencyGroup
- func (in *DependencyGroup) DeepCopy() *DependencyGroup
- func (in *DependencyGroup) DeepCopyInto(out *DependencyGroup)
- func (*DependencyGroup) Descriptor() ([]byte, []int)
- func (m *DependencyGroup) Marshal() (dAtA []byte, err error)
- func (m *DependencyGroup) MarshalTo(dAtA []byte) (int, error)
- func (m *DependencyGroup) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*DependencyGroup) ProtoMessage()
- func (m *DependencyGroup) Reset()
- func (m *DependencyGroup) Size() (n int)
- func (this *DependencyGroup) String() string
- func (m *DependencyGroup) Unmarshal(dAtA []byte) error
- func (m *DependencyGroup) XXX_DiscardUnknown()
- func (m *DependencyGroup) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DependencyGroup) XXX_Merge(src proto.Message)
- func (m *DependencyGroup) XXX_Size() int
- func (m *DependencyGroup) XXX_Unmarshal(b []byte) error
- type Event
- func (e Event) DataString() string
- func (in *Event) DeepCopy() *Event
- func (in *Event) DeepCopyInto(out *Event)
- func (*Event) Descriptor() ([]byte, []int)
- func (m *Event) Marshal() (dAtA []byte, err error)
- func (m *Event) MarshalTo(dAtA []byte) (int, error)
- func (m *Event) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Event) ProtoMessage()
- func (m *Event) Reset()
- func (m *Event) Size() (n int)
- func (e Event) String() string
- func (m *Event) Unmarshal(dAtA []byte) error
- func (m *Event) XXX_DiscardUnknown()
- func (m *Event) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Event) XXX_Merge(src proto.Message)
- func (m *Event) XXX_Size() int
- func (m *Event) XXX_Unmarshal(b []byte) error
- type EventContext
- func (in *EventContext) DeepCopy() *EventContext
- func (in *EventContext) DeepCopyInto(out *EventContext)
- func (*EventContext) Descriptor() ([]byte, []int)
- func (m *EventContext) Marshal() (dAtA []byte, err error)
- func (m *EventContext) MarshalTo(dAtA []byte) (int, error)
- func (m *EventContext) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*EventContext) ProtoMessage()
- func (m *EventContext) Reset()
- func (m *EventContext) Size() (n int)
- func (e EventContext) String() string
- func (m *EventContext) Unmarshal(dAtA []byte) error
- func (m *EventContext) XXX_DiscardUnknown()
- func (m *EventContext) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *EventContext) XXX_Merge(src proto.Message)
- func (m *EventContext) XXX_Size() int
- func (m *EventContext) XXX_Unmarshal(b []byte) error
- type EventDependency
- func (in *EventDependency) DeepCopy() *EventDependency
- func (in *EventDependency) DeepCopyInto(out *EventDependency)
- func (*EventDependency) Descriptor() ([]byte, []int)
- func (m *EventDependency) Marshal() (dAtA []byte, err error)
- func (m *EventDependency) MarshalTo(dAtA []byte) (int, error)
- func (m *EventDependency) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*EventDependency) ProtoMessage()
- func (m *EventDependency) Reset()
- func (m *EventDependency) Size() (n int)
- func (this *EventDependency) String() string
- func (m *EventDependency) Unmarshal(dAtA []byte) error
- func (m *EventDependency) XXX_DiscardUnknown()
- func (m *EventDependency) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *EventDependency) XXX_Merge(src proto.Message)
- func (m *EventDependency) XXX_Size() int
- func (m *EventDependency) XXX_Unmarshal(b []byte) error
- type EventDependencyFilter
- func (in *EventDependencyFilter) DeepCopy() *EventDependencyFilter
- func (in *EventDependencyFilter) DeepCopyInto(out *EventDependencyFilter)
- func (*EventDependencyFilter) Descriptor() ([]byte, []int)
- func (m *EventDependencyFilter) Marshal() (dAtA []byte, err error)
- func (m *EventDependencyFilter) MarshalTo(dAtA []byte) (int, error)
- func (m *EventDependencyFilter) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*EventDependencyFilter) ProtoMessage()
- func (m *EventDependencyFilter) Reset()
- func (m *EventDependencyFilter) Size() (n int)
- func (this *EventDependencyFilter) String() string
- func (m *EventDependencyFilter) Unmarshal(dAtA []byte) error
- func (m *EventDependencyFilter) XXX_DiscardUnknown()
- func (m *EventDependencyFilter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *EventDependencyFilter) XXX_Merge(src proto.Message)
- func (m *EventDependencyFilter) XXX_Size() int
- func (m *EventDependencyFilter) XXX_Unmarshal(b []byte) error
- type FileArtifact
- func (in *FileArtifact) DeepCopy() *FileArtifact
- func (in *FileArtifact) DeepCopyInto(out *FileArtifact)
- func (*FileArtifact) Descriptor() ([]byte, []int)
- func (m *FileArtifact) Marshal() (dAtA []byte, err error)
- func (m *FileArtifact) MarshalTo(dAtA []byte) (int, error)
- func (m *FileArtifact) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*FileArtifact) ProtoMessage()
- func (m *FileArtifact) Reset()
- func (m *FileArtifact) Size() (n int)
- func (this *FileArtifact) String() string
- func (m *FileArtifact) Unmarshal(dAtA []byte) error
- func (m *FileArtifact) XXX_DiscardUnknown()
- func (m *FileArtifact) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *FileArtifact) XXX_Merge(src proto.Message)
- func (m *FileArtifact) XXX_Size() int
- func (m *FileArtifact) XXX_Unmarshal(b []byte) error
- type GitArtifact
- func (in *GitArtifact) DeepCopy() *GitArtifact
- func (in *GitArtifact) DeepCopyInto(out *GitArtifact)
- func (*GitArtifact) Descriptor() ([]byte, []int)
- func (m *GitArtifact) Marshal() (dAtA []byte, err error)
- func (m *GitArtifact) MarshalTo(dAtA []byte) (int, error)
- func (m *GitArtifact) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GitArtifact) ProtoMessage()
- func (m *GitArtifact) Reset()
- func (m *GitArtifact) Size() (n int)
- func (this *GitArtifact) String() string
- func (m *GitArtifact) Unmarshal(dAtA []byte) error
- func (m *GitArtifact) XXX_DiscardUnknown()
- func (m *GitArtifact) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GitArtifact) XXX_Merge(src proto.Message)
- func (m *GitArtifact) XXX_Size() int
- func (m *GitArtifact) XXX_Unmarshal(b []byte) error
- type GitCreds
- func (in *GitCreds) DeepCopy() *GitCreds
- func (in *GitCreds) DeepCopyInto(out *GitCreds)
- func (*GitCreds) Descriptor() ([]byte, []int)
- func (m *GitCreds) Marshal() (dAtA []byte, err error)
- func (m *GitCreds) MarshalTo(dAtA []byte) (int, error)
- func (m *GitCreds) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GitCreds) ProtoMessage()
- func (m *GitCreds) Reset()
- func (m *GitCreds) Size() (n int)
- func (this *GitCreds) String() string
- func (m *GitCreds) Unmarshal(dAtA []byte) error
- func (m *GitCreds) XXX_DiscardUnknown()
- func (m *GitCreds) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GitCreds) XXX_Merge(src proto.Message)
- func (m *GitCreds) XXX_Size() int
- func (m *GitCreds) XXX_Unmarshal(b []byte) error
- type GitRemoteConfig
- func (in *GitRemoteConfig) DeepCopy() *GitRemoteConfig
- func (in *GitRemoteConfig) DeepCopyInto(out *GitRemoteConfig)
- func (*GitRemoteConfig) Descriptor() ([]byte, []int)
- func (m *GitRemoteConfig) Marshal() (dAtA []byte, err error)
- func (m *GitRemoteConfig) MarshalTo(dAtA []byte) (int, error)
- func (m *GitRemoteConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GitRemoteConfig) ProtoMessage()
- func (m *GitRemoteConfig) Reset()
- func (m *GitRemoteConfig) Size() (n int)
- func (this *GitRemoteConfig) String() string
- func (m *GitRemoteConfig) Unmarshal(dAtA []byte) error
- func (m *GitRemoteConfig) XXX_DiscardUnknown()
- func (m *GitRemoteConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GitRemoteConfig) XXX_Merge(src proto.Message)
- func (m *GitRemoteConfig) XXX_Size() int
- func (m *GitRemoteConfig) XXX_Unmarshal(b []byte) error
- type HTTPTrigger
- func (in *HTTPTrigger) DeepCopy() *HTTPTrigger
- func (in *HTTPTrigger) DeepCopyInto(out *HTTPTrigger)
- func (*HTTPTrigger) Descriptor() ([]byte, []int)
- func (m *HTTPTrigger) Marshal() (dAtA []byte, err error)
- func (m *HTTPTrigger) MarshalTo(dAtA []byte) (int, error)
- func (m *HTTPTrigger) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*HTTPTrigger) ProtoMessage()
- func (m *HTTPTrigger) Reset()
- func (m *HTTPTrigger) Size() (n int)
- func (this *HTTPTrigger) String() string
- func (m *HTTPTrigger) Unmarshal(dAtA []byte) error
- func (m *HTTPTrigger) XXX_DiscardUnknown()
- func (m *HTTPTrigger) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *HTTPTrigger) XXX_Merge(src proto.Message)
- func (m *HTTPTrigger) XXX_Size() int
- func (m *HTTPTrigger) XXX_Unmarshal(b []byte) error
- type JSONType
- type K8SResourcePolicy
- func (in *K8SResourcePolicy) DeepCopy() *K8SResourcePolicy
- func (in *K8SResourcePolicy) DeepCopyInto(out *K8SResourcePolicy)
- func (*K8SResourcePolicy) Descriptor() ([]byte, []int)
- func (m *K8SResourcePolicy) Marshal() (dAtA []byte, err error)
- func (m *K8SResourcePolicy) MarshalTo(dAtA []byte) (int, error)
- func (m *K8SResourcePolicy) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*K8SResourcePolicy) ProtoMessage()
- func (m *K8SResourcePolicy) Reset()
- func (m *K8SResourcePolicy) Size() (n int)
- func (this *K8SResourcePolicy) String() string
- func (m *K8SResourcePolicy) Unmarshal(dAtA []byte) error
- func (m *K8SResourcePolicy) XXX_DiscardUnknown()
- func (m *K8SResourcePolicy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *K8SResourcePolicy) XXX_Merge(src proto.Message)
- func (m *K8SResourcePolicy) XXX_Size() int
- func (m *K8SResourcePolicy) XXX_Unmarshal(b []byte) error
- type KafkaTrigger
- func (in *KafkaTrigger) DeepCopy() *KafkaTrigger
- func (in *KafkaTrigger) DeepCopyInto(out *KafkaTrigger)
- func (*KafkaTrigger) Descriptor() ([]byte, []int)
- func (m *KafkaTrigger) Marshal() (dAtA []byte, err error)
- func (m *KafkaTrigger) MarshalTo(dAtA []byte) (int, error)
- func (m *KafkaTrigger) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*KafkaTrigger) ProtoMessage()
- func (m *KafkaTrigger) Reset()
- func (m *KafkaTrigger) Size() (n int)
- func (this *KafkaTrigger) String() string
- func (m *KafkaTrigger) Unmarshal(dAtA []byte) error
- func (m *KafkaTrigger) XXX_DiscardUnknown()
- func (m *KafkaTrigger) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *KafkaTrigger) XXX_Merge(src proto.Message)
- func (m *KafkaTrigger) XXX_Size() int
- func (m *KafkaTrigger) XXX_Unmarshal(b []byte) error
- type KubernetesResourceOperation
- type LogTrigger
- func (in *LogTrigger) DeepCopy() *LogTrigger
- func (in *LogTrigger) DeepCopyInto(out *LogTrigger)
- func (*LogTrigger) Descriptor() ([]byte, []int)
- func (in *LogTrigger) GetInterval() time.Duration
- func (m *LogTrigger) Marshal() (dAtA []byte, err error)
- func (m *LogTrigger) MarshalTo(dAtA []byte) (int, error)
- func (m *LogTrigger) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*LogTrigger) ProtoMessage()
- func (m *LogTrigger) Reset()
- func (m *LogTrigger) Size() (n int)
- func (this *LogTrigger) String() string
- func (m *LogTrigger) Unmarshal(dAtA []byte) error
- func (m *LogTrigger) XXX_DiscardUnknown()
- func (m *LogTrigger) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *LogTrigger) XXX_Merge(src proto.Message)
- func (m *LogTrigger) XXX_Size() int
- func (m *LogTrigger) XXX_Unmarshal(b []byte) error
- type NATSTrigger
- func (in *NATSTrigger) DeepCopy() *NATSTrigger
- func (in *NATSTrigger) DeepCopyInto(out *NATSTrigger)
- func (*NATSTrigger) Descriptor() ([]byte, []int)
- func (m *NATSTrigger) Marshal() (dAtA []byte, err error)
- func (m *NATSTrigger) MarshalTo(dAtA []byte) (int, error)
- func (m *NATSTrigger) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*NATSTrigger) ProtoMessage()
- func (m *NATSTrigger) Reset()
- func (m *NATSTrigger) Size() (n int)
- func (this *NATSTrigger) String() string
- func (m *NATSTrigger) Unmarshal(dAtA []byte) error
- func (m *NATSTrigger) XXX_DiscardUnknown()
- func (m *NATSTrigger) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *NATSTrigger) XXX_Merge(src proto.Message)
- func (m *NATSTrigger) XXX_Size() int
- func (m *NATSTrigger) XXX_Unmarshal(b []byte) error
- type OpenWhiskTrigger
- func (in *OpenWhiskTrigger) DeepCopy() *OpenWhiskTrigger
- func (in *OpenWhiskTrigger) DeepCopyInto(out *OpenWhiskTrigger)
- func (*OpenWhiskTrigger) Descriptor() ([]byte, []int)
- func (m *OpenWhiskTrigger) Marshal() (dAtA []byte, err error)
- func (m *OpenWhiskTrigger) MarshalTo(dAtA []byte) (int, error)
- func (m *OpenWhiskTrigger) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*OpenWhiskTrigger) ProtoMessage()
- func (m *OpenWhiskTrigger) Reset()
- func (m *OpenWhiskTrigger) Size() (n int)
- func (this *OpenWhiskTrigger) String() string
- func (m *OpenWhiskTrigger) Unmarshal(dAtA []byte) error
- func (m *OpenWhiskTrigger) XXX_DiscardUnknown()
- func (m *OpenWhiskTrigger) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *OpenWhiskTrigger) XXX_Merge(src proto.Message)
- func (m *OpenWhiskTrigger) XXX_Size() int
- func (m *OpenWhiskTrigger) XXX_Unmarshal(b []byte) error
- type Sensor
- func (in *Sensor) DeepCopy() *Sensor
- func (in *Sensor) DeepCopyInto(out *Sensor)
- func (in *Sensor) DeepCopyObject() runtime.Object
- func (*Sensor) Descriptor() ([]byte, []int)
- func (m *Sensor) Marshal() (dAtA []byte, err error)
- func (m *Sensor) MarshalTo(dAtA []byte) (int, error)
- func (m *Sensor) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Sensor) ProtoMessage()
- func (m *Sensor) Reset()
- func (m *Sensor) Size() (n int)
- func (this *Sensor) String() string
- func (m *Sensor) Unmarshal(dAtA []byte) error
- func (m *Sensor) XXX_DiscardUnknown()
- func (m *Sensor) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Sensor) XXX_Merge(src proto.Message)
- func (m *Sensor) XXX_Size() int
- func (m *Sensor) XXX_Unmarshal(b []byte) error
- type SensorList
- func (in *SensorList) DeepCopy() *SensorList
- func (in *SensorList) DeepCopyInto(out *SensorList)
- func (in *SensorList) DeepCopyObject() runtime.Object
- func (*SensorList) Descriptor() ([]byte, []int)
- func (m *SensorList) Marshal() (dAtA []byte, err error)
- func (m *SensorList) MarshalTo(dAtA []byte) (int, error)
- func (m *SensorList) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SensorList) ProtoMessage()
- func (m *SensorList) Reset()
- func (m *SensorList) Size() (n int)
- func (this *SensorList) String() string
- func (m *SensorList) Unmarshal(dAtA []byte) error
- func (m *SensorList) XXX_DiscardUnknown()
- func (m *SensorList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SensorList) XXX_Merge(src proto.Message)
- func (m *SensorList) XXX_Size() int
- func (m *SensorList) XXX_Unmarshal(b []byte) error
- type SensorSpec
- func (in *SensorSpec) DeepCopy() *SensorSpec
- func (in *SensorSpec) DeepCopyInto(out *SensorSpec)
- func (*SensorSpec) Descriptor() ([]byte, []int)
- func (m *SensorSpec) Marshal() (dAtA []byte, err error)
- func (m *SensorSpec) MarshalTo(dAtA []byte) (int, error)
- func (m *SensorSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SensorSpec) ProtoMessage()
- func (m *SensorSpec) Reset()
- func (m *SensorSpec) Size() (n int)
- func (this *SensorSpec) String() string
- func (m *SensorSpec) Unmarshal(dAtA []byte) error
- func (m *SensorSpec) XXX_DiscardUnknown()
- func (m *SensorSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SensorSpec) XXX_Merge(src proto.Message)
- func (m *SensorSpec) XXX_Size() int
- func (m *SensorSpec) XXX_Unmarshal(b []byte) error
- type SensorStatus
- func (in *SensorStatus) DeepCopy() *SensorStatus
- func (in *SensorStatus) DeepCopyInto(out *SensorStatus)
- func (*SensorStatus) Descriptor() ([]byte, []int)
- func (s *SensorStatus) InitConditions()
- func (s *SensorStatus) MarkDependenciesNotProvided(reason, message string)
- func (s *SensorStatus) MarkDependenciesProvided()
- func (s *SensorStatus) MarkDeployFailed(reason, message string)
- func (s *SensorStatus) MarkDeployed()
- func (s *SensorStatus) MarkTriggersNotProvided(reason, message string)
- func (s *SensorStatus) MarkTriggersProvided()
- func (m *SensorStatus) Marshal() (dAtA []byte, err error)
- func (m *SensorStatus) MarshalTo(dAtA []byte) (int, error)
- func (m *SensorStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SensorStatus) ProtoMessage()
- func (m *SensorStatus) Reset()
- func (m *SensorStatus) Size() (n int)
- func (this *SensorStatus) String() string
- func (m *SensorStatus) Unmarshal(dAtA []byte) error
- func (m *SensorStatus) XXX_DiscardUnknown()
- func (m *SensorStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SensorStatus) XXX_Merge(src proto.Message)
- func (m *SensorStatus) XXX_Size() int
- func (m *SensorStatus) XXX_Unmarshal(b []byte) error
- type SlackTrigger
- func (in *SlackTrigger) DeepCopy() *SlackTrigger
- func (in *SlackTrigger) DeepCopyInto(out *SlackTrigger)
- func (*SlackTrigger) Descriptor() ([]byte, []int)
- func (m *SlackTrigger) Marshal() (dAtA []byte, err error)
- func (m *SlackTrigger) MarshalTo(dAtA []byte) (int, error)
- func (m *SlackTrigger) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SlackTrigger) ProtoMessage()
- func (m *SlackTrigger) Reset()
- func (m *SlackTrigger) Size() (n int)
- func (this *SlackTrigger) String() string
- func (m *SlackTrigger) Unmarshal(dAtA []byte) error
- func (m *SlackTrigger) XXX_DiscardUnknown()
- func (m *SlackTrigger) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SlackTrigger) XXX_Merge(src proto.Message)
- func (m *SlackTrigger) XXX_Size() int
- func (m *SlackTrigger) XXX_Unmarshal(b []byte) error
- type StandardK8STrigger
- func (in *StandardK8STrigger) DeepCopy() *StandardK8STrigger
- func (in *StandardK8STrigger) DeepCopyInto(out *StandardK8STrigger)
- func (*StandardK8STrigger) Descriptor() ([]byte, []int)
- func (m *StandardK8STrigger) Marshal() (dAtA []byte, err error)
- func (m *StandardK8STrigger) MarshalTo(dAtA []byte) (int, error)
- func (m *StandardK8STrigger) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*StandardK8STrigger) ProtoMessage()
- func (m *StandardK8STrigger) Reset()
- func (m *StandardK8STrigger) Size() (n int)
- func (this *StandardK8STrigger) String() string
- func (m *StandardK8STrigger) Unmarshal(dAtA []byte) error
- func (m *StandardK8STrigger) XXX_DiscardUnknown()
- func (m *StandardK8STrigger) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StandardK8STrigger) XXX_Merge(src proto.Message)
- func (m *StandardK8STrigger) XXX_Size() int
- func (m *StandardK8STrigger) XXX_Unmarshal(b []byte) error
- type StatusPolicy
- func (in *StatusPolicy) DeepCopy() *StatusPolicy
- func (in *StatusPolicy) DeepCopyInto(out *StatusPolicy)
- func (*StatusPolicy) Descriptor() ([]byte, []int)
- func (in *StatusPolicy) GetAllow() []int
- func (m *StatusPolicy) Marshal() (dAtA []byte, err error)
- func (m *StatusPolicy) MarshalTo(dAtA []byte) (int, error)
- func (m *StatusPolicy) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*StatusPolicy) ProtoMessage()
- func (m *StatusPolicy) Reset()
- func (m *StatusPolicy) Size() (n int)
- func (this *StatusPolicy) String() string
- func (m *StatusPolicy) Unmarshal(dAtA []byte) error
- func (m *StatusPolicy) XXX_DiscardUnknown()
- func (m *StatusPolicy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StatusPolicy) XXX_Merge(src proto.Message)
- func (m *StatusPolicy) XXX_Size() int
- func (m *StatusPolicy) XXX_Unmarshal(b []byte) error
- type Template
- func (in *Template) DeepCopy() *Template
- func (in *Template) DeepCopyInto(out *Template)
- func (*Template) Descriptor() ([]byte, []int)
- func (m *Template) Marshal() (dAtA []byte, err error)
- func (m *Template) MarshalTo(dAtA []byte) (int, error)
- func (m *Template) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Template) ProtoMessage()
- func (m *Template) Reset()
- func (m *Template) Size() (n int)
- func (this *Template) String() string
- func (m *Template) Unmarshal(dAtA []byte) error
- func (m *Template) XXX_DiscardUnknown()
- func (m *Template) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Template) XXX_Merge(src proto.Message)
- func (m *Template) XXX_Size() int
- func (m *Template) XXX_Unmarshal(b []byte) error
- type TimeFilter
- func (in *TimeFilter) DeepCopy() *TimeFilter
- func (in *TimeFilter) DeepCopyInto(out *TimeFilter)
- func (*TimeFilter) Descriptor() ([]byte, []int)
- func (m *TimeFilter) Marshal() (dAtA []byte, err error)
- func (m *TimeFilter) MarshalTo(dAtA []byte) (int, error)
- func (m *TimeFilter) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*TimeFilter) ProtoMessage()
- func (m *TimeFilter) Reset()
- func (m *TimeFilter) Size() (n int)
- func (this *TimeFilter) String() string
- func (m *TimeFilter) Unmarshal(dAtA []byte) error
- func (m *TimeFilter) XXX_DiscardUnknown()
- func (m *TimeFilter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TimeFilter) XXX_Merge(src proto.Message)
- func (m *TimeFilter) XXX_Size() int
- func (m *TimeFilter) XXX_Unmarshal(b []byte) error
- type Trigger
- func (in *Trigger) DeepCopy() *Trigger
- func (in *Trigger) DeepCopyInto(out *Trigger)
- func (*Trigger) Descriptor() ([]byte, []int)
- func (m *Trigger) Marshal() (dAtA []byte, err error)
- func (m *Trigger) MarshalTo(dAtA []byte) (int, error)
- func (m *Trigger) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Trigger) ProtoMessage()
- func (m *Trigger) Reset()
- func (m *Trigger) Size() (n int)
- func (this *Trigger) String() string
- func (m *Trigger) Unmarshal(dAtA []byte) error
- func (m *Trigger) XXX_DiscardUnknown()
- func (m *Trigger) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Trigger) XXX_Merge(src proto.Message)
- func (m *Trigger) XXX_Size() int
- func (m *Trigger) XXX_Unmarshal(b []byte) error
- type TriggerParameter
- func (in *TriggerParameter) DeepCopy() *TriggerParameter
- func (in *TriggerParameter) DeepCopyInto(out *TriggerParameter)
- func (*TriggerParameter) Descriptor() ([]byte, []int)
- func (m *TriggerParameter) Marshal() (dAtA []byte, err error)
- func (m *TriggerParameter) MarshalTo(dAtA []byte) (int, error)
- func (m *TriggerParameter) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*TriggerParameter) ProtoMessage()
- func (m *TriggerParameter) Reset()
- func (m *TriggerParameter) Size() (n int)
- func (this *TriggerParameter) String() string
- func (m *TriggerParameter) Unmarshal(dAtA []byte) error
- func (m *TriggerParameter) XXX_DiscardUnknown()
- func (m *TriggerParameter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TriggerParameter) XXX_Merge(src proto.Message)
- func (m *TriggerParameter) XXX_Size() int
- func (m *TriggerParameter) XXX_Unmarshal(b []byte) error
- type TriggerParameterOperation
- type TriggerParameterSource
- func (in *TriggerParameterSource) DeepCopy() *TriggerParameterSource
- func (in *TriggerParameterSource) DeepCopyInto(out *TriggerParameterSource)
- func (*TriggerParameterSource) Descriptor() ([]byte, []int)
- func (m *TriggerParameterSource) Marshal() (dAtA []byte, err error)
- func (m *TriggerParameterSource) MarshalTo(dAtA []byte) (int, error)
- func (m *TriggerParameterSource) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*TriggerParameterSource) ProtoMessage()
- func (m *TriggerParameterSource) Reset()
- func (m *TriggerParameterSource) Size() (n int)
- func (this *TriggerParameterSource) String() string
- func (m *TriggerParameterSource) Unmarshal(dAtA []byte) error
- func (m *TriggerParameterSource) XXX_DiscardUnknown()
- func (m *TriggerParameterSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TriggerParameterSource) XXX_Merge(src proto.Message)
- func (m *TriggerParameterSource) XXX_Size() int
- func (m *TriggerParameterSource) XXX_Unmarshal(b []byte) error
- type TriggerPolicy
- func (in *TriggerPolicy) DeepCopy() *TriggerPolicy
- func (in *TriggerPolicy) DeepCopyInto(out *TriggerPolicy)
- func (*TriggerPolicy) Descriptor() ([]byte, []int)
- func (m *TriggerPolicy) Marshal() (dAtA []byte, err error)
- func (m *TriggerPolicy) MarshalTo(dAtA []byte) (int, error)
- func (m *TriggerPolicy) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*TriggerPolicy) ProtoMessage()
- func (m *TriggerPolicy) Reset()
- func (m *TriggerPolicy) Size() (n int)
- func (this *TriggerPolicy) String() string
- func (m *TriggerPolicy) Unmarshal(dAtA []byte) error
- func (m *TriggerPolicy) XXX_DiscardUnknown()
- func (m *TriggerPolicy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TriggerPolicy) XXX_Merge(src proto.Message)
- func (m *TriggerPolicy) XXX_Size() int
- func (m *TriggerPolicy) XXX_Unmarshal(b []byte) error
- type TriggerSwitch
- func (in *TriggerSwitch) DeepCopy() *TriggerSwitch
- func (in *TriggerSwitch) DeepCopyInto(out *TriggerSwitch)
- func (*TriggerSwitch) Descriptor() ([]byte, []int)
- func (m *TriggerSwitch) Marshal() (dAtA []byte, err error)
- func (m *TriggerSwitch) MarshalTo(dAtA []byte) (int, error)
- func (m *TriggerSwitch) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*TriggerSwitch) ProtoMessage()
- func (m *TriggerSwitch) Reset()
- func (m *TriggerSwitch) Size() (n int)
- func (this *TriggerSwitch) String() string
- func (m *TriggerSwitch) Unmarshal(dAtA []byte) error
- func (m *TriggerSwitch) XXX_DiscardUnknown()
- func (m *TriggerSwitch) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TriggerSwitch) XXX_Merge(src proto.Message)
- func (m *TriggerSwitch) XXX_Size() int
- func (m *TriggerSwitch) XXX_Unmarshal(b []byte) error
- type TriggerTemplate
- func (in *TriggerTemplate) DeepCopy() *TriggerTemplate
- func (in *TriggerTemplate) DeepCopyInto(out *TriggerTemplate)
- func (*TriggerTemplate) Descriptor() ([]byte, []int)
- func (m *TriggerTemplate) Marshal() (dAtA []byte, err error)
- func (m *TriggerTemplate) MarshalTo(dAtA []byte) (int, error)
- func (m *TriggerTemplate) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*TriggerTemplate) ProtoMessage()
- func (m *TriggerTemplate) Reset()
- func (m *TriggerTemplate) Size() (n int)
- func (this *TriggerTemplate) String() string
- func (m *TriggerTemplate) Unmarshal(dAtA []byte) error
- func (m *TriggerTemplate) XXX_DiscardUnknown()
- func (m *TriggerTemplate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TriggerTemplate) XXX_Merge(src proto.Message)
- func (m *TriggerTemplate) XXX_Size() int
- func (m *TriggerTemplate) XXX_Unmarshal(b []byte) error
- type URLArtifact
- func (in *URLArtifact) DeepCopy() *URLArtifact
- func (in *URLArtifact) DeepCopyInto(out *URLArtifact)
- func (*URLArtifact) Descriptor() ([]byte, []int)
- func (m *URLArtifact) Marshal() (dAtA []byte, err error)
- func (m *URLArtifact) MarshalTo(dAtA []byte) (int, error)
- func (m *URLArtifact) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*URLArtifact) ProtoMessage()
- func (m *URLArtifact) Reset()
- func (m *URLArtifact) Size() (n int)
- func (this *URLArtifact) String() string
- func (m *URLArtifact) Unmarshal(dAtA []byte) error
- func (m *URLArtifact) XXX_DiscardUnknown()
- func (m *URLArtifact) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *URLArtifact) XXX_Merge(src proto.Message)
- func (m *URLArtifact) XXX_Size() int
- func (m *URLArtifact) XXX_Unmarshal(b []byte) error
Constants ¶
const ( // SensorConditionDepencencyProvided has the status True when the // Sensor has valid dependencies provided. SensorConditionDepencencyProvided apicommon.ConditionType = "DependenciesProvided" // SensorConditionTriggersProvided has the status True when the // Sensor has valid triggers provided. SensorConditionTriggersProvided apicommon.ConditionType = "TriggersProvided" // SensorConditionDeployed has the status True when the Sensor // has its Deployment created. SensorConditionDeployed apicommon.ConditionType = "Deployed" )
Variables ¶
var ( ErrInvalidLengthGenerated = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowGenerated = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupGenerated = fmt.Errorf("proto: unexpected end of group") )
var ( // SchemeGroupVersion is group version used to register these objects SchemeGroupVersion = schema.GroupVersion{Group: sensor.Group, Version: "v1alpha1"} // SchemaGroupVersionKind is a group version kind used to attach owner references SchemaGroupVersionKind = schema.GroupVersionKind{Group: sensor.Group, Version: "v1alpha1", Kind: sensor.Kind} // SchemeBuilder is used to add go types to the GroupVersionKind scheme SchemeBuilder = runtime.NewSchemeBuilder(addKnownTypes) // AddToScheme is required by pkg/client/... AddToScheme = SchemeBuilder.AddToScheme )
Functions ¶
func GetOpenAPIDefinitions ¶
func GetOpenAPIDefinitions(ref common.ReferenceCallback) map[string]common.OpenAPIDefinition
func Resource ¶
func Resource(resource string) schema.GroupResource
Resource takes an unqualified resource and returns a Group qualified GroupResource
Types ¶
type AWSLambdaTrigger ¶ added in v0.13.0
type AWSLambdaTrigger struct { // FunctionName refers to the name of the function to invoke. FunctionName string `json:"functionName" protobuf:"bytes,1,opt,name=functionName"` // AccessKey refers K8 secret containing aws access key AccessKey *corev1.SecretKeySelector `json:"accessKey,omitempty" protobuf:"bytes,2,opt,name=accessKey"` // SecretKey refers K8 secret containing aws secret key SecretKey *corev1.SecretKeySelector `json:"secretKey,omitempty" protobuf:"bytes,3,opt,name=secretKey"` // Region is AWS region Region string `json:"region" protobuf:"bytes,4,opt,name=region"` Payload []TriggerParameter `json:"payload" protobuf:"bytes,5,rep,name=payload"` // +optional Parameters []TriggerParameter `json:"parameters,omitempty" protobuf:"bytes,6,rep,name=parameters"` }
AWSLambdaTrigger refers to specification of the trigger to invoke an AWS Lambda function
func (*AWSLambdaTrigger) DeepCopy ¶ added in v0.13.0
func (in *AWSLambdaTrigger) DeepCopy() *AWSLambdaTrigger
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AWSLambdaTrigger.
func (*AWSLambdaTrigger) DeepCopyInto ¶ added in v0.13.0
func (in *AWSLambdaTrigger) DeepCopyInto(out *AWSLambdaTrigger)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*AWSLambdaTrigger) Descriptor ¶ added in v0.17.0
func (*AWSLambdaTrigger) Descriptor() ([]byte, []int)
func (*AWSLambdaTrigger) Marshal ¶ added in v0.17.0
func (m *AWSLambdaTrigger) Marshal() (dAtA []byte, err error)
func (*AWSLambdaTrigger) MarshalTo ¶ added in v0.17.0
func (m *AWSLambdaTrigger) MarshalTo(dAtA []byte) (int, error)
func (*AWSLambdaTrigger) MarshalToSizedBuffer ¶ added in v0.17.0
func (m *AWSLambdaTrigger) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*AWSLambdaTrigger) ProtoMessage ¶ added in v0.17.0
func (*AWSLambdaTrigger) ProtoMessage()
func (*AWSLambdaTrigger) Reset ¶ added in v0.17.0
func (m *AWSLambdaTrigger) Reset()
func (*AWSLambdaTrigger) Size ¶ added in v0.17.0
func (m *AWSLambdaTrigger) Size() (n int)
func (*AWSLambdaTrigger) String ¶ added in v0.17.0
func (this *AWSLambdaTrigger) String() string
func (*AWSLambdaTrigger) Unmarshal ¶ added in v0.17.0
func (m *AWSLambdaTrigger) Unmarshal(dAtA []byte) error
func (*AWSLambdaTrigger) XXX_DiscardUnknown ¶ added in v0.17.0
func (m *AWSLambdaTrigger) XXX_DiscardUnknown()
func (*AWSLambdaTrigger) XXX_Marshal ¶ added in v0.17.0
func (m *AWSLambdaTrigger) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AWSLambdaTrigger) XXX_Merge ¶ added in v0.17.0
func (m *AWSLambdaTrigger) XXX_Merge(src proto.Message)
func (*AWSLambdaTrigger) XXX_Size ¶ added in v0.17.0
func (m *AWSLambdaTrigger) XXX_Size() int
func (*AWSLambdaTrigger) XXX_Unmarshal ¶ added in v0.17.0
func (m *AWSLambdaTrigger) XXX_Unmarshal(b []byte) error
type ArgoWorkflowOperation ¶ added in v0.13.0
type ArgoWorkflowOperation string
ArgoWorkflowOperation refers to the type of the operation performed on the Argo Workflow
const ( Submit ArgoWorkflowOperation = "submit" // submit a workflow Suspend ArgoWorkflowOperation = "suspend" // suspends a workflow Resubmit ArgoWorkflowOperation = "resubmit" // resubmit a workflow Retry ArgoWorkflowOperation = "retry" // retry a workflow Resume ArgoWorkflowOperation = "resume" // resume a workflow )
possible values for ArgoWorkflowOperation
type ArgoWorkflowTrigger ¶ added in v0.13.0
type ArgoWorkflowTrigger struct { // Source of the K8 resource file(s) Source *ArtifactLocation `json:"source,omitempty" protobuf:"bytes,1,opt,name=source"` // Operation refers to the type of operation performed on the argo workflow resource. // Default value is Submit. // +optional Operation ArgoWorkflowOperation `json:"operation,omitempty" protobuf:"bytes,2,opt,name=operation,casttype=ArgoWorkflowOperation"` Parameters []TriggerParameter `json:"parameters,omitempty" protobuf:"bytes,3,rep,name=parameters"` // The unambiguous kind of this object - used in order to retrieve the appropriate kubernetes api client for this resource metav1.GroupVersionResource `json:",inline" protobuf:"bytes,4,opt,name=groupVersionResource"` }
ArgoWorkflowTrigger is the trigger for the Argo Workflow
func (*ArgoWorkflowTrigger) DeepCopy ¶ added in v0.13.0
func (in *ArgoWorkflowTrigger) DeepCopy() *ArgoWorkflowTrigger
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ArgoWorkflowTrigger.
func (*ArgoWorkflowTrigger) DeepCopyInto ¶ added in v0.13.0
func (in *ArgoWorkflowTrigger) DeepCopyInto(out *ArgoWorkflowTrigger)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ArgoWorkflowTrigger) Descriptor ¶ added in v0.17.0
func (*ArgoWorkflowTrigger) Descriptor() ([]byte, []int)
func (*ArgoWorkflowTrigger) Marshal ¶ added in v0.17.0
func (m *ArgoWorkflowTrigger) Marshal() (dAtA []byte, err error)
func (*ArgoWorkflowTrigger) MarshalTo ¶ added in v0.17.0
func (m *ArgoWorkflowTrigger) MarshalTo(dAtA []byte) (int, error)
func (*ArgoWorkflowTrigger) MarshalToSizedBuffer ¶ added in v0.17.0
func (m *ArgoWorkflowTrigger) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ArgoWorkflowTrigger) ProtoMessage ¶ added in v0.17.0
func (*ArgoWorkflowTrigger) ProtoMessage()
func (*ArgoWorkflowTrigger) Reset ¶ added in v0.17.0
func (m *ArgoWorkflowTrigger) Reset()
func (*ArgoWorkflowTrigger) Size ¶ added in v0.17.0
func (m *ArgoWorkflowTrigger) Size() (n int)
func (*ArgoWorkflowTrigger) String ¶ added in v0.17.0
func (this *ArgoWorkflowTrigger) String() string
func (*ArgoWorkflowTrigger) Unmarshal ¶ added in v0.17.0
func (m *ArgoWorkflowTrigger) Unmarshal(dAtA []byte) error
func (*ArgoWorkflowTrigger) XXX_DiscardUnknown ¶ added in v0.17.0
func (m *ArgoWorkflowTrigger) XXX_DiscardUnknown()
func (*ArgoWorkflowTrigger) XXX_Marshal ¶ added in v0.17.0
func (m *ArgoWorkflowTrigger) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ArgoWorkflowTrigger) XXX_Merge ¶ added in v0.17.0
func (m *ArgoWorkflowTrigger) XXX_Merge(src proto.Message)
func (*ArgoWorkflowTrigger) XXX_Size ¶ added in v0.17.0
func (m *ArgoWorkflowTrigger) XXX_Size() int
func (*ArgoWorkflowTrigger) XXX_Unmarshal ¶ added in v0.17.0
func (m *ArgoWorkflowTrigger) XXX_Unmarshal(b []byte) error
type ArtifactLocation ¶
type ArtifactLocation struct { // S3 compliant artifact S3 *apicommon.S3Artifact `json:"s3,omitempty" protobuf:"bytes,1,opt,name=s3"` // Inline artifact is embedded in sensor spec as a string Inline *string `json:"inline,omitempty" protobuf:"bytes,2,opt,name=inline"` // File artifact is artifact stored in a file File *FileArtifact `json:"file,omitempty" protobuf:"bytes,3,opt,name=file"` // URL to fetch the artifact from URL *URLArtifact `json:"url,omitempty" protobuf:"bytes,4,opt,name=url"` // Configmap that stores the artifact Configmap *corev1.ConfigMapKeySelector `json:"configmap,omitempty" protobuf:"bytes,5,opt,name=configmap"` // Git repository hosting the artifact Git *GitArtifact `json:"git,omitempty" protobuf:"bytes,6,opt,name=git"` // Resource is generic template for K8s resource Resource *apicommon.Resource `json:"resource,omitempty" protobuf:"bytes,7,opt,name=resource"` }
ArtifactLocation describes the source location for an external artifact
func (*ArtifactLocation) DeepCopy ¶
func (in *ArtifactLocation) DeepCopy() *ArtifactLocation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ArtifactLocation.
func (*ArtifactLocation) DeepCopyInto ¶
func (in *ArtifactLocation) DeepCopyInto(out *ArtifactLocation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ArtifactLocation) Descriptor ¶
func (*ArtifactLocation) Descriptor() ([]byte, []int)
func (*ArtifactLocation) HasLocation ¶
func (a *ArtifactLocation) HasLocation() bool
HasLocation whether or not an artifact has a location defined
func (*ArtifactLocation) Marshal ¶
func (m *ArtifactLocation) Marshal() (dAtA []byte, err error)
func (*ArtifactLocation) MarshalToSizedBuffer ¶ added in v0.17.0
func (m *ArtifactLocation) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ArtifactLocation) ProtoMessage ¶
func (*ArtifactLocation) ProtoMessage()
func (*ArtifactLocation) Reset ¶
func (m *ArtifactLocation) Reset()
func (*ArtifactLocation) Size ¶
func (m *ArtifactLocation) Size() (n int)
func (*ArtifactLocation) String ¶
func (this *ArtifactLocation) String() string
func (*ArtifactLocation) Unmarshal ¶
func (m *ArtifactLocation) Unmarshal(dAtA []byte) error
func (*ArtifactLocation) XXX_DiscardUnknown ¶
func (m *ArtifactLocation) XXX_DiscardUnknown()
func (*ArtifactLocation) XXX_Marshal ¶
func (m *ArtifactLocation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ArtifactLocation) XXX_Merge ¶
func (m *ArtifactLocation) XXX_Merge(src proto.Message)
func (*ArtifactLocation) XXX_Size ¶
func (m *ArtifactLocation) XXX_Size() int
func (*ArtifactLocation) XXX_Unmarshal ¶
func (m *ArtifactLocation) XXX_Unmarshal(b []byte) error
type Comparator ¶ added in v0.13.0
type Comparator string
Comparator refers to the comparator operator for a data filter
const ( GreaterThanOrEqualTo Comparator = ">=" // Greater than or equal to value provided in data filter GreaterThan Comparator = ">" // Greater than value provided in data filter EqualTo Comparator = "=" // Equal to value provided in data filter NotEqualTo Comparator = "!=" // Not equal to value provided in data filter LessThan Comparator = "<" // Less than value provided in data filter LessThanOrEqualTo Comparator = "<=" // Less than or equal to value provided in data filter EmptyComparator = "" // Equal to value provided in data filter )
type CustomTrigger ¶ added in v0.13.0
type CustomTrigger struct { // ServerURL is the url of the gRPC server that executes custom trigger ServerURL string `json:"serverURL" protobuf:"bytes,1,opt,name=serverURL"` // Secure refers to type of the connection between sensor to custom trigger gRPC Secure bool `json:"secure" protobuf:"varint,2,opt,name=secure"` // CertSecret refers to the secret that contains cert for secure connection between sensor and custom trigger gRPC server. CertSecret *corev1.SecretKeySelector `json:"certSecret,omitempty" protobuf:"bytes,3,opt,name=certSecret"` // ServerNameOverride for the secure connection between sensor and custom trigger gRPC server. ServerNameOverride string `json:"serverNameOverride,omitempty" protobuf:"bytes,4,opt,name=serverNameOverride"` // Spec is the custom trigger resource specification that custom trigger gRPC server knows how to interpret. Spec map[string]string `json:"spec" protobuf:"bytes,5,rep,name=spec"` Parameters []TriggerParameter `json:"parameters,omitempty" protobuf:"bytes,6,rep,name=parameters"` Payload []TriggerParameter `json:"payload" protobuf:"bytes,7,rep,name=payload"` // DeprecatedCertFilePath is path to the cert file within sensor for secure connection between sensor and custom trigger gRPC server. // Deprecated: will be removed in v1.5, use CertSecret instead DeprecatedCertFilePath string `json:"certFilePath,omitempty" protobuf:"bytes,8,opt,name=certFilePath"` }
CustomTrigger refers to the specification of the custom trigger.
func (*CustomTrigger) DeepCopy ¶ added in v0.13.0
func (in *CustomTrigger) DeepCopy() *CustomTrigger
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CustomTrigger.
func (*CustomTrigger) DeepCopyInto ¶ added in v0.13.0
func (in *CustomTrigger) DeepCopyInto(out *CustomTrigger)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*CustomTrigger) Descriptor ¶ added in v0.17.0
func (*CustomTrigger) Descriptor() ([]byte, []int)
func (*CustomTrigger) Marshal ¶ added in v0.17.0
func (m *CustomTrigger) Marshal() (dAtA []byte, err error)
func (*CustomTrigger) MarshalTo ¶ added in v0.17.0
func (m *CustomTrigger) MarshalTo(dAtA []byte) (int, error)
func (*CustomTrigger) MarshalToSizedBuffer ¶ added in v0.17.0
func (m *CustomTrigger) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CustomTrigger) ProtoMessage ¶ added in v0.17.0
func (*CustomTrigger) ProtoMessage()
func (*CustomTrigger) Reset ¶ added in v0.17.0
func (m *CustomTrigger) Reset()
func (*CustomTrigger) Size ¶ added in v0.17.0
func (m *CustomTrigger) Size() (n int)
func (*CustomTrigger) String ¶ added in v0.17.0
func (this *CustomTrigger) String() string
func (*CustomTrigger) Unmarshal ¶ added in v0.17.0
func (m *CustomTrigger) Unmarshal(dAtA []byte) error
func (*CustomTrigger) XXX_DiscardUnknown ¶ added in v0.17.0
func (m *CustomTrigger) XXX_DiscardUnknown()
func (*CustomTrigger) XXX_Marshal ¶ added in v0.17.0
func (m *CustomTrigger) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CustomTrigger) XXX_Merge ¶ added in v0.17.0
func (m *CustomTrigger) XXX_Merge(src proto.Message)
func (*CustomTrigger) XXX_Size ¶ added in v0.17.0
func (m *CustomTrigger) XXX_Size() int
func (*CustomTrigger) XXX_Unmarshal ¶ added in v0.17.0
func (m *CustomTrigger) XXX_Unmarshal(b []byte) error
type DataFilter ¶
type DataFilter struct { // Path is the JSONPath of the event's (JSON decoded) data key // Path is a series of keys separated by a dot. A key may contain wildcard characters '*' and '?'. // To access an array value use the index as the key. The dot and wildcard characters can be escaped with '\\'. // See https://github.com/tidwall/gjson#path-syntax for more information on how to use this. Path string `json:"path" protobuf:"bytes,1,opt,name=path"` // Type contains the JSON type of the data Type JSONType `json:"type" protobuf:"bytes,2,opt,name=type,casttype=JSONType"` // Value is the allowed string values for this key // Booleans are passed using strconv.ParseBool() // Numbers are parsed using as float64 using strconv.ParseFloat() // Strings are taken as is // Nils this value is ignored Value []string `json:"value" protobuf:"bytes,3,rep,name=value"` // Comparator compares the event data with a user given value. // Can be ">=", ">", "=", "!=", "<", or "<=". // Is optional, and if left blank treated as equality "=". Comparator Comparator `json:"comparator,omitempty" protobuf:"bytes,4,opt,name=comparator,casttype=Comparator"` // Template is a go-template for extracting a string from the event's data. // A Template is evaluated with provided path, type and value. // The templating follows the standard go-template syntax as well as sprig's extra functions. // See https://pkg.go.dev/text/template and https://masterminds.github.io/sprig/ Template string `json:"template,omitempty" protobuf:"bytes,5,opt,name=template"` }
DataFilter describes constraints and filters for event data Regular Expressions are purposefully not a feature as they are overkill for our uses here See Rob Pike's Post: https://commandcenter.blogspot.com/2011/08/regular-expressions-in-lexing-and.html
func (*DataFilter) DeepCopy ¶
func (in *DataFilter) DeepCopy() *DataFilter
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DataFilter.
func (*DataFilter) DeepCopyInto ¶
func (in *DataFilter) DeepCopyInto(out *DataFilter)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*DataFilter) Descriptor ¶
func (*DataFilter) Descriptor() ([]byte, []int)
func (*DataFilter) Marshal ¶
func (m *DataFilter) Marshal() (dAtA []byte, err error)
func (*DataFilter) MarshalToSizedBuffer ¶ added in v0.17.0
func (m *DataFilter) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*DataFilter) ProtoMessage ¶
func (*DataFilter) ProtoMessage()
func (*DataFilter) Reset ¶
func (m *DataFilter) Reset()
func (*DataFilter) Size ¶
func (m *DataFilter) Size() (n int)
func (*DataFilter) String ¶
func (this *DataFilter) String() string
func (*DataFilter) Unmarshal ¶
func (m *DataFilter) Unmarshal(dAtA []byte) error
func (*DataFilter) XXX_DiscardUnknown ¶
func (m *DataFilter) XXX_DiscardUnknown()
func (*DataFilter) XXX_Marshal ¶
func (m *DataFilter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DataFilter) XXX_Merge ¶
func (m *DataFilter) XXX_Merge(src proto.Message)
func (*DataFilter) XXX_Size ¶
func (m *DataFilter) XXX_Size() int
func (*DataFilter) XXX_Unmarshal ¶
func (m *DataFilter) XXX_Unmarshal(b []byte) error
type DependencyGroup ¶
type DependencyGroup struct { // Name of the group Name string `json:"name" protobuf:"bytes,1,opt,name=name"` // Dependencies of events Dependencies []string `json:"dependencies" protobuf:"bytes,2,rep,name=dependencies"` }
DependencyGroup is the group of dependencies
func (*DependencyGroup) DeepCopy ¶
func (in *DependencyGroup) DeepCopy() *DependencyGroup
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DependencyGroup.
func (*DependencyGroup) DeepCopyInto ¶
func (in *DependencyGroup) DeepCopyInto(out *DependencyGroup)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*DependencyGroup) Descriptor ¶
func (*DependencyGroup) Descriptor() ([]byte, []int)
func (*DependencyGroup) Marshal ¶
func (m *DependencyGroup) Marshal() (dAtA []byte, err error)
func (*DependencyGroup) MarshalToSizedBuffer ¶ added in v0.17.0
func (m *DependencyGroup) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*DependencyGroup) ProtoMessage ¶
func (*DependencyGroup) ProtoMessage()
func (*DependencyGroup) Reset ¶
func (m *DependencyGroup) Reset()
func (*DependencyGroup) Size ¶
func (m *DependencyGroup) Size() (n int)
func (*DependencyGroup) String ¶
func (this *DependencyGroup) String() string
func (*DependencyGroup) Unmarshal ¶
func (m *DependencyGroup) Unmarshal(dAtA []byte) error
func (*DependencyGroup) XXX_DiscardUnknown ¶
func (m *DependencyGroup) XXX_DiscardUnknown()
func (*DependencyGroup) XXX_Marshal ¶
func (m *DependencyGroup) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DependencyGroup) XXX_Merge ¶
func (m *DependencyGroup) XXX_Merge(src proto.Message)
func (*DependencyGroup) XXX_Size ¶
func (m *DependencyGroup) XXX_Size() int
func (*DependencyGroup) XXX_Unmarshal ¶
func (m *DependencyGroup) XXX_Unmarshal(b []byte) error
type Event ¶ added in v0.14.0
type Event struct { Context *EventContext `json:"context,omitempty" protobuf:"bytes,1,opt,name=context"` Data []byte `json:"data" protobuf:"bytes,2,opt,name=data"` }
Event represents the cloudevent received from an event source. +protobuf.options.(gogoproto.goproto_stringer)=false
func (Event) DataString ¶ added in v1.2.0
returns a string representation of the data, either as the text (e.g. if it is text) or as base 64 encoded string
func (*Event) DeepCopy ¶ added in v0.14.0
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Event.
func (*Event) DeepCopyInto ¶ added in v0.14.0
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Event) Descriptor ¶ added in v0.17.0
func (*Event) MarshalToSizedBuffer ¶ added in v0.17.0
func (*Event) ProtoMessage ¶ added in v0.17.0
func (*Event) ProtoMessage()
func (*Event) XXX_DiscardUnknown ¶ added in v0.17.0
func (m *Event) XXX_DiscardUnknown()
func (*Event) XXX_Marshal ¶ added in v0.17.0
func (*Event) XXX_Unmarshal ¶ added in v0.17.0
type EventContext ¶ added in v0.14.0
type EventContext struct { // ID of the event; must be non-empty and unique within the scope of the producer. ID string `json:"id" protobuf:"bytes,1,opt,name=id"` // Source - A URI describing the event producer. Source string `json:"source" protobuf:"bytes,2,opt,name=source"` // SpecVersion - The version of the CloudEvents specification used by the event. SpecVersion string `json:"specversion" protobuf:"bytes,3,opt,name=specversion"` // Type - The type of the occurrence which has happened. Type string `json:"type" protobuf:"bytes,4,opt,name=type"` // DataContentType - A MIME (RFC2046) string describing the media type of `data`. DataContentType string `json:"datacontenttype" protobuf:"bytes,5,opt,name=datacontenttype"` // Subject - The subject of the event in the context of the event producer Subject string `json:"subject" protobuf:"bytes,6,opt,name=subject"` // Time - A Timestamp when the event happened. Time metav1.Time `json:"time" protobuf:"bytes,7,opt,name=time"` }
EventContext holds the context of the cloudevent received from an event source. +protobuf.options.(gogoproto.goproto_stringer)=false
func (*EventContext) DeepCopy ¶ added in v0.14.0
func (in *EventContext) DeepCopy() *EventContext
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EventContext.
func (*EventContext) DeepCopyInto ¶ added in v0.14.0
func (in *EventContext) DeepCopyInto(out *EventContext)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*EventContext) Descriptor ¶ added in v0.17.0
func (*EventContext) Descriptor() ([]byte, []int)
func (*EventContext) Marshal ¶ added in v0.17.0
func (m *EventContext) Marshal() (dAtA []byte, err error)
func (*EventContext) MarshalTo ¶ added in v0.17.0
func (m *EventContext) MarshalTo(dAtA []byte) (int, error)
func (*EventContext) MarshalToSizedBuffer ¶ added in v0.17.0
func (m *EventContext) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EventContext) ProtoMessage ¶ added in v0.17.0
func (*EventContext) ProtoMessage()
func (*EventContext) Reset ¶ added in v0.17.0
func (m *EventContext) Reset()
func (*EventContext) Size ¶ added in v0.17.0
func (m *EventContext) Size() (n int)
func (EventContext) String ¶ added in v0.17.0
func (e EventContext) String() string
func (*EventContext) Unmarshal ¶ added in v0.17.0
func (m *EventContext) Unmarshal(dAtA []byte) error
func (*EventContext) XXX_DiscardUnknown ¶ added in v0.17.0
func (m *EventContext) XXX_DiscardUnknown()
func (*EventContext) XXX_Marshal ¶ added in v0.17.0
func (m *EventContext) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*EventContext) XXX_Merge ¶ added in v0.17.0
func (m *EventContext) XXX_Merge(src proto.Message)
func (*EventContext) XXX_Size ¶ added in v0.17.0
func (m *EventContext) XXX_Size() int
func (*EventContext) XXX_Unmarshal ¶ added in v0.17.0
func (m *EventContext) XXX_Unmarshal(b []byte) error
type EventDependency ¶
type EventDependency struct { // Name is a unique name of this dependency Name string `json:"name" protobuf:"bytes,1,opt,name=name"` // EventSourceName is the name of EventSource that Sensor depends on EventSourceName string `json:"eventSourceName" protobuf:"bytes,2,name=eventSourceName"` // EventName is the name of the event EventName string `json:"eventName" protobuf:"bytes,3,name=eventName"` // Filters and rules governing toleration of success and constraints on the context and data of an event Filters *EventDependencyFilter `json:"filters,omitempty" protobuf:"bytes,4,opt,name=filters"` }
EventDependency describes a dependency
func (*EventDependency) DeepCopy ¶
func (in *EventDependency) DeepCopy() *EventDependency
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EventDependency.
func (*EventDependency) DeepCopyInto ¶
func (in *EventDependency) DeepCopyInto(out *EventDependency)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*EventDependency) Descriptor ¶
func (*EventDependency) Descriptor() ([]byte, []int)
func (*EventDependency) Marshal ¶
func (m *EventDependency) Marshal() (dAtA []byte, err error)
func (*EventDependency) MarshalToSizedBuffer ¶ added in v0.17.0
func (m *EventDependency) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EventDependency) ProtoMessage ¶
func (*EventDependency) ProtoMessage()
func (*EventDependency) Reset ¶
func (m *EventDependency) Reset()
func (*EventDependency) Size ¶
func (m *EventDependency) Size() (n int)
func (*EventDependency) String ¶
func (this *EventDependency) String() string
func (*EventDependency) Unmarshal ¶
func (m *EventDependency) Unmarshal(dAtA []byte) error
func (*EventDependency) XXX_DiscardUnknown ¶
func (m *EventDependency) XXX_DiscardUnknown()
func (*EventDependency) XXX_Marshal ¶
func (m *EventDependency) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*EventDependency) XXX_Merge ¶
func (m *EventDependency) XXX_Merge(src proto.Message)
func (*EventDependency) XXX_Size ¶
func (m *EventDependency) XXX_Size() int
func (*EventDependency) XXX_Unmarshal ¶
func (m *EventDependency) XXX_Unmarshal(b []byte) error
type EventDependencyFilter ¶
type EventDependencyFilter struct { // Time filter on the event with escalation Time *TimeFilter `json:"time,omitempty" protobuf:"bytes,1,opt,name=time"` // Context filter constraints Context *EventContext `json:"context,omitempty" protobuf:"bytes,2,opt,name=context"` // Data filter constraints with escalation Data []DataFilter `json:"data,omitempty" protobuf:"bytes,3,rep,name=data"` }
EventDependencyFilter defines filters and constraints for a event.
func (*EventDependencyFilter) DeepCopy ¶
func (in *EventDependencyFilter) DeepCopy() *EventDependencyFilter
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EventDependencyFilter.
func (*EventDependencyFilter) DeepCopyInto ¶
func (in *EventDependencyFilter) DeepCopyInto(out *EventDependencyFilter)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*EventDependencyFilter) Descriptor ¶
func (*EventDependencyFilter) Descriptor() ([]byte, []int)
func (*EventDependencyFilter) Marshal ¶
func (m *EventDependencyFilter) Marshal() (dAtA []byte, err error)
func (*EventDependencyFilter) MarshalTo ¶
func (m *EventDependencyFilter) MarshalTo(dAtA []byte) (int, error)
func (*EventDependencyFilter) MarshalToSizedBuffer ¶ added in v0.17.0
func (m *EventDependencyFilter) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EventDependencyFilter) ProtoMessage ¶
func (*EventDependencyFilter) ProtoMessage()
func (*EventDependencyFilter) Reset ¶
func (m *EventDependencyFilter) Reset()
func (*EventDependencyFilter) Size ¶
func (m *EventDependencyFilter) Size() (n int)
func (*EventDependencyFilter) String ¶
func (this *EventDependencyFilter) String() string
func (*EventDependencyFilter) Unmarshal ¶
func (m *EventDependencyFilter) Unmarshal(dAtA []byte) error
func (*EventDependencyFilter) XXX_DiscardUnknown ¶
func (m *EventDependencyFilter) XXX_DiscardUnknown()
func (*EventDependencyFilter) XXX_Marshal ¶
func (m *EventDependencyFilter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*EventDependencyFilter) XXX_Merge ¶
func (m *EventDependencyFilter) XXX_Merge(src proto.Message)
func (*EventDependencyFilter) XXX_Size ¶
func (m *EventDependencyFilter) XXX_Size() int
func (*EventDependencyFilter) XXX_Unmarshal ¶
func (m *EventDependencyFilter) XXX_Unmarshal(b []byte) error
type FileArtifact ¶
type FileArtifact struct {
Path string `json:"path,omitempty" protobuf:"bytes,1,opt,name=path"`
}
FileArtifact contains information about an artifact in a filesystem
func (*FileArtifact) DeepCopy ¶
func (in *FileArtifact) DeepCopy() *FileArtifact
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new FileArtifact.
func (*FileArtifact) DeepCopyInto ¶
func (in *FileArtifact) DeepCopyInto(out *FileArtifact)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*FileArtifact) Descriptor ¶
func (*FileArtifact) Descriptor() ([]byte, []int)
func (*FileArtifact) Marshal ¶
func (m *FileArtifact) Marshal() (dAtA []byte, err error)
func (*FileArtifact) MarshalToSizedBuffer ¶ added in v0.17.0
func (m *FileArtifact) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*FileArtifact) ProtoMessage ¶
func (*FileArtifact) ProtoMessage()
func (*FileArtifact) Reset ¶
func (m *FileArtifact) Reset()
func (*FileArtifact) Size ¶
func (m *FileArtifact) Size() (n int)
func (*FileArtifact) String ¶
func (this *FileArtifact) String() string
func (*FileArtifact) Unmarshal ¶
func (m *FileArtifact) Unmarshal(dAtA []byte) error
func (*FileArtifact) XXX_DiscardUnknown ¶
func (m *FileArtifact) XXX_DiscardUnknown()
func (*FileArtifact) XXX_Marshal ¶
func (m *FileArtifact) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*FileArtifact) XXX_Merge ¶
func (m *FileArtifact) XXX_Merge(src proto.Message)
func (*FileArtifact) XXX_Size ¶
func (m *FileArtifact) XXX_Size() int
func (*FileArtifact) XXX_Unmarshal ¶
func (m *FileArtifact) XXX_Unmarshal(b []byte) error
type GitArtifact ¶
type GitArtifact struct { // Git URL URL string `json:"url" protobuf:"bytes,1,opt,name=url"` // Directory to clone the repository. We clone complete directory because GitArtifact is not limited to any specific Git service providers. // Hence we don't use any specific git provider client. CloneDirectory string `json:"cloneDirectory" protobuf:"bytes,2,opt,name=cloneDirectory"` // Creds contain reference to git username and password // +optional Creds *GitCreds `json:"creds,omitempty" protobuf:"bytes,3,opt,name=creds"` // SSHKeySecret refers to the secret that contains SSH key SSHKeySecret *corev1.SecretKeySelector `json:"sshKeySecret,omitempty" protobuf:"bytes,4,opt,name=sshKeySecret"` // Path to file that contains trigger resource definition FilePath string `json:"filePath" protobuf:"bytes,5,opt,name=filePath"` // Branch to use to pull trigger resource // +optional Branch string `json:"branch,omitempty" protobuf:"bytes,6,opt,name=branch"` // Tag to use to pull trigger resource // +optional Tag string `json:"tag,omitempty" protobuf:"bytes,7,opt,name=tag"` // Ref to use to pull trigger resource. Will result in a shallow clone and // fetch. // +optional Ref string `json:"ref,omitempty" protobuf:"bytes,8,opt,name=ref"` // Remote to manage set of tracked repositories. Defaults to "origin". // Refer https://git-scm.com/docs/git-remote // +optional Remote *GitRemoteConfig `json:"remote,omitempty" protobuf:"bytes,9,opt,name=remote"` // DeprecatedSSHKeyPath is path to your ssh key path. Use this if you don't want to provide username and password. // ssh key path must be mounted in sensor pod. // Deprecated: will be removed in v1.5, use SSHKeySecret instead. // +optional DeprecatedSSHKeyPath string `json:"sshKeyPath,omitempty" protobuf:"bytes,10,opt,name=sshKeyPath"` }
GitArtifact contains information about an artifact stored in git
func (*GitArtifact) DeepCopy ¶
func (in *GitArtifact) DeepCopy() *GitArtifact
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GitArtifact.
func (*GitArtifact) DeepCopyInto ¶
func (in *GitArtifact) DeepCopyInto(out *GitArtifact)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*GitArtifact) Descriptor ¶
func (*GitArtifact) Descriptor() ([]byte, []int)
func (*GitArtifact) Marshal ¶
func (m *GitArtifact) Marshal() (dAtA []byte, err error)
func (*GitArtifact) MarshalToSizedBuffer ¶ added in v0.17.0
func (m *GitArtifact) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GitArtifact) ProtoMessage ¶
func (*GitArtifact) ProtoMessage()
func (*GitArtifact) Reset ¶
func (m *GitArtifact) Reset()
func (*GitArtifact) Size ¶
func (m *GitArtifact) Size() (n int)
func (*GitArtifact) String ¶
func (this *GitArtifact) String() string
func (*GitArtifact) Unmarshal ¶
func (m *GitArtifact) Unmarshal(dAtA []byte) error
func (*GitArtifact) XXX_DiscardUnknown ¶
func (m *GitArtifact) XXX_DiscardUnknown()
func (*GitArtifact) XXX_Marshal ¶
func (m *GitArtifact) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GitArtifact) XXX_Merge ¶
func (m *GitArtifact) XXX_Merge(src proto.Message)
func (*GitArtifact) XXX_Size ¶
func (m *GitArtifact) XXX_Size() int
func (*GitArtifact) XXX_Unmarshal ¶
func (m *GitArtifact) XXX_Unmarshal(b []byte) error
type GitCreds ¶
type GitCreds struct { Username *corev1.SecretKeySelector `json:"username,omitempty" protobuf:"bytes,1,opt,name=username"` Password *corev1.SecretKeySelector `json:"password,omitempty" protobuf:"bytes,2,opt,name=password"` }
GitCreds contain reference to git username and password
func (*GitCreds) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GitCreds.
func (*GitCreds) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*GitCreds) Descriptor ¶
func (*GitCreds) MarshalToSizedBuffer ¶ added in v0.17.0
func (*GitCreds) ProtoMessage ¶
func (*GitCreds) ProtoMessage()
func (*GitCreds) XXX_DiscardUnknown ¶
func (m *GitCreds) XXX_DiscardUnknown()
func (*GitCreds) XXX_Marshal ¶
func (*GitCreds) XXX_Unmarshal ¶
type GitRemoteConfig ¶
type GitRemoteConfig struct { // Name of the remote to fetch from. Name string `json:"name" protobuf:"bytes,1,opt,name=name"` // URLs the URLs of a remote repository. It must be non-empty. Fetch will // always use the first URL, while push will use all of them. URLS []string `json:"urls" protobuf:"bytes,2,rep,name=urls"` }
GitRemoteConfig contains the configuration of a Git remote
func (*GitRemoteConfig) DeepCopy ¶
func (in *GitRemoteConfig) DeepCopy() *GitRemoteConfig
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GitRemoteConfig.
func (*GitRemoteConfig) DeepCopyInto ¶
func (in *GitRemoteConfig) DeepCopyInto(out *GitRemoteConfig)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*GitRemoteConfig) Descriptor ¶
func (*GitRemoteConfig) Descriptor() ([]byte, []int)
func (*GitRemoteConfig) Marshal ¶
func (m *GitRemoteConfig) Marshal() (dAtA []byte, err error)
func (*GitRemoteConfig) MarshalToSizedBuffer ¶ added in v0.17.0
func (m *GitRemoteConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GitRemoteConfig) ProtoMessage ¶
func (*GitRemoteConfig) ProtoMessage()
func (*GitRemoteConfig) Reset ¶
func (m *GitRemoteConfig) Reset()
func (*GitRemoteConfig) Size ¶
func (m *GitRemoteConfig) Size() (n int)
func (*GitRemoteConfig) String ¶
func (this *GitRemoteConfig) String() string
func (*GitRemoteConfig) Unmarshal ¶
func (m *GitRemoteConfig) Unmarshal(dAtA []byte) error
func (*GitRemoteConfig) XXX_DiscardUnknown ¶
func (m *GitRemoteConfig) XXX_DiscardUnknown()
func (*GitRemoteConfig) XXX_Marshal ¶
func (m *GitRemoteConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GitRemoteConfig) XXX_Merge ¶
func (m *GitRemoteConfig) XXX_Merge(src proto.Message)
func (*GitRemoteConfig) XXX_Size ¶
func (m *GitRemoteConfig) XXX_Size() int
func (*GitRemoteConfig) XXX_Unmarshal ¶
func (m *GitRemoteConfig) XXX_Unmarshal(b []byte) error
type HTTPTrigger ¶ added in v0.13.0
type HTTPTrigger struct { // URL refers to the URL to send HTTP request to. URL string `json:"url" protobuf:"bytes,1,opt,name=url"` Payload []TriggerParameter `json:"payload" protobuf:"bytes,2,rep,name=payload"` // TLS configuration for the HTTP client. // +optional TLS *apicommon.TLSConfig `json:"tls,omitempty" protobuf:"bytes,3,opt,name=tls"` // Method refers to the type of the HTTP request. // Refer https://golang.org/src/net/http/method.go for more info. // Default value is POST. // +optional Method string `json:"method,omitempty" protobuf:"bytes,4,opt,name=method"` Parameters []TriggerParameter `json:"parameters,omitempty" protobuf:"bytes,5,rep,name=parameters"` // Timeout refers to the HTTP request timeout in seconds. // Default value is 60 seconds. // +optional Timeout int64 `json:"timeout,omitempty" protobuf:"varint,6,opt,name=timeout"` // BasicAuth configuration for the http request. // +optional BasicAuth *apicommon.BasicAuth `json:"basicAuth,omitempty" protobuf:"bytes,7,opt,name=basicAuth"` // Headers for the HTTP request. // +optional Headers map[string]string `json:"headers,omitempty" protobuf:"bytes,8,rep,name=headers"` }
HTTPTrigger is the trigger for the HTTP request
func (*HTTPTrigger) DeepCopy ¶ added in v0.13.0
func (in *HTTPTrigger) DeepCopy() *HTTPTrigger
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new HTTPTrigger.
func (*HTTPTrigger) DeepCopyInto ¶ added in v0.13.0
func (in *HTTPTrigger) DeepCopyInto(out *HTTPTrigger)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*HTTPTrigger) Descriptor ¶ added in v0.17.0
func (*HTTPTrigger) Descriptor() ([]byte, []int)
func (*HTTPTrigger) Marshal ¶ added in v0.17.0
func (m *HTTPTrigger) Marshal() (dAtA []byte, err error)
func (*HTTPTrigger) MarshalTo ¶ added in v0.17.0
func (m *HTTPTrigger) MarshalTo(dAtA []byte) (int, error)
func (*HTTPTrigger) MarshalToSizedBuffer ¶ added in v0.17.0
func (m *HTTPTrigger) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*HTTPTrigger) ProtoMessage ¶ added in v0.17.0
func (*HTTPTrigger) ProtoMessage()
func (*HTTPTrigger) Reset ¶ added in v0.17.0
func (m *HTTPTrigger) Reset()
func (*HTTPTrigger) Size ¶ added in v0.17.0
func (m *HTTPTrigger) Size() (n int)
func (*HTTPTrigger) String ¶ added in v0.17.0
func (this *HTTPTrigger) String() string
func (*HTTPTrigger) Unmarshal ¶ added in v0.17.0
func (m *HTTPTrigger) Unmarshal(dAtA []byte) error
func (*HTTPTrigger) XXX_DiscardUnknown ¶ added in v0.17.0
func (m *HTTPTrigger) XXX_DiscardUnknown()
func (*HTTPTrigger) XXX_Marshal ¶ added in v0.17.0
func (m *HTTPTrigger) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*HTTPTrigger) XXX_Merge ¶ added in v0.17.0
func (m *HTTPTrigger) XXX_Merge(src proto.Message)
func (*HTTPTrigger) XXX_Size ¶ added in v0.17.0
func (m *HTTPTrigger) XXX_Size() int
func (*HTTPTrigger) XXX_Unmarshal ¶ added in v0.17.0
func (m *HTTPTrigger) XXX_Unmarshal(b []byte) error
type K8SResourcePolicy ¶ added in v0.17.0
type K8SResourcePolicy struct { // Labels required to identify whether a resource is in success state Labels map[string]string `json:"labels,omitempty" protobuf:"bytes,1,rep,name=labels"` // Backoff before checking resource state Backoff *apicommon.Backoff `json:"backoff" protobuf:"bytes,2,opt,name=backoff"` // ErrorOnBackoffTimeout determines whether sensor should transition to error state if the trigger policy is unable to determine // the state of the resource ErrorOnBackoffTimeout bool `json:"errorOnBackoffTimeout" protobuf:"varint,3,opt,name=errorOnBackoffTimeout"` }
K8SResourcePolicy refers to the policy used to check the state of K8s based triggers using labels
func (*K8SResourcePolicy) DeepCopy ¶ added in v0.17.0
func (in *K8SResourcePolicy) DeepCopy() *K8SResourcePolicy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new K8SResourcePolicy.
func (*K8SResourcePolicy) DeepCopyInto ¶ added in v0.17.0
func (in *K8SResourcePolicy) DeepCopyInto(out *K8SResourcePolicy)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*K8SResourcePolicy) Descriptor ¶ added in v0.17.0
func (*K8SResourcePolicy) Descriptor() ([]byte, []int)
func (*K8SResourcePolicy) Marshal ¶ added in v0.17.0
func (m *K8SResourcePolicy) Marshal() (dAtA []byte, err error)
func (*K8SResourcePolicy) MarshalTo ¶ added in v0.17.0
func (m *K8SResourcePolicy) MarshalTo(dAtA []byte) (int, error)
func (*K8SResourcePolicy) MarshalToSizedBuffer ¶ added in v0.17.0
func (m *K8SResourcePolicy) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*K8SResourcePolicy) ProtoMessage ¶ added in v0.17.0
func (*K8SResourcePolicy) ProtoMessage()
func (*K8SResourcePolicy) Reset ¶ added in v0.17.0
func (m *K8SResourcePolicy) Reset()
func (*K8SResourcePolicy) Size ¶ added in v0.17.0
func (m *K8SResourcePolicy) Size() (n int)
func (*K8SResourcePolicy) String ¶ added in v0.17.0
func (this *K8SResourcePolicy) String() string
func (*K8SResourcePolicy) Unmarshal ¶ added in v0.17.0
func (m *K8SResourcePolicy) Unmarshal(dAtA []byte) error
func (*K8SResourcePolicy) XXX_DiscardUnknown ¶ added in v0.17.0
func (m *K8SResourcePolicy) XXX_DiscardUnknown()
func (*K8SResourcePolicy) XXX_Marshal ¶ added in v0.17.0
func (m *K8SResourcePolicy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*K8SResourcePolicy) XXX_Merge ¶ added in v0.17.0
func (m *K8SResourcePolicy) XXX_Merge(src proto.Message)
func (*K8SResourcePolicy) XXX_Size ¶ added in v0.17.0
func (m *K8SResourcePolicy) XXX_Size() int
func (*K8SResourcePolicy) XXX_Unmarshal ¶ added in v0.17.0
func (m *K8SResourcePolicy) XXX_Unmarshal(b []byte) error
type KafkaTrigger ¶ added in v0.13.0
type KafkaTrigger struct { // URL of the Kafka broker, multiple URLs separated by comma. URL string `json:"url" protobuf:"bytes,1,opt,name=url"` // Name of the topic. // More info at https://kafka.apache.org/documentation/#intro_topics Topic string `json:"topic" protobuf:"bytes,2,opt,name=topic"` // Partition to write data to. Partition int32 `json:"partition" protobuf:"varint,3,opt,name=partition"` Parameters []TriggerParameter `json:"parameters,omitempty" protobuf:"bytes,4,rep,name=parameters"` // RequiredAcks used in producer to tell the broker how many replica acknowledgements // Defaults to 1 (Only wait for the leader to ack). // +optional. RequiredAcks int32 `json:"requiredAcks,omitempty" protobuf:"varint,5,opt,name=requiredAcks"` // Compress determines whether to compress message or not. // Defaults to false. // If set to true, compresses message using snappy compression. // +optional Compress bool `json:"compress,omitempty" protobuf:"varint,6,opt,name=compress"` // FlushFrequency refers to the frequency in milliseconds to flush batches. // Defaults to 500 milliseconds. // +optional FlushFrequency int32 `json:"flushFrequency,omitempty" protobuf:"varint,7,opt,name=flushFrequency"` // TLS configuration for the Kafka producer. // +optional TLS *apicommon.TLSConfig `json:"tls,omitempty" protobuf:"bytes,8,opt,name=tls"` Payload []TriggerParameter `json:"payload" protobuf:"bytes,9,rep,name=payload"` // The partitioning key for the messages put on the Kafka topic. // Defaults to broker url. // +optional. PartitioningKey string `json:"partitioningKey,omitempty" protobuf:"bytes,10,opt,name=partitioningKey"` // Specify what kafka version is being connected to enables certain features in sarama, defaults to 1.0.0 // +optional Version string `json:"version,omitempty" protobuf:"bytes,11,opt,name=version"` }
KafkaTrigger refers to the specification of the Kafka trigger.
func (*KafkaTrigger) DeepCopy ¶ added in v0.13.0
func (in *KafkaTrigger) DeepCopy() *KafkaTrigger
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KafkaTrigger.
func (*KafkaTrigger) DeepCopyInto ¶ added in v0.13.0
func (in *KafkaTrigger) DeepCopyInto(out *KafkaTrigger)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*KafkaTrigger) Descriptor ¶ added in v0.17.0
func (*KafkaTrigger) Descriptor() ([]byte, []int)
func (*KafkaTrigger) Marshal ¶ added in v0.17.0
func (m *KafkaTrigger) Marshal() (dAtA []byte, err error)
func (*KafkaTrigger) MarshalTo ¶ added in v0.17.0
func (m *KafkaTrigger) MarshalTo(dAtA []byte) (int, error)
func (*KafkaTrigger) MarshalToSizedBuffer ¶ added in v0.17.0
func (m *KafkaTrigger) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*KafkaTrigger) ProtoMessage ¶ added in v0.17.0
func (*KafkaTrigger) ProtoMessage()
func (*KafkaTrigger) Reset ¶ added in v0.17.0
func (m *KafkaTrigger) Reset()
func (*KafkaTrigger) Size ¶ added in v0.17.0
func (m *KafkaTrigger) Size() (n int)
func (*KafkaTrigger) String ¶ added in v0.17.0
func (this *KafkaTrigger) String() string
func (*KafkaTrigger) Unmarshal ¶ added in v0.17.0
func (m *KafkaTrigger) Unmarshal(dAtA []byte) error
func (*KafkaTrigger) XXX_DiscardUnknown ¶ added in v0.17.0
func (m *KafkaTrigger) XXX_DiscardUnknown()
func (*KafkaTrigger) XXX_Marshal ¶ added in v0.17.0
func (m *KafkaTrigger) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*KafkaTrigger) XXX_Merge ¶ added in v0.17.0
func (m *KafkaTrigger) XXX_Merge(src proto.Message)
func (*KafkaTrigger) XXX_Size ¶ added in v0.17.0
func (m *KafkaTrigger) XXX_Size() int
func (*KafkaTrigger) XXX_Unmarshal ¶ added in v0.17.0
func (m *KafkaTrigger) XXX_Unmarshal(b []byte) error
type KubernetesResourceOperation ¶ added in v0.13.0
type KubernetesResourceOperation string
KubernetesResourceOperation refers to the type of operation performed on the K8s resource
const ( // deprecate create. Create KubernetesResourceOperation = "create" // create the resource Update KubernetesResourceOperation = "update" // updates the resource Patch KubernetesResourceOperation = "patch" // patch resource Delete KubernetesResourceOperation = "delete" // deletes the resource )
possible values for KubernetesResourceOperation
type LogTrigger ¶ added in v1.2.0
type LogTrigger struct { // Only print messages every interval. Useful to prevent logging too much data for busy events. // +optional IntervalSeconds uint64 `json:"intervalSeconds,omitempty" protobuf:"varint,1,opt,name=intervalSeconds"` }
func (*LogTrigger) DeepCopy ¶ added in v1.2.0
func (in *LogTrigger) DeepCopy() *LogTrigger
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new LogTrigger.
func (*LogTrigger) DeepCopyInto ¶ added in v1.2.0
func (in *LogTrigger) DeepCopyInto(out *LogTrigger)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*LogTrigger) Descriptor ¶ added in v1.2.0
func (*LogTrigger) Descriptor() ([]byte, []int)
func (*LogTrigger) GetInterval ¶ added in v1.2.0
func (in *LogTrigger) GetInterval() time.Duration
func (*LogTrigger) Marshal ¶ added in v1.2.0
func (m *LogTrigger) Marshal() (dAtA []byte, err error)
func (*LogTrigger) MarshalTo ¶ added in v1.2.0
func (m *LogTrigger) MarshalTo(dAtA []byte) (int, error)
func (*LogTrigger) MarshalToSizedBuffer ¶ added in v1.2.0
func (m *LogTrigger) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*LogTrigger) ProtoMessage ¶ added in v1.2.0
func (*LogTrigger) ProtoMessage()
func (*LogTrigger) Reset ¶ added in v1.2.0
func (m *LogTrigger) Reset()
func (*LogTrigger) Size ¶ added in v1.2.0
func (m *LogTrigger) Size() (n int)
func (*LogTrigger) String ¶ added in v1.2.0
func (this *LogTrigger) String() string
func (*LogTrigger) Unmarshal ¶ added in v1.2.0
func (m *LogTrigger) Unmarshal(dAtA []byte) error
func (*LogTrigger) XXX_DiscardUnknown ¶ added in v1.2.0
func (m *LogTrigger) XXX_DiscardUnknown()
func (*LogTrigger) XXX_Marshal ¶ added in v1.2.0
func (m *LogTrigger) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*LogTrigger) XXX_Merge ¶ added in v1.2.0
func (m *LogTrigger) XXX_Merge(src proto.Message)
func (*LogTrigger) XXX_Size ¶ added in v1.2.0
func (m *LogTrigger) XXX_Size() int
func (*LogTrigger) XXX_Unmarshal ¶ added in v1.2.0
func (m *LogTrigger) XXX_Unmarshal(b []byte) error
type NATSTrigger ¶ added in v0.13.0
type NATSTrigger struct { // URL of the NATS cluster. URL string `json:"url" protobuf:"bytes,1,opt,name=url"` // Name of the subject to put message on. Subject string `json:"subject" protobuf:"bytes,2,opt,name=subject"` Payload []TriggerParameter `json:"payload" protobuf:"bytes,3,rep,name=payload"` Parameters []TriggerParameter `json:"parameters,omitempty" protobuf:"bytes,4,rep,name=parameters"` // TLS configuration for the NATS producer. // +optional TLS *apicommon.TLSConfig `json:"tls,omitempty" protobuf:"bytes,5,opt,name=tls"` }
NATSTrigger refers to the specification of the NATS trigger.
func (*NATSTrigger) DeepCopy ¶ added in v0.13.0
func (in *NATSTrigger) DeepCopy() *NATSTrigger
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NATSTrigger.
func (*NATSTrigger) DeepCopyInto ¶ added in v0.13.0
func (in *NATSTrigger) DeepCopyInto(out *NATSTrigger)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*NATSTrigger) Descriptor ¶ added in v0.17.0
func (*NATSTrigger) Descriptor() ([]byte, []int)
func (*NATSTrigger) Marshal ¶ added in v0.17.0
func (m *NATSTrigger) Marshal() (dAtA []byte, err error)
func (*NATSTrigger) MarshalTo ¶ added in v0.17.0
func (m *NATSTrigger) MarshalTo(dAtA []byte) (int, error)
func (*NATSTrigger) MarshalToSizedBuffer ¶ added in v0.17.0
func (m *NATSTrigger) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*NATSTrigger) ProtoMessage ¶ added in v0.17.0
func (*NATSTrigger) ProtoMessage()
func (*NATSTrigger) Reset ¶ added in v0.17.0
func (m *NATSTrigger) Reset()
func (*NATSTrigger) Size ¶ added in v0.17.0
func (m *NATSTrigger) Size() (n int)
func (*NATSTrigger) String ¶ added in v0.17.0
func (this *NATSTrigger) String() string
func (*NATSTrigger) Unmarshal ¶ added in v0.17.0
func (m *NATSTrigger) Unmarshal(dAtA []byte) error
func (*NATSTrigger) XXX_DiscardUnknown ¶ added in v0.17.0
func (m *NATSTrigger) XXX_DiscardUnknown()
func (*NATSTrigger) XXX_Marshal ¶ added in v0.17.0
func (m *NATSTrigger) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*NATSTrigger) XXX_Merge ¶ added in v0.17.0
func (m *NATSTrigger) XXX_Merge(src proto.Message)
func (*NATSTrigger) XXX_Size ¶ added in v0.17.0
func (m *NATSTrigger) XXX_Size() int
func (*NATSTrigger) XXX_Unmarshal ¶ added in v0.17.0
func (m *NATSTrigger) XXX_Unmarshal(b []byte) error
type OpenWhiskTrigger ¶ added in v0.14.0
type OpenWhiskTrigger struct { // Host URL of the OpenWhisk. Host string `json:"host" protobuf:"bytes,1,opt,name=host"` // Version for the API. // Defaults to v1. // +optional Version string `json:"version,omitempty" protobuf:"bytes,2,opt,name=version"` // Namespace for the action. // Defaults to "_". // +optional. Namespace string `json:"namespace,omitempty" protobuf:"bytes,3,opt,name=namespace"` // AuthToken for authentication. // +optional AuthToken *corev1.SecretKeySelector `json:"authToken,omitempty" protobuf:"bytes,4,opt,name=authToken"` // Name of the action/function. ActionName string `json:"actionName" protobuf:"bytes,5,opt,name=actionName"` Payload []TriggerParameter `json:"payload" protobuf:"bytes,6,rep,name=payload"` // +optional Parameters []TriggerParameter `json:"parameters,omitempty" protobuf:"bytes,7,rep,name=parameters"` }
OpenWhiskTrigger refers to the specification of the OpenWhisk trigger.
func (*OpenWhiskTrigger) DeepCopy ¶ added in v0.14.0
func (in *OpenWhiskTrigger) DeepCopy() *OpenWhiskTrigger
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OpenWhiskTrigger.
func (*OpenWhiskTrigger) DeepCopyInto ¶ added in v0.14.0
func (in *OpenWhiskTrigger) DeepCopyInto(out *OpenWhiskTrigger)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*OpenWhiskTrigger) Descriptor ¶ added in v0.17.0
func (*OpenWhiskTrigger) Descriptor() ([]byte, []int)
func (*OpenWhiskTrigger) Marshal ¶ added in v0.17.0
func (m *OpenWhiskTrigger) Marshal() (dAtA []byte, err error)
func (*OpenWhiskTrigger) MarshalTo ¶ added in v0.17.0
func (m *OpenWhiskTrigger) MarshalTo(dAtA []byte) (int, error)
func (*OpenWhiskTrigger) MarshalToSizedBuffer ¶ added in v0.17.0
func (m *OpenWhiskTrigger) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*OpenWhiskTrigger) ProtoMessage ¶ added in v0.17.0
func (*OpenWhiskTrigger) ProtoMessage()
func (*OpenWhiskTrigger) Reset ¶ added in v0.17.0
func (m *OpenWhiskTrigger) Reset()
func (*OpenWhiskTrigger) Size ¶ added in v0.17.0
func (m *OpenWhiskTrigger) Size() (n int)
func (*OpenWhiskTrigger) String ¶ added in v0.17.0
func (this *OpenWhiskTrigger) String() string
func (*OpenWhiskTrigger) Unmarshal ¶ added in v0.17.0
func (m *OpenWhiskTrigger) Unmarshal(dAtA []byte) error
func (*OpenWhiskTrigger) XXX_DiscardUnknown ¶ added in v0.17.0
func (m *OpenWhiskTrigger) XXX_DiscardUnknown()
func (*OpenWhiskTrigger) XXX_Marshal ¶ added in v0.17.0
func (m *OpenWhiskTrigger) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*OpenWhiskTrigger) XXX_Merge ¶ added in v0.17.0
func (m *OpenWhiskTrigger) XXX_Merge(src proto.Message)
func (*OpenWhiskTrigger) XXX_Size ¶ added in v0.17.0
func (m *OpenWhiskTrigger) XXX_Size() int
func (*OpenWhiskTrigger) XXX_Unmarshal ¶ added in v0.17.0
func (m *OpenWhiskTrigger) XXX_Unmarshal(b []byte) error
type Sensor ¶
type Sensor struct { metav1.TypeMeta `json:",inline"` metav1.ObjectMeta `json:"metadata" protobuf:"bytes,1,opt,name=metadata"` Spec SensorSpec `json:"spec" protobuf:"bytes,2,opt,name=spec"` // +optional Status SensorStatus `json:"status,omitempty" protobuf:"bytes,3,opt,name=status"` }
Sensor is the definition of a sensor resource +genclient +genclient:noStatus +kubebuilder:resource:shortName=sn +kubebuilder:subresource:status +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object +k8s:openapi-gen=true
func (*Sensor) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Sensor.
func (*Sensor) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Sensor) DeepCopyObject ¶
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*Sensor) Descriptor ¶
func (*Sensor) MarshalToSizedBuffer ¶ added in v0.17.0
func (*Sensor) ProtoMessage ¶
func (*Sensor) ProtoMessage()
func (*Sensor) XXX_DiscardUnknown ¶
func (m *Sensor) XXX_DiscardUnknown()
func (*Sensor) XXX_Marshal ¶
func (*Sensor) XXX_Unmarshal ¶
type SensorList ¶
type SensorList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata" protobuf:"bytes,1,opt,name=metadata"` Items []Sensor `json:"items" protobuf:"bytes,2,rep,name=items"` }
SensorList is the list of Sensor resources +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object
func (*SensorList) DeepCopy ¶
func (in *SensorList) DeepCopy() *SensorList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SensorList.
func (*SensorList) DeepCopyInto ¶
func (in *SensorList) DeepCopyInto(out *SensorList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*SensorList) DeepCopyObject ¶
func (in *SensorList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*SensorList) Descriptor ¶
func (*SensorList) Descriptor() ([]byte, []int)
func (*SensorList) Marshal ¶
func (m *SensorList) Marshal() (dAtA []byte, err error)
func (*SensorList) MarshalToSizedBuffer ¶ added in v0.17.0
func (m *SensorList) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SensorList) ProtoMessage ¶
func (*SensorList) ProtoMessage()
func (*SensorList) Reset ¶
func (m *SensorList) Reset()
func (*SensorList) Size ¶
func (m *SensorList) Size() (n int)
func (*SensorList) String ¶
func (this *SensorList) String() string
func (*SensorList) Unmarshal ¶
func (m *SensorList) Unmarshal(dAtA []byte) error
func (*SensorList) XXX_DiscardUnknown ¶
func (m *SensorList) XXX_DiscardUnknown()
func (*SensorList) XXX_Marshal ¶
func (m *SensorList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SensorList) XXX_Merge ¶
func (m *SensorList) XXX_Merge(src proto.Message)
func (*SensorList) XXX_Size ¶
func (m *SensorList) XXX_Size() int
func (*SensorList) XXX_Unmarshal ¶
func (m *SensorList) XXX_Unmarshal(b []byte) error
type SensorSpec ¶
type SensorSpec struct { // Dependencies is a list of the events that this sensor is dependent on. Dependencies []EventDependency `json:"dependencies" protobuf:"bytes,1,rep,name=dependencies"` // Triggers is a list of the things that this sensor evokes. These are the outputs from this sensor. Triggers []Trigger `json:"triggers" protobuf:"bytes,2,rep,name=triggers"` // Template is the pod specification for the sensor // +optional Template *Template `json:"template,omitempty" protobuf:"bytes,3,opt,name=template"` // DependencyGroups is a list of the groups of events. DependencyGroups []DependencyGroup `json:"dependencyGroups,omitempty" protobuf:"bytes,4,rep,name=dependencyGroups"` // ErrorOnFailedRound if set to true, marks sensor state as `error` if the previous trigger round fails. // Once sensor state is set to `error`, no further triggers will be processed. ErrorOnFailedRound bool `json:"errorOnFailedRound,omitempty" protobuf:"varint,5,opt,name=errorOnFailedRound"` // EventBusName references to a EventBus name. By default the value is "default" EventBusName string `json:"eventBusName,omitempty" protobuf:"bytes,6,opt,name=eventBusName"` // Circuit is a boolean expression of dependency groups // Deprecated: will be removed in v1.5, use Switch in triggers instead. DeprecatedCircuit string `json:"circuit,omitempty" protobuf:"bytes,7,opt,name=circuit"` }
SensorSpec represents desired sensor state
func (*SensorSpec) DeepCopy ¶
func (in *SensorSpec) DeepCopy() *SensorSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SensorSpec.
func (*SensorSpec) DeepCopyInto ¶
func (in *SensorSpec) DeepCopyInto(out *SensorSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*SensorSpec) Descriptor ¶
func (*SensorSpec) Descriptor() ([]byte, []int)
func (*SensorSpec) Marshal ¶
func (m *SensorSpec) Marshal() (dAtA []byte, err error)
func (*SensorSpec) MarshalToSizedBuffer ¶ added in v0.17.0
func (m *SensorSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SensorSpec) ProtoMessage ¶
func (*SensorSpec) ProtoMessage()
func (*SensorSpec) Reset ¶
func (m *SensorSpec) Reset()
func (*SensorSpec) Size ¶
func (m *SensorSpec) Size() (n int)
func (*SensorSpec) String ¶
func (this *SensorSpec) String() string
func (*SensorSpec) Unmarshal ¶
func (m *SensorSpec) Unmarshal(dAtA []byte) error
func (*SensorSpec) XXX_DiscardUnknown ¶
func (m *SensorSpec) XXX_DiscardUnknown()
func (*SensorSpec) XXX_Marshal ¶
func (m *SensorSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SensorSpec) XXX_Merge ¶
func (m *SensorSpec) XXX_Merge(src proto.Message)
func (*SensorSpec) XXX_Size ¶
func (m *SensorSpec) XXX_Size() int
func (*SensorSpec) XXX_Unmarshal ¶
func (m *SensorSpec) XXX_Unmarshal(b []byte) error
type SensorStatus ¶
SensorStatus contains information about the status of a sensor.
func (*SensorStatus) DeepCopy ¶
func (in *SensorStatus) DeepCopy() *SensorStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SensorStatus.
func (*SensorStatus) DeepCopyInto ¶
func (in *SensorStatus) DeepCopyInto(out *SensorStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*SensorStatus) Descriptor ¶
func (*SensorStatus) Descriptor() ([]byte, []int)
func (*SensorStatus) InitConditions ¶ added in v0.17.0
func (s *SensorStatus) InitConditions()
InitConditions sets conditions to Unknown state.
func (*SensorStatus) MarkDependenciesNotProvided ¶ added in v0.17.0
func (s *SensorStatus) MarkDependenciesNotProvided(reason, message string)
MarkDependenciesNotProvided set the sensor has invalid dependencies provided.
func (*SensorStatus) MarkDependenciesProvided ¶ added in v0.17.0
func (s *SensorStatus) MarkDependenciesProvided()
MarkDependenciesProvided set the sensor has valid dependencies provided.
func (*SensorStatus) MarkDeployFailed ¶ added in v0.17.0
func (s *SensorStatus) MarkDeployFailed(reason, message string)
MarkDeployFailed set the sensor deploy failed
func (*SensorStatus) MarkDeployed ¶ added in v0.17.0
func (s *SensorStatus) MarkDeployed()
MarkDeployed set the sensor has been deployed.
func (*SensorStatus) MarkTriggersNotProvided ¶ added in v0.17.0
func (s *SensorStatus) MarkTriggersNotProvided(reason, message string)
MarkTriggersNotProvided set the sensor has invalid triggers provided.
func (*SensorStatus) MarkTriggersProvided ¶ added in v0.17.0
func (s *SensorStatus) MarkTriggersProvided()
MarkTriggersProvided set the sensor has valid triggers provided.
func (*SensorStatus) Marshal ¶
func (m *SensorStatus) Marshal() (dAtA []byte, err error)
func (*SensorStatus) MarshalToSizedBuffer ¶ added in v0.17.0
func (m *SensorStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SensorStatus) ProtoMessage ¶
func (*SensorStatus) ProtoMessage()
func (*SensorStatus) Reset ¶
func (m *SensorStatus) Reset()
func (*SensorStatus) Size ¶
func (m *SensorStatus) Size() (n int)
func (*SensorStatus) String ¶
func (this *SensorStatus) String() string
func (*SensorStatus) Unmarshal ¶
func (m *SensorStatus) Unmarshal(dAtA []byte) error
func (*SensorStatus) XXX_DiscardUnknown ¶
func (m *SensorStatus) XXX_DiscardUnknown()
func (*SensorStatus) XXX_Marshal ¶
func (m *SensorStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SensorStatus) XXX_Merge ¶
func (m *SensorStatus) XXX_Merge(src proto.Message)
func (*SensorStatus) XXX_Size ¶
func (m *SensorStatus) XXX_Size() int
func (*SensorStatus) XXX_Unmarshal ¶
func (m *SensorStatus) XXX_Unmarshal(b []byte) error
type SlackTrigger ¶ added in v0.14.0
type SlackTrigger struct { // +optional Parameters []TriggerParameter `json:"parameters,omitempty" protobuf:"bytes,1,rep,name=parameters"` // SlackToken refers to the Kubernetes secret that holds the slack token required to send messages. SlackToken *corev1.SecretKeySelector `json:"slackToken,omitempty" protobuf:"bytes,2,opt,name=slackToken"` // Channel refers to which Slack channel to send slack message. // +optional Channel string `json:"channel,omitempty" protobuf:"bytes,3,opt,name=channel"` // Message refers to the message to send to the Slack channel. // +optional Message string `json:"message,omitempty" protobuf:"bytes,4,opt,name=message"` }
SlackTrigger refers to the specification of the slack notification trigger.
func (*SlackTrigger) DeepCopy ¶ added in v0.14.0
func (in *SlackTrigger) DeepCopy() *SlackTrigger
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SlackTrigger.
func (*SlackTrigger) DeepCopyInto ¶ added in v0.14.0
func (in *SlackTrigger) DeepCopyInto(out *SlackTrigger)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*SlackTrigger) Descriptor ¶ added in v0.17.0
func (*SlackTrigger) Descriptor() ([]byte, []int)
func (*SlackTrigger) Marshal ¶ added in v0.17.0
func (m *SlackTrigger) Marshal() (dAtA []byte, err error)
func (*SlackTrigger) MarshalTo ¶ added in v0.17.0
func (m *SlackTrigger) MarshalTo(dAtA []byte) (int, error)
func (*SlackTrigger) MarshalToSizedBuffer ¶ added in v0.17.0
func (m *SlackTrigger) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SlackTrigger) ProtoMessage ¶ added in v0.17.0
func (*SlackTrigger) ProtoMessage()
func (*SlackTrigger) Reset ¶ added in v0.17.0
func (m *SlackTrigger) Reset()
func (*SlackTrigger) Size ¶ added in v0.17.0
func (m *SlackTrigger) Size() (n int)
func (*SlackTrigger) String ¶ added in v0.17.0
func (this *SlackTrigger) String() string
func (*SlackTrigger) Unmarshal ¶ added in v0.17.0
func (m *SlackTrigger) Unmarshal(dAtA []byte) error
func (*SlackTrigger) XXX_DiscardUnknown ¶ added in v0.17.0
func (m *SlackTrigger) XXX_DiscardUnknown()
func (*SlackTrigger) XXX_Marshal ¶ added in v0.17.0
func (m *SlackTrigger) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SlackTrigger) XXX_Merge ¶ added in v0.17.0
func (m *SlackTrigger) XXX_Merge(src proto.Message)
func (*SlackTrigger) XXX_Size ¶ added in v0.17.0
func (m *SlackTrigger) XXX_Size() int
func (*SlackTrigger) XXX_Unmarshal ¶ added in v0.17.0
func (m *SlackTrigger) XXX_Unmarshal(b []byte) error
type StandardK8STrigger ¶ added in v0.17.0
type StandardK8STrigger struct { // The unambiguous kind of this object - used in order to retrieve the appropriate kubernetes api client for this resource metav1.GroupVersionResource `json:",inline" protobuf:"bytes,1,opt,name=groupVersionResource"` // Source of the K8 resource file(s) Source *ArtifactLocation `json:"source,omitempty" protobuf:"bytes,2,opt,name=source"` // Operation refers to the type of operation performed on the k8s resource. // Default value is Create. // +optional Operation KubernetesResourceOperation `json:"operation,omitempty" protobuf:"bytes,3,opt,name=operation,casttype=KubernetesResourceOperation"` Parameters []TriggerParameter `json:"parameters,omitempty" protobuf:"bytes,4,rep,name=parameters"` // PatchStrategy controls the K8s object patching strategy when the trigger operation is specified as patch. // possible values: // "application/json-patch+json" // "application/merge-patch+json" // "application/strategic-merge-patch+json" // "application/apply-patch+yaml". // Defaults to "application/merge-patch+json" // +optional PatchStrategy k8stypes.PatchType `json:"patchStrategy,omitempty" protobuf:"bytes,5,opt,name=patchStrategy,casttype=k8s.io/apimachinery/pkg/types.PatchType"` // LiveObject specifies whether the resource should be directly fetched from K8s instead // of being marshaled from the resource artifact. If set to true, the resource artifact // must contain the information required to uniquely identify the resource in the cluster, // that is, you must specify "apiVersion", "kind" as well as "name" and "namespace" meta // data. // Only valid for operation type `update` // +optional LiveObject bool `json:"liveObject,omitempty" protobuf:"varint,6,opt,name=liveObject"` }
StandardK8STrigger is the standard Kubernetes resource trigger
func (*StandardK8STrigger) DeepCopy ¶ added in v0.17.0
func (in *StandardK8STrigger) DeepCopy() *StandardK8STrigger
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StandardK8STrigger.
func (*StandardK8STrigger) DeepCopyInto ¶ added in v0.17.0
func (in *StandardK8STrigger) DeepCopyInto(out *StandardK8STrigger)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*StandardK8STrigger) Descriptor ¶ added in v0.17.0
func (*StandardK8STrigger) Descriptor() ([]byte, []int)
func (*StandardK8STrigger) Marshal ¶ added in v0.17.0
func (m *StandardK8STrigger) Marshal() (dAtA []byte, err error)
func (*StandardK8STrigger) MarshalTo ¶ added in v0.17.0
func (m *StandardK8STrigger) MarshalTo(dAtA []byte) (int, error)
func (*StandardK8STrigger) MarshalToSizedBuffer ¶ added in v0.17.0
func (m *StandardK8STrigger) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*StandardK8STrigger) ProtoMessage ¶ added in v0.17.0
func (*StandardK8STrigger) ProtoMessage()
func (*StandardK8STrigger) Reset ¶ added in v0.17.0
func (m *StandardK8STrigger) Reset()
func (*StandardK8STrigger) Size ¶ added in v0.17.0
func (m *StandardK8STrigger) Size() (n int)
func (*StandardK8STrigger) String ¶ added in v0.17.0
func (this *StandardK8STrigger) String() string
func (*StandardK8STrigger) Unmarshal ¶ added in v0.17.0
func (m *StandardK8STrigger) Unmarshal(dAtA []byte) error
func (*StandardK8STrigger) XXX_DiscardUnknown ¶ added in v0.17.0
func (m *StandardK8STrigger) XXX_DiscardUnknown()
func (*StandardK8STrigger) XXX_Marshal ¶ added in v0.17.0
func (m *StandardK8STrigger) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StandardK8STrigger) XXX_Merge ¶ added in v0.17.0
func (m *StandardK8STrigger) XXX_Merge(src proto.Message)
func (*StandardK8STrigger) XXX_Size ¶ added in v0.17.0
func (m *StandardK8STrigger) XXX_Size() int
func (*StandardK8STrigger) XXX_Unmarshal ¶ added in v0.17.0
func (m *StandardK8STrigger) XXX_Unmarshal(b []byte) error
type StatusPolicy ¶ added in v0.13.0
type StatusPolicy struct {
Allow []int32 `json:"allow" protobuf:"varint,1,rep,name=allow"`
}
StatusPolicy refers to the policy used to check the state of the trigger using response status
func (*StatusPolicy) DeepCopy ¶ added in v0.13.0
func (in *StatusPolicy) DeepCopy() *StatusPolicy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StatusPolicy.
func (*StatusPolicy) DeepCopyInto ¶ added in v0.13.0
func (in *StatusPolicy) DeepCopyInto(out *StatusPolicy)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*StatusPolicy) Descriptor ¶ added in v0.17.0
func (*StatusPolicy) Descriptor() ([]byte, []int)
func (*StatusPolicy) GetAllow ¶ added in v0.17.0
func (in *StatusPolicy) GetAllow() []int
func (*StatusPolicy) Marshal ¶ added in v0.17.0
func (m *StatusPolicy) Marshal() (dAtA []byte, err error)
func (*StatusPolicy) MarshalTo ¶ added in v0.17.0
func (m *StatusPolicy) MarshalTo(dAtA []byte) (int, error)
func (*StatusPolicy) MarshalToSizedBuffer ¶ added in v0.17.0
func (m *StatusPolicy) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*StatusPolicy) ProtoMessage ¶ added in v0.17.0
func (*StatusPolicy) ProtoMessage()
func (*StatusPolicy) Reset ¶ added in v0.17.0
func (m *StatusPolicy) Reset()
func (*StatusPolicy) Size ¶ added in v0.17.0
func (m *StatusPolicy) Size() (n int)
func (*StatusPolicy) String ¶ added in v0.17.0
func (this *StatusPolicy) String() string
func (*StatusPolicy) Unmarshal ¶ added in v0.17.0
func (m *StatusPolicy) Unmarshal(dAtA []byte) error
func (*StatusPolicy) XXX_DiscardUnknown ¶ added in v0.17.0
func (m *StatusPolicy) XXX_DiscardUnknown()
func (*StatusPolicy) XXX_Marshal ¶ added in v0.17.0
func (m *StatusPolicy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StatusPolicy) XXX_Merge ¶ added in v0.17.0
func (m *StatusPolicy) XXX_Merge(src proto.Message)
func (*StatusPolicy) XXX_Size ¶ added in v0.17.0
func (m *StatusPolicy) XXX_Size() int
func (*StatusPolicy) XXX_Unmarshal ¶ added in v0.17.0
func (m *StatusPolicy) XXX_Unmarshal(b []byte) error
type Template ¶ added in v0.15.0
type Template struct { // Metadata sets the pods's metadata, i.e. annotations and labels Metadata *apicommon.Metadata `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"` // ServiceAccountName is the name of the ServiceAccount to use to run sensor pod. // More info: https://kubernetes.io/docs/tasks/configure-pod-container/configure-service-account/ // +optional ServiceAccountName string `json:"serviceAccountName,omitempty" protobuf:"bytes,2,opt,name=serviceAccountName"` // Container is the main container image to run in the sensor pod // +optional Container *corev1.Container `json:"container,omitempty" protobuf:"bytes,3,opt,name=container"` // Volumes is a list of volumes that can be mounted by containers in a workflow. // +patchStrategy=merge // +patchMergeKey=name // +optional Volumes []corev1.Volume `json:"volumes,omitempty" patchStrategy:"merge" patchMergeKey:"name" protobuf:"bytes,4,rep,name=volumes"` // SecurityContext holds pod-level security attributes and common container settings. // Optional: Defaults to empty. See type description for default values of each field. // +optional SecurityContext *corev1.PodSecurityContext `json:"securityContext,omitempty" protobuf:"bytes,5,opt,name=securityContext"` // NodeSelector is a selector which must be true for the pod to fit on a node. // Selector which must match a node's labels for the pod to be scheduled on that node. // More info: https://kubernetes.io/docs/concepts/configuration/assign-pod-node/ // +optional NodeSelector map[string]string `json:"nodeSelector,omitempty" protobuf:"bytes,6,rep,name=nodeSelector"` // If specified, the pod's tolerations. // +optional Tolerations []corev1.Toleration `json:"tolerations,omitempty" protobuf:"bytes,7,rep,name=tolerations"` // ImagePullSecrets is an optional list of references to secrets in the same namespace to use for pulling any of the images used by this PodSpec. // If specified, these secrets will be passed to individual puller implementations for them to use. For example, // in the case of docker, only DockerConfig type secrets are honored. // More info: https://kubernetes.io/docs/concepts/containers/images#specifying-imagepullsecrets-on-a-pod // +optional // +patchMergeKey=name // +patchStrategy=merge ImagePullSecrets []corev1.LocalObjectReference `json:"imagePullSecrets,omitempty" patchStrategy:"merge" patchMergeKey:"name" protobuf:"bytes,8,rep,name=imagePullSecrets"` // If specified, indicates the EventSource pod's priority. "system-node-critical" // and "system-cluster-critical" are two special keywords which indicate the // highest priorities with the former being the highest priority. Any other // name must be defined by creating a PriorityClass object with that name. // If not specified, the pod priority will be default or zero if there is no // default. // More info: https://kubernetes.io/docs/concepts/configuration/pod-priority-preemption/ // +optional PriorityClassName string `json:"priorityClassName,omitempty" protobuf:"bytes,9,opt,name=priorityClassName"` // The priority value. Various system components use this field to find the // priority of the EventSource pod. When Priority Admission Controller is enabled, // it prevents users from setting this field. The admission controller populates // this field from PriorityClassName. // The higher the value, the higher the priority. // More info: https://kubernetes.io/docs/concepts/configuration/pod-priority-preemption/ // +optional Priority *int32 `json:"priority,omitempty" protobuf:"bytes,10,opt,name=priority"` }
Template holds the information of a sensor deployment template
func (*Template) DeepCopy ¶ added in v0.15.0
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Template.
func (*Template) DeepCopyInto ¶ added in v0.15.0
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Template) Descriptor ¶ added in v0.17.0
func (*Template) MarshalToSizedBuffer ¶ added in v0.17.0
func (*Template) ProtoMessage ¶ added in v0.17.0
func (*Template) ProtoMessage()
func (*Template) XXX_DiscardUnknown ¶ added in v0.17.0
func (m *Template) XXX_DiscardUnknown()
func (*Template) XXX_Marshal ¶ added in v0.17.0
func (*Template) XXX_Unmarshal ¶ added in v0.17.0
type TimeFilter ¶
type TimeFilter struct { // Start is the beginning of a time window in UTC. // Before this time, events for this dependency are ignored. // Format is hh:mm:ss. Start string `json:"start" protobuf:"bytes,1,opt,name=start"` // Stop is the end of a time window in UTC. // After or equal to this time, events for this dependency are ignored and // Format is hh:mm:ss. // If it is smaller than Start, it is treated as next day of Start // (e.g.: 22:00:00-01:00:00 means 22:00:00-25:00:00). Stop string `json:"stop" protobuf:"bytes,2,opt,name=stop"` }
TimeFilter describes a window in time. It filters out events that occur outside the time limits. In other words, only events that occur after Start and before Stop will pass this filter.
func (*TimeFilter) DeepCopy ¶
func (in *TimeFilter) DeepCopy() *TimeFilter
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TimeFilter.
func (*TimeFilter) DeepCopyInto ¶
func (in *TimeFilter) DeepCopyInto(out *TimeFilter)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*TimeFilter) Descriptor ¶
func (*TimeFilter) Descriptor() ([]byte, []int)
func (*TimeFilter) Marshal ¶
func (m *TimeFilter) Marshal() (dAtA []byte, err error)
func (*TimeFilter) MarshalToSizedBuffer ¶ added in v0.17.0
func (m *TimeFilter) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*TimeFilter) ProtoMessage ¶
func (*TimeFilter) ProtoMessage()
func (*TimeFilter) Reset ¶
func (m *TimeFilter) Reset()
func (*TimeFilter) Size ¶
func (m *TimeFilter) Size() (n int)
func (*TimeFilter) String ¶
func (this *TimeFilter) String() string
func (*TimeFilter) Unmarshal ¶
func (m *TimeFilter) Unmarshal(dAtA []byte) error
func (*TimeFilter) XXX_DiscardUnknown ¶
func (m *TimeFilter) XXX_DiscardUnknown()
func (*TimeFilter) XXX_Marshal ¶
func (m *TimeFilter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TimeFilter) XXX_Merge ¶
func (m *TimeFilter) XXX_Merge(src proto.Message)
func (*TimeFilter) XXX_Size ¶
func (m *TimeFilter) XXX_Size() int
func (*TimeFilter) XXX_Unmarshal ¶
func (m *TimeFilter) XXX_Unmarshal(b []byte) error
type Trigger ¶
type Trigger struct { // Template describes the trigger specification. Template *TriggerTemplate `json:"template,omitempty" protobuf:"bytes,1,opt,name=template"` // Parameters is the list of parameters applied to the trigger template definition Parameters []TriggerParameter `json:"parameters,omitempty" protobuf:"bytes,2,rep,name=parameters"` // Policy to configure backoff and execution criteria for the trigger // +optional Policy *TriggerPolicy `json:"policy,omitempty" protobuf:"bytes,3,opt,name=policy"` // Retry strategy, defaults to no retry // +optional RetryStrategy *apicommon.Backoff `json:"retryStrategy,omitempty" protobuf:"bytes,4,opt,name=retryStrategy"` }
Trigger is an action taken, output produced, an event created, a message sent
func (*Trigger) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Trigger.
func (*Trigger) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Trigger) Descriptor ¶
func (*Trigger) MarshalToSizedBuffer ¶ added in v0.17.0
func (*Trigger) ProtoMessage ¶
func (*Trigger) ProtoMessage()
func (*Trigger) XXX_DiscardUnknown ¶
func (m *Trigger) XXX_DiscardUnknown()
func (*Trigger) XXX_Marshal ¶
func (*Trigger) XXX_Unmarshal ¶
type TriggerParameter ¶ added in v0.8.3
type TriggerParameter struct { // Src contains a source reference to the value of the parameter from a dependency Src *TriggerParameterSource `json:"src,omitempty" protobuf:"bytes,1,opt,name=src"` // Dest is the JSONPath of a resource key. // A path is a series of keys separated by a dot. The colon character can be escaped with '.' // The -1 key can be used to append a value to an existing array. // See https://github.com/tidwall/sjson#path-syntax for more information about how this is used. Dest string `json:"dest" protobuf:"bytes,2,opt,name=dest"` // Operation is what to do with the existing value at Dest, whether to // 'prepend', 'overwrite', or 'append' it. Operation TriggerParameterOperation `json:"operation,omitempty" protobuf:"bytes,3,opt,name=operation,casttype=TriggerParameterOperation"` }
TriggerParameter indicates a passed parameter to a service template
func (*TriggerParameter) DeepCopy ¶ added in v0.8.3
func (in *TriggerParameter) DeepCopy() *TriggerParameter
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TriggerParameter.
func (*TriggerParameter) DeepCopyInto ¶ added in v0.8.3
func (in *TriggerParameter) DeepCopyInto(out *TriggerParameter)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*TriggerParameter) Descriptor ¶ added in v0.17.0
func (*TriggerParameter) Descriptor() ([]byte, []int)
func (*TriggerParameter) Marshal ¶ added in v0.17.0
func (m *TriggerParameter) Marshal() (dAtA []byte, err error)
func (*TriggerParameter) MarshalTo ¶ added in v0.17.0
func (m *TriggerParameter) MarshalTo(dAtA []byte) (int, error)
func (*TriggerParameter) MarshalToSizedBuffer ¶ added in v0.17.0
func (m *TriggerParameter) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*TriggerParameter) ProtoMessage ¶ added in v0.17.0
func (*TriggerParameter) ProtoMessage()
func (*TriggerParameter) Reset ¶ added in v0.17.0
func (m *TriggerParameter) Reset()
func (*TriggerParameter) Size ¶ added in v0.17.0
func (m *TriggerParameter) Size() (n int)
func (*TriggerParameter) String ¶ added in v0.17.0
func (this *TriggerParameter) String() string
func (*TriggerParameter) Unmarshal ¶ added in v0.17.0
func (m *TriggerParameter) Unmarshal(dAtA []byte) error
func (*TriggerParameter) XXX_DiscardUnknown ¶ added in v0.17.0
func (m *TriggerParameter) XXX_DiscardUnknown()
func (*TriggerParameter) XXX_Marshal ¶ added in v0.17.0
func (m *TriggerParameter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TriggerParameter) XXX_Merge ¶ added in v0.17.0
func (m *TriggerParameter) XXX_Merge(src proto.Message)
func (*TriggerParameter) XXX_Size ¶ added in v0.17.0
func (m *TriggerParameter) XXX_Size() int
func (*TriggerParameter) XXX_Unmarshal ¶ added in v0.17.0
func (m *TriggerParameter) XXX_Unmarshal(b []byte) error
type TriggerParameterOperation ¶ added in v0.13.0
type TriggerParameterOperation string
TriggerParameterOperation represents how to set a trigger destination resource key
const ( // TriggerParameterOpNone is the zero value of TriggerParameterOperation TriggerParameterOpNone TriggerParameterOperation = "" // TriggerParameterOpAppend means append the new value to the existing TriggerParameterOpAppend TriggerParameterOperation = "append" // TriggerParameterOpOverwrite means overwrite the existing value with the new TriggerParameterOpOverwrite TriggerParameterOperation = "overwrite" // TriggerParameterOpPrepend means prepend the new value to the existing TriggerParameterOpPrepend TriggerParameterOperation = "prepend" )
type TriggerParameterSource ¶ added in v0.8.3
type TriggerParameterSource struct { // DependencyName refers to the name of the dependency. The event which is stored for this dependency is used as payload // for the parameterization. Make sure to refer to one of the dependencies you have defined under Dependencies list. DependencyName string `json:"dependencyName" protobuf:"bytes,1,opt,name=dependencyName"` // ContextKey is the JSONPath of the event's (JSON decoded) context key // ContextKey is a series of keys separated by a dot. A key may contain wildcard characters '*' and '?'. // To access an array value use the index as the key. The dot and wildcard characters can be escaped with '\\'. // See https://github.com/tidwall/gjson#path-syntax for more information on how to use this. ContextKey string `json:"contextKey,omitempty" protobuf:"bytes,2,opt,name=contextKey"` // ContextTemplate is a go-template for extracting a string from the event's context. // If a ContextTemplate is provided with a ContextKey, the template will be evaluated first and fallback to the ContextKey. // The templating follows the standard go-template syntax as well as sprig's extra functions. // See https://pkg.go.dev/text/template and https://masterminds.github.io/sprig/ ContextTemplate string `json:"contextTemplate,omitempty" protobuf:"bytes,3,opt,name=contextTemplate"` // DataKey is the JSONPath of the event's (JSON decoded) data key // DataKey is a series of keys separated by a dot. A key may contain wildcard characters '*' and '?'. // To access an array value use the index as the key. The dot and wildcard characters can be escaped with '\\'. // See https://github.com/tidwall/gjson#path-syntax for more information on how to use this. DataKey string `json:"dataKey,omitempty" protobuf:"bytes,4,opt,name=dataKey"` // DataTemplate is a go-template for extracting a string from the event's data. // If a DataTemplate is provided with a DataKey, the template will be evaluated first and fallback to the DataKey. // The templating follows the standard go-template syntax as well as sprig's extra functions. // See https://pkg.go.dev/text/template and https://masterminds.github.io/sprig/ DataTemplate string `json:"dataTemplate,omitempty" protobuf:"bytes,5,opt,name=dataTemplate"` // Value is the default literal value to use for this parameter source // This is only used if the DataKey is invalid. // If the DataKey is invalid and this is not defined, this param source will produce an error. Value *string `json:"value,omitempty" protobuf:"bytes,6,opt,name=value"` }
TriggerParameterSource defines the source for a parameter from a event event
func (*TriggerParameterSource) DeepCopy ¶ added in v0.8.3
func (in *TriggerParameterSource) DeepCopy() *TriggerParameterSource
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TriggerParameterSource.
func (*TriggerParameterSource) DeepCopyInto ¶ added in v0.8.3
func (in *TriggerParameterSource) DeepCopyInto(out *TriggerParameterSource)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*TriggerParameterSource) Descriptor ¶ added in v0.17.0
func (*TriggerParameterSource) Descriptor() ([]byte, []int)
func (*TriggerParameterSource) Marshal ¶ added in v0.17.0
func (m *TriggerParameterSource) Marshal() (dAtA []byte, err error)
func (*TriggerParameterSource) MarshalTo ¶ added in v0.17.0
func (m *TriggerParameterSource) MarshalTo(dAtA []byte) (int, error)
func (*TriggerParameterSource) MarshalToSizedBuffer ¶ added in v0.17.0
func (m *TriggerParameterSource) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*TriggerParameterSource) ProtoMessage ¶ added in v0.17.0
func (*TriggerParameterSource) ProtoMessage()
func (*TriggerParameterSource) Reset ¶ added in v0.17.0
func (m *TriggerParameterSource) Reset()
func (*TriggerParameterSource) Size ¶ added in v0.17.0
func (m *TriggerParameterSource) Size() (n int)
func (*TriggerParameterSource) String ¶ added in v0.17.0
func (this *TriggerParameterSource) String() string
func (*TriggerParameterSource) Unmarshal ¶ added in v0.17.0
func (m *TriggerParameterSource) Unmarshal(dAtA []byte) error
func (*TriggerParameterSource) XXX_DiscardUnknown ¶ added in v0.17.0
func (m *TriggerParameterSource) XXX_DiscardUnknown()
func (*TriggerParameterSource) XXX_Marshal ¶ added in v0.17.0
func (m *TriggerParameterSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TriggerParameterSource) XXX_Merge ¶ added in v0.17.0
func (m *TriggerParameterSource) XXX_Merge(src proto.Message)
func (*TriggerParameterSource) XXX_Size ¶ added in v0.17.0
func (m *TriggerParameterSource) XXX_Size() int
func (*TriggerParameterSource) XXX_Unmarshal ¶ added in v0.17.0
func (m *TriggerParameterSource) XXX_Unmarshal(b []byte) error
type TriggerPolicy ¶ added in v0.9.1
type TriggerPolicy struct { // K8SResourcePolicy refers to the policy used to check the state of K8s based triggers using using labels K8s *K8SResourcePolicy `json:"k8s,omitempty" protobuf:"bytes,1,opt,name=k8s"` // Status refers to the policy used to check the state of the trigger using response status Status *StatusPolicy `json:"status,omitempty" protobuf:"bytes,2,opt,name=status"` }
TriggerPolicy dictates the policy for the trigger retries
func (*TriggerPolicy) DeepCopy ¶ added in v0.9.1
func (in *TriggerPolicy) DeepCopy() *TriggerPolicy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TriggerPolicy.
func (*TriggerPolicy) DeepCopyInto ¶ added in v0.9.1
func (in *TriggerPolicy) DeepCopyInto(out *TriggerPolicy)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*TriggerPolicy) Descriptor ¶ added in v0.17.0
func (*TriggerPolicy) Descriptor() ([]byte, []int)
func (*TriggerPolicy) Marshal ¶ added in v0.17.0
func (m *TriggerPolicy) Marshal() (dAtA []byte, err error)
func (*TriggerPolicy) MarshalTo ¶ added in v0.17.0
func (m *TriggerPolicy) MarshalTo(dAtA []byte) (int, error)
func (*TriggerPolicy) MarshalToSizedBuffer ¶ added in v0.17.0
func (m *TriggerPolicy) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*TriggerPolicy) ProtoMessage ¶ added in v0.17.0
func (*TriggerPolicy) ProtoMessage()
func (*TriggerPolicy) Reset ¶ added in v0.17.0
func (m *TriggerPolicy) Reset()
func (*TriggerPolicy) Size ¶ added in v0.17.0
func (m *TriggerPolicy) Size() (n int)
func (*TriggerPolicy) String ¶ added in v0.17.0
func (this *TriggerPolicy) String() string
func (*TriggerPolicy) Unmarshal ¶ added in v0.17.0
func (m *TriggerPolicy) Unmarshal(dAtA []byte) error
func (*TriggerPolicy) XXX_DiscardUnknown ¶ added in v0.17.0
func (m *TriggerPolicy) XXX_DiscardUnknown()
func (*TriggerPolicy) XXX_Marshal ¶ added in v0.17.0
func (m *TriggerPolicy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TriggerPolicy) XXX_Merge ¶ added in v0.17.0
func (m *TriggerPolicy) XXX_Merge(src proto.Message)
func (*TriggerPolicy) XXX_Size ¶ added in v0.17.0
func (m *TriggerPolicy) XXX_Size() int
func (*TriggerPolicy) XXX_Unmarshal ¶ added in v0.17.0
func (m *TriggerPolicy) XXX_Unmarshal(b []byte) error
type TriggerSwitch ¶ added in v0.13.0
type TriggerSwitch struct { // Any acts as a OR operator between dependencies Any []string `json:"any,omitempty" protobuf:"bytes,1,rep,name=any"` // All acts as a AND operator between dependencies All []string `json:"all,omitempty" protobuf:"bytes,2,rep,name=all"` }
TriggerSwitch describes condition which must be satisfied in order to execute a trigger. Depending upon condition type, status of dependency groups is used to evaluate the result. Deprecated: will be removed in v1.5
func (*TriggerSwitch) DeepCopy ¶ added in v0.13.0
func (in *TriggerSwitch) DeepCopy() *TriggerSwitch
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TriggerSwitch.
func (*TriggerSwitch) DeepCopyInto ¶ added in v0.13.0
func (in *TriggerSwitch) DeepCopyInto(out *TriggerSwitch)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*TriggerSwitch) Descriptor ¶ added in v0.17.0
func (*TriggerSwitch) Descriptor() ([]byte, []int)
func (*TriggerSwitch) Marshal ¶ added in v0.17.0
func (m *TriggerSwitch) Marshal() (dAtA []byte, err error)
func (*TriggerSwitch) MarshalTo ¶ added in v0.17.0
func (m *TriggerSwitch) MarshalTo(dAtA []byte) (int, error)
func (*TriggerSwitch) MarshalToSizedBuffer ¶ added in v0.17.0
func (m *TriggerSwitch) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*TriggerSwitch) ProtoMessage ¶ added in v0.17.0
func (*TriggerSwitch) ProtoMessage()
func (*TriggerSwitch) Reset ¶ added in v0.17.0
func (m *TriggerSwitch) Reset()
func (*TriggerSwitch) Size ¶ added in v0.17.0
func (m *TriggerSwitch) Size() (n int)
func (*TriggerSwitch) String ¶ added in v0.17.0
func (this *TriggerSwitch) String() string
func (*TriggerSwitch) Unmarshal ¶ added in v0.17.0
func (m *TriggerSwitch) Unmarshal(dAtA []byte) error
func (*TriggerSwitch) XXX_DiscardUnknown ¶ added in v0.17.0
func (m *TriggerSwitch) XXX_DiscardUnknown()
func (*TriggerSwitch) XXX_Marshal ¶ added in v0.17.0
func (m *TriggerSwitch) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TriggerSwitch) XXX_Merge ¶ added in v0.17.0
func (m *TriggerSwitch) XXX_Merge(src proto.Message)
func (*TriggerSwitch) XXX_Size ¶ added in v0.17.0
func (m *TriggerSwitch) XXX_Size() int
func (*TriggerSwitch) XXX_Unmarshal ¶ added in v0.17.0
func (m *TriggerSwitch) XXX_Unmarshal(b []byte) error
type TriggerTemplate ¶ added in v0.8.3
type TriggerTemplate struct { // Name is a unique name of the action to take. Name string `json:"name" protobuf:"bytes,1,opt,name=name"` // Conditions is the conditions to execute the trigger. // For example: "(dep01 || dep02) && dep04" // +optional Conditions string `json:"conditions,omitempty" protobuf:"bytes,2,opt,name=conditions"` // StandardK8STrigger refers to the trigger designed to create or update a generic Kubernetes resource. // +optional K8s *StandardK8STrigger `json:"k8s,omitempty" protobuf:"bytes,3,opt,name=k8s"` // ArgoWorkflow refers to the trigger that can perform various operations on an Argo workflow. // +optional ArgoWorkflow *ArgoWorkflowTrigger `json:"argoWorkflow,omitempty" protobuf:"bytes,4,opt,name=argoWorkflow"` // HTTP refers to the trigger designed to dispatch a HTTP request with on-the-fly constructable payload. // +optional HTTP *HTTPTrigger `json:"http,omitempty" protobuf:"bytes,5,opt,name=http"` // AWSLambda refers to the trigger designed to invoke AWS Lambda function with with on-the-fly constructable payload. // +optional AWSLambda *AWSLambdaTrigger `json:"awsLambda,omitempty" protobuf:"bytes,6,opt,name=awsLambda"` // CustomTrigger refers to the trigger designed to connect to a gRPC trigger server and execute a custom trigger. // +optional CustomTrigger *CustomTrigger `json:"custom,omitempty" protobuf:"bytes,7,opt,name=custom"` // Kafka refers to the trigger designed to place messages on Kafka topic. // +optional. Kafka *KafkaTrigger `json:"kafka,omitempty" protobuf:"bytes,8,opt,name=kafka"` // NATS refers to the trigger designed to place message on NATS subject. // +optional. NATS *NATSTrigger `json:"nats,omitempty" protobuf:"bytes,9,opt,name=nats"` // Slack refers to the trigger designed to send slack notification message. // +optional Slack *SlackTrigger `json:"slack,omitempty" protobuf:"bytes,10,opt,name=slack"` // OpenWhisk refers to the trigger designed to invoke OpenWhisk action. // +optional OpenWhisk *OpenWhiskTrigger `json:"openWhisk,omitempty" protobuf:"bytes,11,opt,name=openWhisk"` // Log refers to the trigger designed to invoke log the event. // +optional Log *LogTrigger `json:"log,omitempty" protobuf:"bytes,13,opt,name=log"` // DeprecatedSwitch is the condition to execute the trigger. // Deprecated: will be removed in v1.5, use conditions instead // +optional DeprecatedSwitch *TriggerSwitch `json:"switch,omitempty" protobuf:"bytes,12,opt,name=switch"` }
TriggerTemplate is the template that describes trigger specification.
func (*TriggerTemplate) DeepCopy ¶ added in v0.8.3
func (in *TriggerTemplate) DeepCopy() *TriggerTemplate
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TriggerTemplate.
func (*TriggerTemplate) DeepCopyInto ¶ added in v0.8.3
func (in *TriggerTemplate) DeepCopyInto(out *TriggerTemplate)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*TriggerTemplate) Descriptor ¶ added in v0.17.0
func (*TriggerTemplate) Descriptor() ([]byte, []int)
func (*TriggerTemplate) Marshal ¶ added in v0.17.0
func (m *TriggerTemplate) Marshal() (dAtA []byte, err error)
func (*TriggerTemplate) MarshalTo ¶ added in v0.17.0
func (m *TriggerTemplate) MarshalTo(dAtA []byte) (int, error)
func (*TriggerTemplate) MarshalToSizedBuffer ¶ added in v0.17.0
func (m *TriggerTemplate) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*TriggerTemplate) ProtoMessage ¶ added in v0.17.0
func (*TriggerTemplate) ProtoMessage()
func (*TriggerTemplate) Reset ¶ added in v0.17.0
func (m *TriggerTemplate) Reset()
func (*TriggerTemplate) Size ¶ added in v0.17.0
func (m *TriggerTemplate) Size() (n int)
func (*TriggerTemplate) String ¶ added in v0.17.0
func (this *TriggerTemplate) String() string
func (*TriggerTemplate) Unmarshal ¶ added in v0.17.0
func (m *TriggerTemplate) Unmarshal(dAtA []byte) error
func (*TriggerTemplate) XXX_DiscardUnknown ¶ added in v0.17.0
func (m *TriggerTemplate) XXX_DiscardUnknown()
func (*TriggerTemplate) XXX_Marshal ¶ added in v0.17.0
func (m *TriggerTemplate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TriggerTemplate) XXX_Merge ¶ added in v0.17.0
func (m *TriggerTemplate) XXX_Merge(src proto.Message)
func (*TriggerTemplate) XXX_Size ¶ added in v0.17.0
func (m *TriggerTemplate) XXX_Size() int
func (*TriggerTemplate) XXX_Unmarshal ¶ added in v0.17.0
func (m *TriggerTemplate) XXX_Unmarshal(b []byte) error
type URLArtifact ¶
type URLArtifact struct { // Path is the complete URL Path string `json:"path" protobuf:"bytes,1,opt,name=path"` // VerifyCert decides whether the connection is secure or not VerifyCert bool `json:"verifyCert,omitempty" protobuf:"varint,2,opt,name=verifyCert"` }
URLArtifact contains information about an artifact at an http endpoint.
func (*URLArtifact) DeepCopy ¶
func (in *URLArtifact) DeepCopy() *URLArtifact
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new URLArtifact.
func (*URLArtifact) DeepCopyInto ¶
func (in *URLArtifact) DeepCopyInto(out *URLArtifact)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*URLArtifact) Descriptor ¶
func (*URLArtifact) Descriptor() ([]byte, []int)
func (*URLArtifact) Marshal ¶
func (m *URLArtifact) Marshal() (dAtA []byte, err error)
func (*URLArtifact) MarshalToSizedBuffer ¶ added in v0.17.0
func (m *URLArtifact) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*URLArtifact) ProtoMessage ¶
func (*URLArtifact) ProtoMessage()
func (*URLArtifact) Reset ¶
func (m *URLArtifact) Reset()
func (*URLArtifact) Size ¶
func (m *URLArtifact) Size() (n int)
func (*URLArtifact) String ¶
func (this *URLArtifact) String() string
func (*URLArtifact) Unmarshal ¶
func (m *URLArtifact) Unmarshal(dAtA []byte) error
func (*URLArtifact) XXX_DiscardUnknown ¶
func (m *URLArtifact) XXX_DiscardUnknown()
func (*URLArtifact) XXX_Marshal ¶
func (m *URLArtifact) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*URLArtifact) XXX_Merge ¶
func (m *URLArtifact) XXX_Merge(src proto.Message)
func (*URLArtifact) XXX_Size ¶
func (m *URLArtifact) XXX_Size() int
func (*URLArtifact) XXX_Unmarshal ¶
func (m *URLArtifact) XXX_Unmarshal(b []byte) error