v1alpha1

package

Go to main page

Versions in this module

v0

v0.15.0

May 8, 2020

Changes in this version

type CustomTrigger

+ Spec map[string]string

type HTTPTrigger

+ Headers map[string][]string

type KubernetesResourceOperation

+ const Patch

type StandardK8sTrigger

+ PatchStrategy k8stypes.PatchType

+ type Template struct

+ Container *corev1.Container

+ SecurityContext *corev1.PodSecurityContext

+ ServiceAccountName string

+ Spec *corev1.PodSpec

+ Volumes []corev1.Volume

+ func (in *Template) DeepCopy() *Template

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

v0.14.0

Apr 12, 2020

Changes in this version

+ type BasicAuth struct

+ Namespace string

+ Password *corev1.SecretKeySelector

+ Username *corev1.SecretKeySelector

+ func (in *BasicAuth) DeepCopy() *BasicAuth

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

+ type Event struct

+ Context *EventContext

+ Data []byte

+ func (in *Event) DeepCopy() *Event

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

+ type EventContext struct

+ DataContentType string

+ ID string

+ Source string

+ SpecVersion string

+ Subject string

+ Time metav1.Time

+ Type string

+ func (in *EventContext) DeepCopy() *EventContext

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

type HTTPTrigger

+ BasicAuth *BasicAuth

+ URL string

+ type OpenWhiskTrigger struct

+ ActionName string

+ AuthToken *corev1.SecretKeySelector

+ Host string

+ Namespace string

+ Parameters []TriggerParameter

+ Payload []TriggerParameter

+ Version string

+ func (in *OpenWhiskTrigger) DeepCopy() *OpenWhiskTrigger

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

+ type SlackTrigger struct

+ Channel string

+ Message string

+ Namespace string

+ Parameters []TriggerParameter

+ SlackToken *corev1.SecretKeySelector

+ func (in *SlackTrigger) DeepCopy() *SlackTrigger

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

type TriggerParameterSource

+ ContextTemplate string

+ DataTemplate string

type TriggerTemplate

+ OpenWhisk *OpenWhiskTrigger

+ Slack *SlackTrigger

v0.13.0

Mar 21, 2020

Changes in this version

+ type AWSLambdaTrigger struct

+ AccessKey *corev1.SecretKeySelector

+ FunctionName string

+ Namespace string

+ Parameters []TriggerParameter

+ Payload []TriggerParameter

+ Region string

+ SecretKey *corev1.SecretKeySelector

+ func (in *AWSLambdaTrigger) DeepCopy() *AWSLambdaTrigger

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

+ type ArgoWorkflowOperation string

+ const Resubmit

+ const Resume

+ const Retry

+ const Submit

+ const Suspend

+ type ArgoWorkflowTrigger struct

+ Operation ArgoWorkflowOperation

+ Parameters []TriggerParameter

+ Source *ArtifactLocation

+ func (in *ArgoWorkflowTrigger) DeepCopy() *ArgoWorkflowTrigger

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

+ type Comparator string

+ const EmptyComparator

+ const EqualTo

+ const GreaterThan

+ const GreaterThanOrEqualTo

+ const LessThan

+ const LessThanOrEqualTo

+ type CustomTrigger struct

+ CertFilePath string

+ Parameters []TriggerParameter

+ Payload []TriggerParameter

+ Secure bool

+ ServerNameOverride string

+ ServerURL string

+ TriggerBody string

+ func (in *CustomTrigger) DeepCopy() *CustomTrigger

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

type DataFilter

+ Comparator Comparator

type EventDependency

+ EventName string

+ GatewayName string

type GitArtifact

+ Ref string

+ type HTTPSubscription struct

+ Port int

+ func (in *HTTPSubscription) DeepCopy() *HTTPSubscription

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

+ type HTTPTrigger struct

+ Method string

+ Parameters []TriggerParameter

+ Payload []TriggerParameter

+ ServerURL string

+ TLS *TLSConfig

+ Timeout int

+ func (in *HTTPTrigger) DeepCopy() *HTTPTrigger

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

+ type K8sResourcePolicy struct

+ Backoff wait.Backoff

+ ErrorOnBackoffTimeout bool

+ Labels map[string]string

+ func (in *K8sResourcePolicy) DeepCopy() *K8sResourcePolicy

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

+ type KafkaTrigger struct

+ Compress bool

+ FlushFrequency int

+ Parameters []TriggerParameter

+ Partition int

+ PartitioningKey string

+ Payload []TriggerParameter

+ RequiredAcks int

+ TLS *TLSConfig

+ Topic string

+ URL string

+ func (in *KafkaTrigger) DeepCopy() *KafkaTrigger

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

+ type KubernetesResourceOperation string

+ const Create

+ const Update

+ type NATSSubscription struct

+ ServerURL string

+ Subject string

+ func (in *NATSSubscription) DeepCopy() *NATSSubscription

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

+ type NATSTrigger struct

+ Parameters []TriggerParameter

+ Payload []TriggerParameter

+ Subject string

+ TLS *TLSConfig

+ URL string

+ func (in *NATSTrigger) DeepCopy() *NATSTrigger

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

type NodeStatus

+ ResolvedAt metav1.MicroTime

+ UpdatedAt metav1.MicroTime

+ type OpenFaasTrigger struct

+ FunctionName string

+ GatewayURL string

+ Namespace string

+ Parameters []TriggerParameter

+ Password *corev1.SecretKeySelector

+ Payload []TriggerParameter

+ Username *corev1.SecretKeySelector

+ func (in *OpenFaasTrigger) DeepCopy() *OpenFaasTrigger

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

+ type SensorResources struct

+ Deployment *metav1.ObjectMeta

+ Service *metav1.ObjectMeta

+ func (in *SensorResources) DeepCopy() *SensorResources

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

type SensorSpec

+ ServiceAnnotations map[string]string

+ ServiceLabels map[string]string

+ Subscription *Subscription

type SensorStatus

+ Resources *SensorResources

+ type StandardK8sTrigger struct

+ Operation KubernetesResourceOperation

+ Parameters []TriggerParameter

+ Source *ArtifactLocation

+ func (in *StandardK8sTrigger) DeepCopy() *StandardK8sTrigger

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

+ type StatusPolicy struct

+ Allow []int

+ func (in *StatusPolicy) DeepCopy() *StatusPolicy

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

+ type Subscription struct

+ HTTP *HTTPSubscription

+ NATS *NATSSubscription

+ func (in *Subscription) DeepCopy() *Subscription

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

+ type TLSConfig struct

+ CACertPath string

+ ClientCertPath string

+ ClientKeyPath string

+ func (in *TLSConfig) DeepCopy() *TLSConfig

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

type Trigger

+ Parameters []TriggerParameter

type TriggerParameter

+ Operation TriggerParameterOperation

+ type TriggerParameterOperation string

+ const TriggerParameterOpAppend

+ const TriggerParameterOpNone

+ const TriggerParameterOpOverwrite

+ const TriggerParameterOpPrepend

type TriggerParameterSource

+ ContextKey string

+ DataKey string

+ DependencyName string

type TriggerPolicy

+ K8s *K8sResourcePolicy

+ Status *StatusPolicy

+ type TriggerSwitch struct

+ All []string

+ Any []string

+ func (in *TriggerSwitch) DeepCopy() *TriggerSwitch

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

type TriggerTemplate

+ AWSLambda *AWSLambdaTrigger

+ ArgoWorkflow *ArgoWorkflowTrigger

+ CustomTrigger *CustomTrigger

+ HTTP *HTTPTrigger

+ K8s *StandardK8sTrigger

+ Kafka *KafkaTrigger

+ NATS *NATSTrigger

+ OpenFaas *OpenFaasTrigger

+ Switch *TriggerSwitch

v0.13.0-rc

Feb 26, 2020

v0.9.3

Jun 28, 2019

v0.9.2

Apr 25, 2019

v0.9.1

Apr 25, 2019

Changes in this version

+ const ArgoEventsSensorVersion

type ArtifactLocation

+ Resource *unstructured.Unstructured

+ type Backoff struct

+ Duration time.Duration

+ Factor float64

+ Jitter float64

+ Steps int

+ func (in *Backoff) DeepCopy() *Backoff

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

type SensorSpec

+ ErrorOnFailedRound bool

type SensorStatus

+ LastCycleTime metav1.Time

+ TriggerCycleCount int32

+ TriggerCycleStatus TriggerCycleState

type Trigger

+ Policy *TriggerPolicy

+ type TriggerCycleState string

+ const TriggerCycleFailure

+ const TriggerCycleSuccess

+ type TriggerPolicy struct

+ Backoff Backoff

+ ErrorOnBackoffTimeout bool

+ State *TriggerStateLabels

+ func (in *TriggerPolicy) DeepCopy() *TriggerPolicy

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

+ type TriggerStateLabels struct

+ Failure map[string]string

+ Success map[string]string

+ func (in *TriggerStateLabels) DeepCopy() *TriggerStateLabels

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

v0.8.3

Mar 18, 2019

Changes in this version

type SensorSpec

+ Template *corev1.PodTemplateSpec

type Trigger

+ ResourceParameters []TriggerParameter

+ Template *TriggerTemplate

+ TemplateParameters []TriggerParameter

+ type TriggerParameter struct

+ Dest string

+ Src *TriggerParameterSource

+ func (in *TriggerParameter) DeepCopy() *TriggerParameter

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

+ type TriggerParameterSource struct

+ Event string

+ Path string

+ Value *string

+ func (in *TriggerParameterSource) DeepCopy() *TriggerParameterSource

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

+ type TriggerTemplate struct

+ Name string

+ Source *ArtifactLocation

+ When *TriggerCondition

+ func (in *TriggerTemplate) DeepCopy() *TriggerTemplate

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

v0.8.2

Mar 13, 2019

v0.8.1

Mar 10, 2019

Changes in this version

+ var AddToScheme = SchemeBuilder.AddToScheme

+ var ErrIntOverflowGenerated = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthGenerated = fmt.Errorf("proto: negative length found during unmarshaling")

+ var SchemaGroupVersionKind = schema.GroupVersionKind

+ var SchemeBuilder = runtime.NewSchemeBuilder(addKnownTypes)

+ var SchemeGroupVersion = schema.GroupVersion

+ func GetOpenAPIDefinitions(ref common.ReferenceCallback) map[string]common.OpenAPIDefinition

+ func Kind(kind string) schema.GroupKind

+ func Resource(resource string) schema.GroupResource

+ type ArtifactLocation struct

+ Configmap *ConfigmapArtifact

+ File *FileArtifact

+ Git *GitArtifact

+ Inline *string

+ S3 *apicommon.S3Artifact

+ URL *URLArtifact

+ func (*ArtifactLocation) Descriptor() ([]byte, []int)

+ func (*ArtifactLocation) ProtoMessage()

+ func (a *ArtifactLocation) HasLocation() bool

+ func (dst *ArtifactLocation) XXX_Merge(src proto.Message)

+ func (in *ArtifactLocation) DeepCopy() *ArtifactLocation

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

+ func (m *ArtifactLocation) Marshal() (dAtA []byte, err error)

+ func (m *ArtifactLocation) MarshalTo(dAtA []byte) (int, error)

+ func (m *ArtifactLocation) Reset()

+ func (m *ArtifactLocation) Size() (n int)

+ 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_Size() int

+ func (m *ArtifactLocation) XXX_Unmarshal(b []byte) error

+ func (this *ArtifactLocation) String() string

+ type ConfigmapArtifact struct

+ Key string

+ Name string

+ Namespace string

+ func (*ConfigmapArtifact) Descriptor() ([]byte, []int)

+ func (*ConfigmapArtifact) ProtoMessage()

+ func (dst *ConfigmapArtifact) XXX_Merge(src proto.Message)

+ func (in *ConfigmapArtifact) DeepCopy() *ConfigmapArtifact

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

+ func (m *ConfigmapArtifact) Marshal() (dAtA []byte, err error)

+ func (m *ConfigmapArtifact) MarshalTo(dAtA []byte) (int, error)

+ func (m *ConfigmapArtifact) Reset()

+ func (m *ConfigmapArtifact) Size() (n int)

+ func (m *ConfigmapArtifact) Unmarshal(dAtA []byte) error

+ func (m *ConfigmapArtifact) XXX_DiscardUnknown()

+ func (m *ConfigmapArtifact) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ConfigmapArtifact) XXX_Size() int

+ func (m *ConfigmapArtifact) XXX_Unmarshal(b []byte) error

+ func (this *ConfigmapArtifact) String() string

+ type DataFilter struct

+ Path string

+ Type JSONType

+ Value []string

+ func (*DataFilter) Descriptor() ([]byte, []int)

+ func (*DataFilter) ProtoMessage()

+ func (dst *DataFilter) XXX_Merge(src proto.Message)

+ func (in *DataFilter) DeepCopy() *DataFilter

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

+ func (m *DataFilter) Marshal() (dAtA []byte, err error)

+ func (m *DataFilter) MarshalTo(dAtA []byte) (int, error)

+ func (m *DataFilter) Reset()

+ func (m *DataFilter) Size() (n int)

+ 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_Size() int

+ func (m *DataFilter) XXX_Unmarshal(b []byte) error

+ func (this *DataFilter) String() string

+ type DependencyGroup struct

+ Dependencies []string

+ Name string

+ func (*DependencyGroup) Descriptor() ([]byte, []int)

+ func (*DependencyGroup) ProtoMessage()

+ func (dst *DependencyGroup) XXX_Merge(src proto.Message)

+ func (in *DependencyGroup) DeepCopy() *DependencyGroup

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

+ func (m *DependencyGroup) Marshal() (dAtA []byte, err error)

+ func (m *DependencyGroup) MarshalTo(dAtA []byte) (int, error)

+ func (m *DependencyGroup) Reset()

+ func (m *DependencyGroup) Size() (n int)

+ 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_Size() int

+ func (m *DependencyGroup) XXX_Unmarshal(b []byte) error

+ func (this *DependencyGroup) String() string

+ type EventDependency struct

+ Connected bool

+ Deadline int64

+ Filters EventDependencyFilter

+ Name string

+ func (*EventDependency) Descriptor() ([]byte, []int)

+ func (*EventDependency) ProtoMessage()

+ func (dst *EventDependency) XXX_Merge(src proto.Message)

+ func (in *EventDependency) DeepCopy() *EventDependency

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

+ func (m *EventDependency) Marshal() (dAtA []byte, err error)

+ func (m *EventDependency) MarshalTo(dAtA []byte) (int, error)

+ func (m *EventDependency) Reset()

+ func (m *EventDependency) Size() (n int)

+ 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_Size() int

+ func (m *EventDependency) XXX_Unmarshal(b []byte) error

+ func (this *EventDependency) String() string

+ type EventDependencyFilter struct

+ Context *common.EventContext

+ Data []DataFilter

+ Name string

+ Time *TimeFilter

+ func (*EventDependencyFilter) Descriptor() ([]byte, []int)

+ func (*EventDependencyFilter) ProtoMessage()

+ func (dst *EventDependencyFilter) XXX_Merge(src proto.Message)

+ func (in *EventDependencyFilter) DeepCopy() *EventDependencyFilter

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

+ func (m *EventDependencyFilter) Marshal() (dAtA []byte, err error)

+ func (m *EventDependencyFilter) MarshalTo(dAtA []byte) (int, error)

+ func (m *EventDependencyFilter) Reset()

+ func (m *EventDependencyFilter) Size() (n int)

+ 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_Size() int

+ func (m *EventDependencyFilter) XXX_Unmarshal(b []byte) error

+ func (this *EventDependencyFilter) String() string

+ type FileArtifact struct

+ Path string

+ func (*FileArtifact) Descriptor() ([]byte, []int)

+ func (*FileArtifact) ProtoMessage()

+ func (dst *FileArtifact) XXX_Merge(src proto.Message)

+ func (in *FileArtifact) DeepCopy() *FileArtifact

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

+ func (m *FileArtifact) Marshal() (dAtA []byte, err error)

+ func (m *FileArtifact) MarshalTo(dAtA []byte) (int, error)

+ func (m *FileArtifact) Reset()

+ func (m *FileArtifact) Size() (n int)

+ 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_Size() int

+ func (m *FileArtifact) XXX_Unmarshal(b []byte) error

+ func (this *FileArtifact) String() string

+ type GitArtifact struct

+ Branch string

+ CloneDirectory string

+ Creds *GitCreds

+ FilePath string

+ Namespace string

+ Remote *GitRemoteConfig

+ SSHKeyPath string

+ Tag string

+ URL string

+ func (*GitArtifact) Descriptor() ([]byte, []int)

+ func (*GitArtifact) ProtoMessage()

+ func (dst *GitArtifact) XXX_Merge(src proto.Message)

+ func (in *GitArtifact) DeepCopy() *GitArtifact

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

+ func (m *GitArtifact) Marshal() (dAtA []byte, err error)

+ func (m *GitArtifact) MarshalTo(dAtA []byte) (int, error)

+ func (m *GitArtifact) Reset()

+ func (m *GitArtifact) Size() (n int)

+ 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_Size() int

+ func (m *GitArtifact) XXX_Unmarshal(b []byte) error

+ func (this *GitArtifact) String() string

+ type GitCreds struct

+ Password *corev1.SecretKeySelector

+ Username *corev1.SecretKeySelector

+ func (*GitCreds) Descriptor() ([]byte, []int)

+ func (*GitCreds) ProtoMessage()

+ func (dst *GitCreds) XXX_Merge(src proto.Message)

+ func (in *GitCreds) DeepCopy() *GitCreds

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

+ func (m *GitCreds) Marshal() (dAtA []byte, err error)

+ func (m *GitCreds) MarshalTo(dAtA []byte) (int, error)

+ func (m *GitCreds) Reset()

+ func (m *GitCreds) Size() (n int)

+ 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_Size() int

+ func (m *GitCreds) XXX_Unmarshal(b []byte) error

+ func (this *GitCreds) String() string

+ type GitRemoteConfig struct

+ Name string

+ URLS []string

+ func (*GitRemoteConfig) Descriptor() ([]byte, []int)

+ func (*GitRemoteConfig) ProtoMessage()

+ func (dst *GitRemoteConfig) XXX_Merge(src proto.Message)

+ func (in *GitRemoteConfig) DeepCopy() *GitRemoteConfig

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

+ func (m *GitRemoteConfig) Marshal() (dAtA []byte, err error)

+ func (m *GitRemoteConfig) MarshalTo(dAtA []byte) (int, error)

+ func (m *GitRemoteConfig) Reset()

+ func (m *GitRemoteConfig) Size() (n int)

+ 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_Size() int

+ func (m *GitRemoteConfig) XXX_Unmarshal(b []byte) error

+ func (this *GitRemoteConfig) String() string

+ type GroupVersionKind struct

+ Group string

+ Kind string

+ Version string

+ func (*GroupVersionKind) Descriptor() ([]byte, []int)

+ func (*GroupVersionKind) ProtoMessage()

+ func (dst *GroupVersionKind) XXX_Merge(src proto.Message)

+ func (in *GroupVersionKind) DeepCopy() *GroupVersionKind

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

+ func (m *GroupVersionKind) Marshal() (dAtA []byte, err error)

+ func (m *GroupVersionKind) MarshalTo(dAtA []byte) (int, error)

+ func (m *GroupVersionKind) Reset()

+ func (m *GroupVersionKind) Size() (n int)

+ func (m *GroupVersionKind) Unmarshal(dAtA []byte) error

+ func (m *GroupVersionKind) XXX_DiscardUnknown()

+ func (m *GroupVersionKind) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GroupVersionKind) XXX_Size() int

+ func (m *GroupVersionKind) XXX_Unmarshal(b []byte) error

+ func (this *GroupVersionKind) String() string

+ type JSONType string

+ const JSONTypeBool

+ const JSONTypeNumber

+ const JSONTypeString

+ type NodePhase string

+ const NodePhaseActive

+ const NodePhaseComplete

+ const NodePhaseError

+ const NodePhaseNew

+ type NodeStatus struct

+ CompletedAt v1.MicroTime

+ DisplayName string

+ Event *apicommon.Event

+ ID string

+ Message string

+ Name string

+ Phase NodePhase

+ StartedAt v1.MicroTime

+ Type NodeType

+ func (*NodeStatus) Descriptor() ([]byte, []int)

+ func (*NodeStatus) ProtoMessage()

+ func (dst *NodeStatus) XXX_Merge(src proto.Message)

+ func (in *NodeStatus) DeepCopy() *NodeStatus

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

+ func (m *NodeStatus) Marshal() (dAtA []byte, err error)

+ func (m *NodeStatus) MarshalTo(dAtA []byte) (int, error)

+ func (m *NodeStatus) Reset()

+ func (m *NodeStatus) Size() (n int)

+ func (m *NodeStatus) Unmarshal(dAtA []byte) error

+ func (m *NodeStatus) XXX_DiscardUnknown()

+ func (m *NodeStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *NodeStatus) XXX_Size() int

+ func (m *NodeStatus) XXX_Unmarshal(b []byte) error

+ func (node NodeStatus) IsComplete() bool

+ func (this *NodeStatus) String() string

+ type NodeType string

+ const NodeTypeDependencyGroup

+ const NodeTypeEventDependency

+ const NodeTypeTrigger

+ type NotificationType string

+ const EventNotification

+ const ResourceUpdateNotification

+ type ResourceObject struct

+ Labels map[string]string

+ Namespace string

+ Parameters []ResourceParameter

+ Source ArtifactLocation

+ func (*ResourceObject) Descriptor() ([]byte, []int)

+ func (*ResourceObject) ProtoMessage()

+ func (dst *ResourceObject) XXX_Merge(src proto.Message)

+ func (in *ResourceObject) DeepCopy() *ResourceObject

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

+ func (m *ResourceObject) Marshal() (dAtA []byte, err error)

+ func (m *ResourceObject) MarshalTo(dAtA []byte) (int, error)

+ func (m *ResourceObject) Reset()

+ func (m *ResourceObject) Size() (n int)

+ func (m *ResourceObject) Unmarshal(dAtA []byte) error

+ func (m *ResourceObject) XXX_DiscardUnknown()

+ func (m *ResourceObject) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ResourceObject) XXX_Size() int

+ func (m *ResourceObject) XXX_Unmarshal(b []byte) error

+ func (this *ResourceObject) String() string

+ type ResourceParameter struct

+ Dest string

+ Src *ResourceParameterSource

+ func (*ResourceParameter) Descriptor() ([]byte, []int)

+ func (*ResourceParameter) ProtoMessage()

+ func (dst *ResourceParameter) XXX_Merge(src proto.Message)

+ func (in *ResourceParameter) DeepCopy() *ResourceParameter

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

+ func (m *ResourceParameter) Marshal() (dAtA []byte, err error)

+ func (m *ResourceParameter) MarshalTo(dAtA []byte) (int, error)

+ func (m *ResourceParameter) Reset()

+ func (m *ResourceParameter) Size() (n int)

+ func (m *ResourceParameter) Unmarshal(dAtA []byte) error

+ func (m *ResourceParameter) XXX_DiscardUnknown()

+ func (m *ResourceParameter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ResourceParameter) XXX_Size() int

+ func (m *ResourceParameter) XXX_Unmarshal(b []byte) error

+ func (this *ResourceParameter) String() string

+ type ResourceParameterSource struct

+ Event string

+ Path string

+ Value *string

+ func (*ResourceParameterSource) Descriptor() ([]byte, []int)

+ func (*ResourceParameterSource) ProtoMessage()

+ func (dst *ResourceParameterSource) XXX_Merge(src proto.Message)

+ func (in *ResourceParameterSource) DeepCopy() *ResourceParameterSource

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

+ func (m *ResourceParameterSource) Marshal() (dAtA []byte, err error)

+ func (m *ResourceParameterSource) MarshalTo(dAtA []byte) (int, error)

+ func (m *ResourceParameterSource) Reset()

+ func (m *ResourceParameterSource) Size() (n int)

+ func (m *ResourceParameterSource) Unmarshal(dAtA []byte) error

+ func (m *ResourceParameterSource) XXX_DiscardUnknown()

+ func (m *ResourceParameterSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ResourceParameterSource) XXX_Size() int

+ func (m *ResourceParameterSource) XXX_Unmarshal(b []byte) error

+ func (this *ResourceParameterSource) String() string

+ type RetryStrategy struct

+ func (*RetryStrategy) Descriptor() ([]byte, []int)

+ func (*RetryStrategy) ProtoMessage()

+ func (dst *RetryStrategy) XXX_Merge(src proto.Message)

+ func (in *RetryStrategy) DeepCopy() *RetryStrategy

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

+ func (m *RetryStrategy) Marshal() (dAtA []byte, err error)

+ func (m *RetryStrategy) MarshalTo(dAtA []byte) (int, error)

+ func (m *RetryStrategy) Reset()

+ func (m *RetryStrategy) Size() (n int)

+ func (m *RetryStrategy) Unmarshal(dAtA []byte) error

+ func (m *RetryStrategy) XXX_DiscardUnknown()

+ func (m *RetryStrategy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RetryStrategy) XXX_Size() int

+ func (m *RetryStrategy) XXX_Unmarshal(b []byte) error

+ func (this *RetryStrategy) String() string

+ type Sensor struct

+ Spec SensorSpec

+ Status SensorStatus

+ func (*Sensor) Descriptor() ([]byte, []int)

+ func (*Sensor) ProtoMessage()

+ func (dst *Sensor) XXX_Merge(src proto.Message)

+ func (in *Sensor) DeepCopy() *Sensor

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

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

+ func (m *Sensor) Marshal() (dAtA []byte, err error)

+ func (m *Sensor) MarshalTo(dAtA []byte) (int, error)

+ func (m *Sensor) Reset()

+ func (m *Sensor) Size() (n int)

+ 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_Size() int

+ func (m *Sensor) XXX_Unmarshal(b []byte) error

+ func (s *Sensor) AreAllNodesSuccess(nodeType NodeType) bool

+ func (s *Sensor) IsComplete() bool

+ func (s *Sensor) NodeID(name string) string

+ func (this *Sensor) String() string

+ type SensorList struct

+ Items []Sensor

+ func (*SensorList) Descriptor() ([]byte, []int)

+ func (*SensorList) ProtoMessage()

+ func (dst *SensorList) XXX_Merge(src proto.Message)

+ func (in *SensorList) DeepCopy() *SensorList

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

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

+ func (m *SensorList) Marshal() (dAtA []byte, err error)

+ func (m *SensorList) MarshalTo(dAtA []byte) (int, error)

+ func (m *SensorList) Reset()

+ func (m *SensorList) Size() (n int)

+ 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_Size() int

+ func (m *SensorList) XXX_Unmarshal(b []byte) error

+ func (this *SensorList) String() string

+ type SensorSpec struct

+ Circuit string

+ Dependencies []EventDependency

+ DependencyGroups []DependencyGroup

+ DeploySpec *corev1.PodSpec

+ EventProtocol *apicommon.EventProtocol

+ Triggers []Trigger

+ func (*SensorSpec) Descriptor() ([]byte, []int)

+ func (*SensorSpec) ProtoMessage()

+ func (dst *SensorSpec) XXX_Merge(src proto.Message)

+ func (in *SensorSpec) DeepCopy() *SensorSpec

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

+ func (m *SensorSpec) Marshal() (dAtA []byte, err error)

+ func (m *SensorSpec) MarshalTo(dAtA []byte) (int, error)

+ func (m *SensorSpec) Reset()

+ func (m *SensorSpec) Size() (n int)

+ 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_Size() int

+ func (m *SensorSpec) XXX_Unmarshal(b []byte) error

+ func (this *SensorSpec) String() string

+ type SensorStatus struct

+ CompletedAt v1.Time

+ CompletionCount int32

+ Message string

+ Nodes map[string]NodeStatus

+ Phase NodePhase

+ StartedAt v1.Time

+ func (*SensorStatus) Descriptor() ([]byte, []int)

+ func (*SensorStatus) ProtoMessage()

+ func (dst *SensorStatus) XXX_Merge(src proto.Message)

+ func (in *SensorStatus) DeepCopy() *SensorStatus

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

+ func (m *SensorStatus) Marshal() (dAtA []byte, err error)

+ func (m *SensorStatus) MarshalTo(dAtA []byte) (int, error)

+ func (m *SensorStatus) Reset()

+ func (m *SensorStatus) Size() (n int)

+ 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_Size() int

+ func (m *SensorStatus) XXX_Unmarshal(b []byte) error

+ func (this *SensorStatus) String() string

+ type TimeFilter struct

+ Start string

+ Stop string

+ func (*TimeFilter) Descriptor() ([]byte, []int)

+ func (*TimeFilter) ProtoMessage()

+ func (dst *TimeFilter) XXX_Merge(src proto.Message)

+ func (in *TimeFilter) DeepCopy() *TimeFilter

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

+ func (m *TimeFilter) Marshal() (dAtA []byte, err error)

+ func (m *TimeFilter) MarshalTo(dAtA []byte) (int, error)

+ func (m *TimeFilter) Reset()

+ func (m *TimeFilter) Size() (n int)

+ 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_Size() int

+ func (m *TimeFilter) XXX_Unmarshal(b []byte) error

+ func (this *TimeFilter) String() string

+ type Trigger struct

+ Message string

+ Name string

+ Resource *ResourceObject

+ RetryStrategy *RetryStrategy

+ When *TriggerCondition

+ func (*Trigger) Descriptor() ([]byte, []int)

+ func (*Trigger) ProtoMessage()

+ func (dst *Trigger) XXX_Merge(src proto.Message)

+ func (in *Trigger) DeepCopy() *Trigger

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

+ func (m *Trigger) Marshal() (dAtA []byte, err error)

+ func (m *Trigger) MarshalTo(dAtA []byte) (int, error)

+ func (m *Trigger) Reset()

+ func (m *Trigger) Size() (n int)

+ 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_Size() int

+ func (m *Trigger) XXX_Unmarshal(b []byte) error

+ func (this *Trigger) String() string

+ type TriggerCondition struct

+ All []string

+ Any []string

+ func (*TriggerCondition) Descriptor() ([]byte, []int)

+ func (*TriggerCondition) ProtoMessage()

+ func (dst *TriggerCondition) XXX_Merge(src proto.Message)

+ func (in *TriggerCondition) DeepCopy() *TriggerCondition

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

+ func (m *TriggerCondition) Marshal() (dAtA []byte, err error)

+ func (m *TriggerCondition) MarshalTo(dAtA []byte) (int, error)

+ func (m *TriggerCondition) Reset()

+ func (m *TriggerCondition) Size() (n int)

+ func (m *TriggerCondition) Unmarshal(dAtA []byte) error

+ func (m *TriggerCondition) XXX_DiscardUnknown()

+ func (m *TriggerCondition) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TriggerCondition) XXX_Size() int

+ func (m *TriggerCondition) XXX_Unmarshal(b []byte) error

+ func (this *TriggerCondition) String() string

+ type URLArtifact struct

+ Path string

+ VerifyCert bool

+ func (*URLArtifact) Descriptor() ([]byte, []int)

+ func (*URLArtifact) ProtoMessage()

+ func (dst *URLArtifact) XXX_Merge(src proto.Message)

+ func (in *URLArtifact) DeepCopy() *URLArtifact

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

+ func (m *URLArtifact) Marshal() (dAtA []byte, err error)

+ func (m *URLArtifact) MarshalTo(dAtA []byte) (int, error)

+ func (m *URLArtifact) Reset()

+ func (m *URLArtifact) Size() (n int)

+ 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_Size() int

+ func (m *URLArtifact) XXX_Unmarshal(b []byte) error

+ func (this *URLArtifact) String() string

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