v1alpha1

package
v1.15.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 6, 2022 License: Apache-2.0 Imports: 20 Imported by: 0

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

View Source 
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

View Source 
var (
	ErrInvalidLengthGenerated        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowGenerated          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupGenerated = fmt.Errorf("proto: unexpected end of group")
)
View Source 
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 = SchemeGroupVersion.WithKind(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 Kind 

func Kind(kind string) schema.GroupKind

Kind takes an unqualified kind and returns back a Group qualified GroupKind

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 K8s secret containing aws access key
	// +optional
	AccessKey *corev1.SecretKeySelector `json:"accessKey,omitempty" protobuf:"bytes,2,opt,name=accessKey"`
	// SecretKey refers K8s secret containing aws secret key
	// +optional
	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 is the list of key-value extracted from an event payload to construct the request payload.
	Payload []TriggerParameter `json:"payload" protobuf:"bytes,5,rep,name=payload"`
	// Parameters is the list of key-value extracted from event's payload that are applied to
	// the trigger resource.
	// +optional
	Parameters []TriggerParameter `json:"parameters,omitempty" protobuf:"bytes,6,rep,name=parameters"`
	// Choose from the following options.
	//
	//    * RequestResponse (default) - Invoke the function synchronously. Keep
	//    the connection open until the function returns a response or times out.
	//    The API response includes the function response and additional data.
	//
	//    * Event - Invoke the function asynchronously. Send events that fail multiple
	//    times to the function's dead-letter queue (if it's configured). The API
	//    response only includes a status code.
	//
	//    * DryRun - Validate parameter values and verify that the user or role
	//    has permission to invoke the function.
	// +optional
	InvocationType *string `json:"invocationType,omitempty" protobuf:"bytes,7,opt,name=invocationType"`
	// RoleARN is the Amazon Resource Name (ARN) of the role to assume.
	// +optional
	RoleARN string `json:"roleARN,omitempty" protobuf:"bytes,8,opt,name=roleARN"`
}

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
	Terminate ArgoWorkflowOperation = "terminate" // terminate a workflow
)

possible values for ArgoWorkflowOperation

type ArgoWorkflowTrigger added in v0.13.0 

type ArgoWorkflowTrigger struct {
	// Source of the K8s 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 is the list of parameters to pass to resolved Argo Workflow object
	Parameters []TriggerParameter `json:"parameters,omitempty" protobuf:"bytes,3,rep,name=parameters"`
}

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) MarshalTo 

func (m *ArtifactLocation) MarshalTo(dAtA []byte) (int, 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 AzureEventHubsTrigger added in v1.3.0 

type AzureEventHubsTrigger struct {
	// FQDN refers to the namespace dns of Azure Event Hubs to be used i.e. <namespace>.servicebus.windows.net
	FQDN string `json:"fqdn" protobuf:"bytes,1,opt,name=fqdn"`
	// HubName refers to the Azure Event Hub to send events to
	HubName string `json:"hubName" protobuf:"bytes,2,opt,name=hubName"`
	// SharedAccessKeyName refers to the name of the Shared Access Key
	SharedAccessKeyName *corev1.SecretKeySelector `json:"sharedAccessKeyName" protobuf:"bytes,3,opt,name=sharedAccessKeyName"`
	// SharedAccessKey refers to a K8s secret containing the primary key for the
	SharedAccessKey *corev1.SecretKeySelector `json:"sharedAccessKey,omitempty" protobuf:"bytes,4,opt,name=sharedAccessKey"`
	// Payload is the list of key-value extracted from an event payload to construct the request payload.
	Payload []TriggerParameter `json:"payload" protobuf:"bytes,5,rep,name=payload"`
	// Parameters is the list of key-value extracted from event's payload that are applied to
	// the trigger resource.
	// +optional
	Parameters []TriggerParameter `json:"parameters,omitempty" protobuf:"bytes,6,rep,name=parameters"`
}

AzureEventHubsTrigger refers to specification of the Azure Event Hubs Trigger

func (*AzureEventHubsTrigger) DeepCopy added in v1.3.0 

func (in *AzureEventHubsTrigger) DeepCopy() *AzureEventHubsTrigger

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AzureEventHubsTrigger.

func (*AzureEventHubsTrigger) DeepCopyInto added in v1.3.0 

func (in *AzureEventHubsTrigger) DeepCopyInto(out *AzureEventHubsTrigger)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*AzureEventHubsTrigger) Descriptor added in v1.3.0 

func (*AzureEventHubsTrigger) Descriptor() ([]byte, []int)

func (*AzureEventHubsTrigger) Marshal added in v1.3.0 

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

func (*AzureEventHubsTrigger) MarshalTo added in v1.3.0 

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

func (*AzureEventHubsTrigger) MarshalToSizedBuffer added in v1.3.0 

func (m *AzureEventHubsTrigger) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AzureEventHubsTrigger) ProtoMessage added in v1.3.0 

func (*AzureEventHubsTrigger) ProtoMessage()

func (*AzureEventHubsTrigger) Reset added in v1.3.0 

func (m *AzureEventHubsTrigger) Reset()

func (*AzureEventHubsTrigger) Size added in v1.3.0 

func (m *AzureEventHubsTrigger) Size() (n int)

func (*AzureEventHubsTrigger) String added in v1.3.0 

func (this *AzureEventHubsTrigger) String() string

func (*AzureEventHubsTrigger) Unmarshal added in v1.3.0 

func (m *AzureEventHubsTrigger) Unmarshal(dAtA []byte) error

func (*AzureEventHubsTrigger) XXX_DiscardUnknown added in v1.3.0 

func (m *AzureEventHubsTrigger) XXX_DiscardUnknown()

func (*AzureEventHubsTrigger) XXX_Marshal added in v1.3.0 

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

func (*AzureEventHubsTrigger) XXX_Merge added in v1.3.0 

func (m *AzureEventHubsTrigger) XXX_Merge(src proto.Message)

func (*AzureEventHubsTrigger) XXX_Size added in v1.3.0 

func (m *AzureEventHubsTrigger) XXX_Size() int

func (*AzureEventHubsTrigger) XXX_Unmarshal added in v1.3.0 

func (m *AzureEventHubsTrigger) 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 ConditionsResetByTime added in v1.5.1 

type ConditionsResetByTime struct {
	// Cron is a cron-like expression. For reference, see: https://en.wikipedia.org/wiki/Cron
	Cron string `json:"cron,omitempty" protobuf:"bytes,1,opt,name=cron"`
	// +optional
	Timezone string `json:"timezone,omitempty" protobuf:"bytes,2,opt,name=timezone"`
}

func (*ConditionsResetByTime) DeepCopy added in v1.5.1 

func (in *ConditionsResetByTime) DeepCopy() *ConditionsResetByTime

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ConditionsResetByTime.

func (*ConditionsResetByTime) DeepCopyInto added in v1.5.1 

func (in *ConditionsResetByTime) DeepCopyInto(out *ConditionsResetByTime)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*ConditionsResetByTime) Descriptor added in v1.5.1 

func (*ConditionsResetByTime) Descriptor() ([]byte, []int)

func (*ConditionsResetByTime) Marshal added in v1.5.1 

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

func (*ConditionsResetByTime) MarshalTo added in v1.5.1 

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

func (*ConditionsResetByTime) MarshalToSizedBuffer added in v1.5.1 

func (m *ConditionsResetByTime) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ConditionsResetByTime) ProtoMessage added in v1.5.1 

func (*ConditionsResetByTime) ProtoMessage()

func (*ConditionsResetByTime) Reset added in v1.5.1 

func (m *ConditionsResetByTime) Reset()

func (*ConditionsResetByTime) Size added in v1.5.1 

func (m *ConditionsResetByTime) Size() (n int)

func (*ConditionsResetByTime) String added in v1.5.1 

func (this *ConditionsResetByTime) String() string

func (*ConditionsResetByTime) Unmarshal added in v1.5.1 

func (m *ConditionsResetByTime) Unmarshal(dAtA []byte) error

func (*ConditionsResetByTime) XXX_DiscardUnknown added in v1.5.1 

func (m *ConditionsResetByTime) XXX_DiscardUnknown()

func (*ConditionsResetByTime) XXX_Marshal added in v1.5.1 

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

func (*ConditionsResetByTime) XXX_Merge added in v1.5.1 

func (m *ConditionsResetByTime) XXX_Merge(src proto.Message)

func (*ConditionsResetByTime) XXX_Size added in v1.5.1 

func (m *ConditionsResetByTime) XXX_Size() int

func (*ConditionsResetByTime) XXX_Unmarshal added in v1.5.1 

func (m *ConditionsResetByTime) XXX_Unmarshal(b []byte) error

type ConditionsResetCriteria added in v1.5.1 

type ConditionsResetCriteria struct {
	// Schedule is a cron-like expression. For reference, see: https://en.wikipedia.org/wiki/Cron
	ByTime *ConditionsResetByTime `json:"byTime,omitempty" protobuf:"bytes,1,opt,name=byTime"`
}

func (*ConditionsResetCriteria) DeepCopy added in v1.5.1 

func (in *ConditionsResetCriteria) DeepCopy() *ConditionsResetCriteria

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ConditionsResetCriteria.

func (*ConditionsResetCriteria) DeepCopyInto added in v1.5.1 

func (in *ConditionsResetCriteria) DeepCopyInto(out *ConditionsResetCriteria)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*ConditionsResetCriteria) Descriptor added in v1.5.1 

func (*ConditionsResetCriteria) Descriptor() ([]byte, []int)

func (*ConditionsResetCriteria) Marshal added in v1.5.1 

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

func (*ConditionsResetCriteria) MarshalTo added in v1.5.1 

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

func (*ConditionsResetCriteria) MarshalToSizedBuffer added in v1.5.1 

func (m *ConditionsResetCriteria) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ConditionsResetCriteria) ProtoMessage added in v1.5.1 

func (*ConditionsResetCriteria) ProtoMessage()

func (*ConditionsResetCriteria) Reset added in v1.5.1 

func (m *ConditionsResetCriteria) Reset()

func (*ConditionsResetCriteria) Size added in v1.5.1 

func (m *ConditionsResetCriteria) Size() (n int)

func (*ConditionsResetCriteria) String added in v1.5.1 

func (this *ConditionsResetCriteria) String() string

func (*ConditionsResetCriteria) Unmarshal added in v1.5.1 

func (m *ConditionsResetCriteria) Unmarshal(dAtA []byte) error

func (*ConditionsResetCriteria) XXX_DiscardUnknown added in v1.5.1 

func (m *ConditionsResetCriteria) XXX_DiscardUnknown()

func (*ConditionsResetCriteria) XXX_Marshal added in v1.5.1 

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

func (*ConditionsResetCriteria) XXX_Merge added in v1.5.1 

func (m *ConditionsResetCriteria) XXX_Merge(src proto.Message)

func (*ConditionsResetCriteria) XXX_Size added in v1.5.1 

func (m *ConditionsResetCriteria) XXX_Size() int

func (*ConditionsResetCriteria) XXX_Unmarshal added in v1.5.1 

func (m *ConditionsResetCriteria) XXX_Unmarshal(b []byte) error

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 is the list of parameters that is applied to resolved custom trigger trigger object.
	Parameters []TriggerParameter `json:"parameters,omitempty" protobuf:"bytes,6,rep,name=parameters"`
	// Payload is the list of key-value extracted from an event payload to construct the request payload.
	Payload []TriggerParameter `json:"payload" protobuf:"bytes,7,rep,name=payload"`
}

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) MarshalTo 

func (m *DataFilter) MarshalTo(dAtA []byte) (int, 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 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 

func (e Event) DataString() string

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 

func (in *Event) DeepCopy() *Event

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Event.

func (*Event) DeepCopyInto added in v0.14.0 

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

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) Descriptor() ([]byte, []int)

func (*Event) Marshal added in v0.17.0 

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

func (*Event) MarshalTo added in v0.17.0 

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

func (*Event) MarshalToSizedBuffer added in v0.17.0 

func (m *Event) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Event) ProtoMessage added in v0.17.0 

func (*Event) ProtoMessage()

func (*Event) Reset added in v0.17.0 

func (m *Event) Reset()

func (*Event) Size added in v0.17.0 

func (m *Event) Size() (n int)

func (Event) String added in v0.17.0 

func (e Event) String() string

func (*Event) Unmarshal added in v0.17.0 

func (m *Event) Unmarshal(dAtA []byte) error

func (*Event) XXX_DiscardUnknown added in v0.17.0 

func (m *Event) XXX_DiscardUnknown()

func (*Event) XXX_Marshal added in v0.17.0 

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

func (*Event) XXX_Merge added in v0.17.0 

func (m *Event) XXX_Merge(src proto.Message)

func (*Event) XXX_Size added in v0.17.0 

func (m *Event) XXX_Size() int

func (*Event) XXX_Unmarshal added in v0.17.0 

func (m *Event) XXX_Unmarshal(b []byte) error

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"`
	// Transform transforms the event data
	Transform *EventDependencyTransformer `json:"transform,omitempty" protobuf:"bytes,5,opt,name=transform"`
	// FiltersLogicalOperator defines how different filters are evaluated together.
	// Available values: and (&&), or (||)
	// Is optional and if left blank treated as and (&&).
	FiltersLogicalOperator LogicalOperator `json:"filtersLogicalOperator,omitempty" protobuf:"bytes,6,opt,name=filtersLogicalOperator,casttype=LogicalOperator"`
}

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) MarshalTo 

func (m *EventDependency) MarshalTo(dAtA []byte) (int, 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"`
	// Exprs contains the list of expressions evaluated against the event payload.
	Exprs []ExprFilter `json:"exprs,omitempty" protobuf:"bytes,4,rep,name=exprs"`
	// DataLogicalOperator defines how multiple Data filters (if defined) are evaluated together.
	// Available values: and (&&), or (||)
	// Is optional and if left blank treated as and (&&).
	DataLogicalOperator LogicalOperator `json:"dataLogicalOperator,omitempty" protobuf:"bytes,5,opt,name=dataLogicalOperator,casttype=DataLogicalOperator"`
	// ExprLogicalOperator defines how multiple Exprs filters (if defined) are evaluated together.
	// Available values: and (&&), or (||)
	// Is optional and if left blank treated as and (&&).
	ExprLogicalOperator LogicalOperator `json:"exprLogicalOperator,omitempty" protobuf:"bytes,6,opt,name=exprLogicalOperator,casttype=ExprLogicalOperator"`
}

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 EventDependencyTransformer added in v1.6.0 

type EventDependencyTransformer struct {
	// JQ holds the jq command applied for transformation
	// +optional
	JQ string `json:"jq,omitempty" protobuf:"bytes,1,opt,name=jq"`
	// Script refers to a Lua script used to transform the event
	// +optional
	Script string `json:"script,omitempty" protobuf:"bytes,2,opt,name=script"`
}

EventDependencyTransformer transforms the event

func (*EventDependencyTransformer) DeepCopy added in v1.6.0 

func (in *EventDependencyTransformer) DeepCopy() *EventDependencyTransformer

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EventDependencyTransformer.

func (*EventDependencyTransformer) DeepCopyInto added in v1.6.0 

func (in *EventDependencyTransformer) DeepCopyInto(out *EventDependencyTransformer)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*EventDependencyTransformer) Descriptor added in v1.6.0 

func (*EventDependencyTransformer) Descriptor() ([]byte, []int)

func (*EventDependencyTransformer) Marshal added in v1.6.0 

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

func (*EventDependencyTransformer) MarshalTo added in v1.6.0 

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

func (*EventDependencyTransformer) MarshalToSizedBuffer added in v1.6.0 

func (m *EventDependencyTransformer) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EventDependencyTransformer) ProtoMessage added in v1.6.0 

func (*EventDependencyTransformer) ProtoMessage()

func (*EventDependencyTransformer) Reset added in v1.6.0 

func (m *EventDependencyTransformer) Reset()

func (*EventDependencyTransformer) Size added in v1.6.0 

func (m *EventDependencyTransformer) Size() (n int)

func (*EventDependencyTransformer) String added in v1.6.0 

func (this *EventDependencyTransformer) String() string

func (*EventDependencyTransformer) Unmarshal added in v1.6.0 

func (m *EventDependencyTransformer) Unmarshal(dAtA []byte) error

func (*EventDependencyTransformer) XXX_DiscardUnknown added in v1.6.0 

func (m *EventDependencyTransformer) XXX_DiscardUnknown()

func (*EventDependencyTransformer) XXX_Marshal added in v1.6.0 

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

func (*EventDependencyTransformer) XXX_Merge added in v1.6.0 

func (m *EventDependencyTransformer) XXX_Merge(src proto.Message)

func (*EventDependencyTransformer) XXX_Size added in v1.6.0 

func (m *EventDependencyTransformer) XXX_Size() int

func (*EventDependencyTransformer) XXX_Unmarshal added in v1.6.0 

func (m *EventDependencyTransformer) XXX_Unmarshal(b []byte) error

type ExprFilter added in v1.4.0 

type ExprFilter struct {
	// Expr refers to the expression that determines the outcome of the filter.
	Expr string `json:"expr" protobuf:"bytes,1,opt,name=expr"`
	// Fields refers to set of keys that refer to the paths within event payload.
	Fields []PayloadField `json:"fields" protobuf:"bytes,2,rep,name=fields"`
}

func (*ExprFilter) DeepCopy added in v1.4.0 

func (in *ExprFilter) DeepCopy() *ExprFilter

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ExprFilter.

func (*ExprFilter) DeepCopyInto added in v1.4.0 

func (in *ExprFilter) DeepCopyInto(out *ExprFilter)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*ExprFilter) Descriptor added in v1.4.0 

func (*ExprFilter) Descriptor() ([]byte, []int)

func (*ExprFilter) Marshal added in v1.4.0 

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

func (*ExprFilter) MarshalTo added in v1.4.0 

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

func (*ExprFilter) MarshalToSizedBuffer added in v1.4.0 

func (m *ExprFilter) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ExprFilter) ProtoMessage added in v1.4.0 

func (*ExprFilter) ProtoMessage()

func (*ExprFilter) Reset added in v1.4.0 

func (m *ExprFilter) Reset()

func (*ExprFilter) Size added in v1.4.0 

func (m *ExprFilter) Size() (n int)

func (*ExprFilter) String added in v1.4.0 

func (this *ExprFilter) String() string

func (*ExprFilter) Unmarshal added in v1.4.0 

func (m *ExprFilter) Unmarshal(dAtA []byte) error

func (*ExprFilter) XXX_DiscardUnknown added in v1.4.0 

func (m *ExprFilter) XXX_DiscardUnknown()

func (*ExprFilter) XXX_Marshal added in v1.4.0 

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

func (*ExprFilter) XXX_Merge added in v1.4.0 

func (m *ExprFilter) XXX_Merge(src proto.Message)

func (*ExprFilter) XXX_Size added in v1.4.0 

func (m *ExprFilter) XXX_Size() int

func (*ExprFilter) XXX_Unmarshal added in v1.4.0 

func (m *ExprFilter) 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) MarshalTo 

func (m *FileArtifact) MarshalTo(dAtA []byte) (int, 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"`
}

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) MarshalTo 

func (m *GitArtifact) MarshalTo(dAtA []byte) (int, 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 

func (in *GitCreds) DeepCopy() *GitCreds

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GitCreds.

func (*GitCreds) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*GitCreds) Descriptor 

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

func (*GitCreds) Marshal 

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

func (*GitCreds) MarshalTo 

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

func (*GitCreds) MarshalToSizedBuffer added in v0.17.0 

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

func (*GitCreds) ProtoMessage 

func (*GitCreds) ProtoMessage()

func (*GitCreds) Reset 

func (m *GitCreds) Reset()

func (*GitCreds) Size 

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

func (*GitCreds) String 

func (this *GitCreds) String() string

func (*GitCreds) Unmarshal 

func (m *GitCreds) Unmarshal(dAtA []byte) error

func (*GitCreds) XXX_DiscardUnknown 

func (m *GitCreds) XXX_DiscardUnknown()

func (*GitCreds) XXX_Marshal 

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

func (*GitCreds) XXX_Merge 

func (m *GitCreds) XXX_Merge(src proto.Message)

func (*GitCreds) XXX_Size 

func (m *GitCreds) XXX_Size() int

func (*GitCreds) XXX_Unmarshal 

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

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) MarshalTo 

func (m *GitRemoteConfig) MarshalTo(dAtA []byte) (int, 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 is the list of key-value extracted from event's payload that are applied to
	// the HTTP trigger resource.
	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"`
	// Secure Headers stored in Kubernetes Secrets for the HTTP requests.
	// +optional
	SecureHeaders []*apicommon.SecureHeader `json:"secureHeaders,omitempty" protobuf:"bytes,9,rep,name=secureHeaders"`
}

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 JSONType 

type JSONType string

JSONType contains the supported JSON types for data filtering 

const (
	JSONTypeBool   JSONType = "bool"
	JSONTypeNumber JSONType = "number"
	JSONTypeString JSONType = "string"
)

the various supported JSONTypes

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 is the list of parameters that is applied to resolved Kafka trigger object.
	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 is the list of key-value extracted from an event payload to construct the request payload.
	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"`
	// SASL configuration for the kafka client
	// +optional
	SASL *apicommon.SASLConfig `json:"sasl,omitempty" protobuf:"bytes,12,opt,name=sasl"`
}

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 (
	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 LogicalOperator added in v1.6.0 

type LogicalOperator string
const (
	AndLogicalOperator   LogicalOperator = "and" // Equal to &&
	OrLogicalOperator    LogicalOperator = "or"  // Equal to ||
	EmptyLogicalOperator LogicalOperator = ""    // Empty will default to AND (&&)
)

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 is the list of key-value extracted from an event payload to construct the request payload.
	Payload []TriggerParameter `json:"payload" protobuf:"bytes,6,rep,name=payload"`
	// Parameters is the list of key-value extracted from event's payload that are applied to
	// the trigger resource.
	// +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 PayloadField added in v1.4.0 

type PayloadField 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"`
	// Name acts as key that holds the value at the path.
	Name string `json:"name" protobuf:"bytes,2,opt,name=name"`
}

PayloadField binds a value at path within the event payload against a name.

func (*PayloadField) DeepCopy added in v1.4.0 

func (in *PayloadField) DeepCopy() *PayloadField

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PayloadField.

func (*PayloadField) DeepCopyInto added in v1.4.0 

func (in *PayloadField) DeepCopyInto(out *PayloadField)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*PayloadField) Descriptor added in v1.4.0 

func (*PayloadField) Descriptor() ([]byte, []int)

func (*PayloadField) Marshal added in v1.4.0 

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

func (*PayloadField) MarshalTo added in v1.4.0 

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

func (*PayloadField) MarshalToSizedBuffer added in v1.4.0 

func (m *PayloadField) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PayloadField) ProtoMessage added in v1.4.0 

func (*PayloadField) ProtoMessage()

func (*PayloadField) Reset added in v1.4.0 

func (m *PayloadField) Reset()

func (*PayloadField) Size added in v1.4.0 

func (m *PayloadField) Size() (n int)

func (*PayloadField) String added in v1.4.0 

func (this *PayloadField) String() string

func (*PayloadField) Unmarshal added in v1.4.0 

func (m *PayloadField) Unmarshal(dAtA []byte) error

func (*PayloadField) XXX_DiscardUnknown added in v1.4.0 

func (m *PayloadField) XXX_DiscardUnknown()

func (*PayloadField) XXX_Marshal added in v1.4.0 

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

func (*PayloadField) XXX_Merge added in v1.4.0 

func (m *PayloadField) XXX_Merge(src proto.Message)

func (*PayloadField) XXX_Size added in v1.4.0 

func (m *PayloadField) XXX_Size() int

func (*PayloadField) XXX_Unmarshal added in v1.4.0 

func (m *PayloadField) XXX_Unmarshal(b []byte) error

type PulsarTrigger added in v1.5.0 

type PulsarTrigger struct {
	// Configure the service URL for the Pulsar service.
	// +required
	URL string `json:"url" protobuf:"bytes,1,name=url"`
	// Name of the topic.
	// See https://pulsar.apache.org/docs/en/concepts-messaging/
	Topic string `json:"topic" protobuf:"bytes,2,name=topic"`
	// Parameters is the list of parameters that is applied to resolved Kafka trigger object.
	Parameters []TriggerParameter `json:"parameters,omitempty" protobuf:"bytes,3,rep,name=parameters"`
	// Payload is the list of key-value extracted from an event payload to construct the request payload.
	Payload []TriggerParameter `json:"payload" protobuf:"bytes,4,rep,name=payload"`
	// Trusted TLS certificate secret.
	// +optional
	TLSTrustCertsSecret *corev1.SecretKeySelector `json:"tlsTrustCertsSecret,omitempty" protobuf:"bytes,5,opt,name=tlsTrustCertsSecret"`
	// Whether the Pulsar client accept untrusted TLS certificate from broker.
	// +optional
	TLSAllowInsecureConnection bool `json:"tlsAllowInsecureConnection,omitempty" protobuf:"bytes,6,opt,name=tlsAllowInsecureConnection"`
	// Whether the Pulsar client verify the validity of the host name from broker.
	// +optional
	TLSValidateHostname bool `json:"tlsValidateHostname,omitempty" protobuf:"bytes,7,opt,name=tlsValidateHostname"`
	// TLS configuration for the pulsar client.
	// +optional
	TLS *apicommon.TLSConfig `json:"tls,omitempty" protobuf:"bytes,8,opt,name=tls"`
	// Authentication token for the pulsar client.
	// +optional
	AuthTokenSecret *corev1.SecretKeySelector `json:"authTokenSecret,omitempty" protobuf:"bytes,9,opt,name=authTokenSecret"`
	// Backoff holds parameters applied to connection.
	// +optional
	ConnectionBackoff *apicommon.Backoff `json:"connectionBackoff,omitempty" protobuf:"bytes,10,opt,name=connectionBackoff"`
}

PulsarTrigger refers to the specification of the Pulsar trigger.

func (*PulsarTrigger) DeepCopy added in v1.5.0 

func (in *PulsarTrigger) DeepCopy() *PulsarTrigger

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PulsarTrigger.

func (*PulsarTrigger) DeepCopyInto added in v1.5.0 

func (in *PulsarTrigger) DeepCopyInto(out *PulsarTrigger)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*PulsarTrigger) Descriptor added in v1.5.0 

func (*PulsarTrigger) Descriptor() ([]byte, []int)

func (*PulsarTrigger) Marshal added in v1.5.0 

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

func (*PulsarTrigger) MarshalTo added in v1.5.0 

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

func (*PulsarTrigger) MarshalToSizedBuffer added in v1.5.0 

func (m *PulsarTrigger) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PulsarTrigger) ProtoMessage added in v1.5.0 

func (*PulsarTrigger) ProtoMessage()

func (*PulsarTrigger) Reset added in v1.5.0 

func (m *PulsarTrigger) Reset()

func (*PulsarTrigger) Size added in v1.5.0 

func (m *PulsarTrigger) Size() (n int)

func (*PulsarTrigger) String added in v1.5.0 

func (this *PulsarTrigger) String() string

func (*PulsarTrigger) Unmarshal added in v1.5.0 

func (m *PulsarTrigger) Unmarshal(dAtA []byte) error

func (*PulsarTrigger) XXX_DiscardUnknown added in v1.5.0 

func (m *PulsarTrigger) XXX_DiscardUnknown()

func (*PulsarTrigger) XXX_Marshal added in v1.5.0 

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

func (*PulsarTrigger) XXX_Merge added in v1.5.0 

func (m *PulsarTrigger) XXX_Merge(src proto.Message)

func (*PulsarTrigger) XXX_Size added in v1.5.0 

func (m *PulsarTrigger) XXX_Size() int

func (*PulsarTrigger) XXX_Unmarshal added in v1.5.0 

func (m *PulsarTrigger) XXX_Unmarshal(b []byte) error

type RateLimit added in v1.5.0 

type RateLimit struct {
	// Defaults to Second
	Unit            RateLimiteUnit `json:"unit,omitempty" protobuf:"bytes,1,opt,name=unit"`
	RequestsPerUnit int32          `json:"requestsPerUnit,omitempty" protobuf:"bytes,2,opt,name=requestsPerUnit"`
}

func (*RateLimit) DeepCopy added in v1.5.0 

func (in *RateLimit) DeepCopy() *RateLimit

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RateLimit.

func (*RateLimit) DeepCopyInto added in v1.5.0 

func (in *RateLimit) DeepCopyInto(out *RateLimit)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*RateLimit) Descriptor added in v1.5.0 

func (*RateLimit) Descriptor() ([]byte, []int)

func (*RateLimit) Marshal added in v1.5.0 

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

func (*RateLimit) MarshalTo added in v1.5.0 

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

func (*RateLimit) MarshalToSizedBuffer added in v1.5.0 

func (m *RateLimit) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RateLimit) ProtoMessage added in v1.5.0 

func (*RateLimit) ProtoMessage()

func (*RateLimit) Reset added in v1.5.0 

func (m *RateLimit) Reset()

func (*RateLimit) Size added in v1.5.0 

func (m *RateLimit) Size() (n int)

func (*RateLimit) String added in v1.5.0 

func (this *RateLimit) String() string

func (*RateLimit) Unmarshal added in v1.5.0 

func (m *RateLimit) Unmarshal(dAtA []byte) error

func (*RateLimit) XXX_DiscardUnknown added in v1.5.0 

func (m *RateLimit) XXX_DiscardUnknown()

func (*RateLimit) XXX_Marshal added in v1.5.0 

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

func (*RateLimit) XXX_Merge added in v1.5.0 

func (m *RateLimit) XXX_Merge(src proto.Message)

func (*RateLimit) XXX_Size added in v1.5.0 

func (m *RateLimit) XXX_Size() int

func (*RateLimit) XXX_Unmarshal added in v1.5.0 

func (m *RateLimit) XXX_Unmarshal(b []byte) error

type RateLimiteUnit added in v1.5.0 

type RateLimiteUnit string
const (
	Second RateLimiteUnit = "Second"
	Minute RateLimiteUnit = "Minute"
	Hour   RateLimiteUnit = "Hour"
)

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 

func (in *Sensor) DeepCopy() *Sensor

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Sensor.

func (*Sensor) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*Sensor) DeepCopyObject 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*Sensor) Descriptor 

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

func (*Sensor) Marshal 

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

func (*Sensor) MarshalTo 

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

func (*Sensor) MarshalToSizedBuffer added in v0.17.0 

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

func (*Sensor) ProtoMessage 

func (*Sensor) ProtoMessage()

func (*Sensor) Reset 

func (m *Sensor) Reset()

func (*Sensor) Size 

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

func (*Sensor) String 

func (this *Sensor) String() string

func (*Sensor) Unmarshal 

func (m *Sensor) Unmarshal(dAtA []byte) error

func (*Sensor) XXX_DiscardUnknown 

func (m *Sensor) XXX_DiscardUnknown()

func (*Sensor) XXX_Marshal 

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

func (*Sensor) XXX_Merge 

func (m *Sensor) XXX_Merge(src proto.Message)

func (*Sensor) XXX_Size 

func (m *Sensor) XXX_Size() int

func (*Sensor) XXX_Unmarshal 

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

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) MarshalTo 

func (m *SensorList) MarshalTo(dAtA []byte) (int, 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"`
	// 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,4,opt,name=errorOnFailedRound"`
	// EventBusName references to a EventBus name. By default the value is "default"
	EventBusName string `json:"eventBusName,omitempty" protobuf:"bytes,5,opt,name=eventBusName"`
	// Replicas is the sensor deployment replicas
	Replicas *int32 `json:"replicas,omitempty" protobuf:"varint,6,opt,name=replicas"`
}

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) GetReplicas added in v1.3.0 

func (s SensorSpec) GetReplicas() int32

func (*SensorSpec) Marshal 

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

func (*SensorSpec) MarshalTo 

func (m *SensorSpec) MarshalTo(dAtA []byte) (int, 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 

type SensorStatus struct {
	apicommon.Status `json:",inline" protobuf:"bytes,1,opt,name=status"`
}

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) MarshalTo 

func (m *SensorStatus) MarshalTo(dAtA []byte) (int, 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 {
	// Parameters is the list of key-value extracted from event's payload that are applied to
	// the trigger resource.
	// +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 {
	// Source of the K8s resource file(s)
	Source *ArtifactLocation `json:"source,omitempty" protobuf:"bytes,1,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,2,opt,name=operation,casttype=KubernetesResourceOperation"`
	// Parameters is the list of parameters that is applied to resolved K8s trigger object.
	Parameters []TriggerParameter `json:"parameters,omitempty" protobuf:"bytes,3,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,4,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,5,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"`
	// If specified, the pod's scheduling constraints
	// +optional
	Affinity *corev1.Affinity `json:"affinity,omitempty" protobuf:"bytes,11,opt,name=affinity"`
}

Template holds the information of a sensor deployment template

func (*Template) DeepCopy added in v0.15.0 

func (in *Template) DeepCopy() *Template

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Template.

func (*Template) DeepCopyInto added in v0.15.0 

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

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) Descriptor() ([]byte, []int)

func (*Template) Marshal added in v0.17.0 

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

func (*Template) MarshalTo added in v0.17.0 

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

func (*Template) MarshalToSizedBuffer added in v0.17.0 

func (m *Template) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Template) ProtoMessage added in v0.17.0 

func (*Template) ProtoMessage()

func (*Template) Reset added in v0.17.0 

func (m *Template) Reset()

func (*Template) Size added in v0.17.0 

func (m *Template) Size() (n int)

func (*Template) String added in v0.17.0 

func (this *Template) String() string

func (*Template) Unmarshal added in v0.17.0 

func (m *Template) Unmarshal(dAtA []byte) error

func (*Template) XXX_DiscardUnknown added in v0.17.0 

func (m *Template) XXX_DiscardUnknown()

func (*Template) XXX_Marshal added in v0.17.0 

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

func (*Template) XXX_Merge added in v0.17.0 

func (m *Template) XXX_Merge(src proto.Message)

func (*Template) XXX_Size added in v0.17.0 

func (m *Template) XXX_Size() int

func (*Template) XXX_Unmarshal added in v0.17.0 

func (m *Template) XXX_Unmarshal(b []byte) error

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) MarshalTo 

func (m *TimeFilter) MarshalTo(dAtA []byte) (int, 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"`
	// Rate limit, default unit is Second
	// +optional
	RateLimit *RateLimit `json:"rateLimit,omitempty" protobuf:"bytes,5,opt,name=rateLimit"`
}

Trigger is an action taken, output produced, an event created, a message sent

func (*Trigger) DeepCopy 

func (in *Trigger) DeepCopy() *Trigger

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Trigger.

func (*Trigger) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*Trigger) Descriptor 

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

func (*Trigger) Marshal 

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

func (*Trigger) MarshalTo 

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

func (*Trigger) MarshalToSizedBuffer added in v0.17.0 

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

func (*Trigger) ProtoMessage 

func (*Trigger) ProtoMessage()

func (*Trigger) Reset 

func (m *Trigger) Reset()

func (*Trigger) Size 

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

func (*Trigger) String 

func (this *Trigger) String() string

func (*Trigger) Unmarshal 

func (m *Trigger) Unmarshal(dAtA []byte) error

func (*Trigger) XXX_DiscardUnknown 

func (m *Trigger) XXX_DiscardUnknown()

func (*Trigger) XXX_Marshal 

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

func (*Trigger) XXX_Merge 

func (m *Trigger) XXX_Merge(src proto.Message)

func (*Trigger) XXX_Size 

func (m *Trigger) XXX_Size() int

func (*Trigger) XXX_Unmarshal 

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

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 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,12,opt,name=log"`
	// AzureEventHubs refers to the trigger send an event to an Azure Event Hub.
	// +optional
	AzureEventHubs *AzureEventHubsTrigger `json:"azureEventHubs,omitempty" protobuf:"bytes,13,opt,name=azureEventHubs"`
	// Pulsar refers to the trigger designed to place messages on Pulsar topic.
	// +optional
	Pulsar *PulsarTrigger `json:"pulsar,omitempty" protobuf:"bytes,14,opt,name=pulsar"`
	// Criteria to reset the conditons
	// +optional
	ConditionsReset []ConditionsResetCriteria `json:"conditionsReset,omitempty" protobuf:"bytes,15,rep,name=conditionsReset"`
}

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) MarshalTo 

func (m *URLArtifact) MarshalTo(dAtA []byte) (int, 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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.