common

package
v1.5.0 Latest Latest
Warning

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

 Go to latest Published: Oct 12, 2021 License: Apache-2.0 Imports: 16 Imported by: 18

Documentation

Overview

+k8s:deepcopy-gen=package +k8s:openapi-gen=true

Index

Constants

This section is empty.

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 (
	// RecreateStrategyEventSources refers to the list of event source types
	// that need to use Recreate strategy for its Deployment
	RecreateStrategyEventSources = []EventSourceType{
		AMQPEvent,
		CalendarEvent,
		KafkaEvent,
		PubSubEvent,
		AzureEventsHub,
		NATSEvent,
		MQTTEvent,
		MinioEvent,
		EmitterEvent,
		NSQEvent,
		PulsarEvent,
		RedisEvent,
		ResourceEvent,
		HDFSEvent,
		FileEvent,
		GenericEvent,
	}
)

Functions

func GetOpenAPIDefinitions added in v0.13.0 

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

func ValidateBasicAuth added in v1.4.0 

func ValidateBasicAuth(auth *BasicAuth) error

func ValidateSASLConfig added in v1.4.0 

func ValidateSASLConfig(saslConfig *SASLConfig) error

func ValidateTLSConfig added in v1.0.0 

func ValidateTLSConfig(tlsConfig *TLSConfig) error

ValidateTLSConfig validates a TLS configuration.

Types

type Amount added in v0.17.0 

type Amount struct {
	Value []byte `json:"value" protobuf:"bytes,1,opt,name=value"`
}

Amount represent a numeric amount.

func NewAmount added in v0.17.0 

func NewAmount(s string) Amount

func (*Amount) DeepCopy added in v0.17.0 

func (in *Amount) DeepCopy() *Amount

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

func (*Amount) DeepCopyInto added in v0.17.0 

func (in *Amount) DeepCopyInto(out *Amount)

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

func (*Amount) Descriptor added in v0.17.0 

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

func (*Amount) Float64 added in v0.17.0 

func (n *Amount) Float64() (float64, error)

func (*Amount) Marshal added in v0.17.0 

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

func (Amount) MarshalJSON added in v0.17.0 

func (n Amount) MarshalJSON() ([]byte, error)

func (*Amount) MarshalTo added in v0.17.0 

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

func (*Amount) MarshalToSizedBuffer added in v0.17.0 

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

func (Amount) OpenAPISchemaFormat added in v0.17.0 

func (n Amount) OpenAPISchemaFormat() string

func (Amount) OpenAPISchemaType added in v0.17.0 

func (n Amount) OpenAPISchemaType() []string

func (*Amount) ProtoMessage added in v0.17.0 

func (*Amount) ProtoMessage()

func (*Amount) Reset added in v0.17.0 

func (m *Amount) Reset()

func (*Amount) Size added in v0.17.0 

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

func (*Amount) String added in v0.17.0 

func (this *Amount) String() string

func (*Amount) Unmarshal added in v0.17.0 

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

func (*Amount) UnmarshalJSON added in v0.17.0 

func (a *Amount) UnmarshalJSON(value []byte) error

func (*Amount) XXX_DiscardUnknown added in v0.17.0 

func (m *Amount) XXX_DiscardUnknown()

func (*Amount) XXX_Marshal added in v0.17.0 

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

func (*Amount) XXX_Merge added in v0.17.0 

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

func (*Amount) XXX_Size added in v0.17.0 

func (m *Amount) XXX_Size() int

func (*Amount) XXX_Unmarshal added in v0.17.0 

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

type Backoff added in v0.17.0 

type Backoff struct {
	// The initial duration in nanoseconds or strings like "1s", "3m"
	// +optional
	Duration *Int64OrString `json:"duration,omitempty" protobuf:"varint,1,opt,name=duration"`
	// Duration is multiplied by factor each iteration
	// +optional
	Factor *Amount `json:"factor,omitempty" protobuf:"bytes,2,opt,name=factor"`
	// The amount of jitter applied each iteration
	// +optional
	Jitter *Amount `json:"jitter,omitempty" protobuf:"bytes,3,opt,name=jitter"`
	// Exit with error after this many steps
	// +optional
	Steps int32 `json:"steps,omitempty" protobuf:"varint,4,opt,name=steps"`
}

Backoff for an operation

func (*Backoff) DeepCopy added in v0.17.0 

func (in *Backoff) DeepCopy() *Backoff

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

func (*Backoff) DeepCopyInto added in v0.17.0 

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

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

func (*Backoff) Descriptor added in v0.17.0 

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

func (Backoff) GetSteps added in v0.17.0 

func (b Backoff) GetSteps() int

func (*Backoff) Marshal added in v0.17.0 

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

func (*Backoff) MarshalTo added in v0.17.0 

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

func (*Backoff) MarshalToSizedBuffer added in v0.17.0 

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

func (*Backoff) ProtoMessage added in v0.17.0 

func (*Backoff) ProtoMessage()

func (*Backoff) Reset added in v0.17.0 

func (m *Backoff) Reset()

func (*Backoff) Size added in v0.17.0 

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

func (*Backoff) String added in v0.17.0 

func (this *Backoff) String() string

func (*Backoff) Unmarshal added in v0.17.0 

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

func (*Backoff) XXX_DiscardUnknown added in v0.17.0 

func (m *Backoff) XXX_DiscardUnknown()

func (*Backoff) XXX_Marshal added in v0.17.0 

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

func (*Backoff) XXX_Merge added in v0.17.0 

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

func (*Backoff) XXX_Size added in v0.17.0 

func (m *Backoff) XXX_Size() int

func (*Backoff) XXX_Unmarshal added in v0.17.0 

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

type BasicAuth added in v1.3.0 

type BasicAuth struct {
	// Username refers to the Kubernetes secret that holds the username required for basic auth.
	Username *corev1.SecretKeySelector `json:"username,omitempty" protobuf:"bytes,1,opt,name=username"`
	// Password refers to the Kubernetes secret that holds the password required for basic auth.
	Password *corev1.SecretKeySelector `json:"password,omitempty" protobuf:"bytes,2,opt,name=password"`
}

BasicAuth contains the reference to K8s secrets that holds the username and password

func (*BasicAuth) DeepCopy added in v1.3.0 

func (in *BasicAuth) DeepCopy() *BasicAuth

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

func (*BasicAuth) DeepCopyInto added in v1.3.0 

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

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

func (*BasicAuth) Descriptor added in v1.3.0 

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

func (*BasicAuth) Marshal added in v1.3.0 

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

func (*BasicAuth) MarshalTo added in v1.3.0 

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

func (*BasicAuth) MarshalToSizedBuffer added in v1.3.0 

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

func (*BasicAuth) ProtoMessage added in v1.3.0 

func (*BasicAuth) ProtoMessage()

func (*BasicAuth) Reset added in v1.3.0 

func (m *BasicAuth) Reset()

func (*BasicAuth) Size added in v1.3.0 

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

func (*BasicAuth) String added in v1.3.0 

func (this *BasicAuth) String() string

func (*BasicAuth) Unmarshal added in v1.3.0 

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

func (*BasicAuth) XXX_DiscardUnknown added in v1.3.0 

func (m *BasicAuth) XXX_DiscardUnknown()

func (*BasicAuth) XXX_Marshal added in v1.3.0 

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

func (*BasicAuth) XXX_Merge added in v1.3.0 

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

func (*BasicAuth) XXX_Size added in v1.3.0 

func (m *BasicAuth) XXX_Size() int

func (*BasicAuth) XXX_Unmarshal added in v1.3.0 

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

type Condition added in v0.16.0 

type Condition struct {
	// Condition type.
	// +required
	Type ConditionType `json:"type" protobuf:"bytes,1,opt,name=type"`
	// Condition status, True, False or Unknown.
	// +required
	Status corev1.ConditionStatus `json:"status" protobuf:"bytes,2,opt,name=status,casttype=k8s.io/api/core/v1.ConditionStatus"`
	// Last time the condition transitioned from one status to another.
	// +optional
	LastTransitionTime metav1.Time `json:"lastTransitionTime,omitempty" protobuf:"bytes,3,opt,name=lastTransitionTime"`
	// Unique, this should be a short, machine understandable string that gives the reason
	// for condition's last transition. For example, "ImageNotFound"
	// +optional
	Reason string `json:"reason,omitempty" protobuf:"bytes,4,opt,name=reason"`
	// Human-readable message indicating details about last transition.
	// +optional
	Message string `json:"message,omitempty" protobuf:"bytes,5,opt,name=message"`
}

Condition contains details about resource state

func (*Condition) DeepCopy added in v0.16.0 

func (in *Condition) DeepCopy() *Condition

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

func (*Condition) DeepCopyInto added in v0.16.0 

func (in *Condition) DeepCopyInto(out *Condition)

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

func (*Condition) Descriptor added in v0.17.0 

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

func (*Condition) GetMessage added in v0.16.0 

func (c *Condition) GetMessage() string

GetMessage returns a Message

func (*Condition) GetReason added in v0.16.0 

func (c *Condition) GetReason() string

GetReason returns as Reason

func (*Condition) IsFalse added in v0.16.0 

func (c *Condition) IsFalse() bool

IsFalse tells if the condition is False

func (*Condition) IsTrue added in v0.16.0 

func (c *Condition) IsTrue() bool

IsTrue tells if the condition is True

func (*Condition) IsUnknown added in v0.16.0 

func (c *Condition) IsUnknown() bool

IsUnknown tells if the condition is Unknown

func (*Condition) Marshal added in v0.17.0 

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

func (*Condition) MarshalTo added in v0.17.0 

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

func (*Condition) MarshalToSizedBuffer added in v0.17.0 

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

func (*Condition) ProtoMessage added in v0.17.0 

func (*Condition) ProtoMessage()

func (*Condition) Reset added in v0.17.0 

func (m *Condition) Reset()

func (*Condition) Size added in v0.17.0 

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

func (*Condition) String added in v0.17.0 

func (this *Condition) String() string

func (*Condition) Unmarshal added in v0.17.0 

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

func (*Condition) XXX_DiscardUnknown added in v0.17.0 

func (m *Condition) XXX_DiscardUnknown()

func (*Condition) XXX_Marshal added in v0.17.0 

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

func (*Condition) XXX_Merge added in v0.17.0 

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

func (*Condition) XXX_Size added in v0.17.0 

func (m *Condition) XXX_Size() int

func (*Condition) XXX_Unmarshal added in v0.17.0 

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

type ConditionType added in v0.16.0 

type ConditionType string

ConditionType is a valid value of Condition.Type 

const (
	// ConditionReady indicates the resource is ready.
	ConditionReady ConditionType = "Ready"
)

type EventBusType added in v0.17.0 

type EventBusType string

EventBusType is the type of event bus 

var (
	EventBusNATS EventBusType = "nats"
)

possible event bus types

type EventSourceType added in v0.13.0 

type EventSourceType string

EventSourceType is the type of event source 

var (
	MinioEvent           EventSourceType = "minio"
	CalendarEvent        EventSourceType = "calendar"
	FileEvent            EventSourceType = "file"
	ResourceEvent        EventSourceType = "resource"
	WebhookEvent         EventSourceType = "webhook"
	AMQPEvent            EventSourceType = "amqp"
	KafkaEvent           EventSourceType = "kafka"
	MQTTEvent            EventSourceType = "mqtt"
	NATSEvent            EventSourceType = "nats"
	SNSEvent             EventSourceType = "sns"
	SQSEvent             EventSourceType = "sqs"
	PubSubEvent          EventSourceType = "pubsub"
	GithubEvent          EventSourceType = "github"
	GitlabEvent          EventSourceType = "gitlab"
	HDFSEvent            EventSourceType = "hdfs"
	SlackEvent           EventSourceType = "slack"
	StorageGridEvent     EventSourceType = "storagegrid"
	AzureEventsHub       EventSourceType = "azureEventsHub"
	StripeEvent          EventSourceType = "stripe"
	EmitterEvent         EventSourceType = "emitter"
	RedisEvent           EventSourceType = "redis"
	NSQEvent             EventSourceType = "nsq"
	PulsarEvent          EventSourceType = "pulsar"
	GenericEvent         EventSourceType = "generic"
	BitbucketServerEvent EventSourceType = "bitbucketserver"
)

possible event source types

type Int64OrString added in v1.3.0 

type Int64OrString struct {
	Type     Type   `json:"type" protobuf:"varint,1,opt,name=type,casttype=Type"`
	Int64Val int64  `json:"int64Val,omitempty" protobuf:"varint,2,opt,name=int64Val"`
	StrVal   string `json:"strVal,omitempty" protobuf:"bytes,3,opt,name=strVal"`
}

func FromInt64 added in v1.3.0 

func FromInt64(val int64) Int64OrString

FromInt64 creates an Int64OrString object with an int64 value.

func FromString added in v1.3.0 

func FromString(val string) Int64OrString

FromString creates an Int64OrString object with a string value.

func Parse added in v1.3.0 

func Parse(val string) Int64OrString

Parse the given string and try to convert it to an int64 before setting it as a string value.

func (*Int64OrString) DeepCopy added in v1.3.0 

func (in *Int64OrString) DeepCopy() *Int64OrString

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

func (*Int64OrString) DeepCopyInto added in v1.3.0 

func (in *Int64OrString) DeepCopyInto(out *Int64OrString)

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

func (*Int64OrString) Descriptor added in v1.3.0 

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

func (*Int64OrString) Int64Value added in v1.3.0 

func (int64str *Int64OrString) Int64Value() int64

Int64Value returns the Int64Val if type Int64, or if it is a String, will attempt a conversion to int64, returning 0 if a parsing error occurs.

func (*Int64OrString) Marshal added in v1.3.0 

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

func (Int64OrString) MarshalJSON added in v1.3.0 

func (int64str Int64OrString) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaller interface.

func (*Int64OrString) MarshalTo added in v1.3.0 

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

func (*Int64OrString) MarshalToSizedBuffer added in v1.3.0 

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

func (Int64OrString) OpenAPISchemaFormat added in v1.3.0 

func (Int64OrString) OpenAPISchemaFormat() string

OpenAPISchemaFormat is used by the kube-openapi generator when constructing the OpenAPI spec of this type.

func (Int64OrString) OpenAPISchemaType added in v1.3.0 

func (Int64OrString) OpenAPISchemaType() []string

OpenAPISchemaType is used by the kube-openapi generator when constructing the OpenAPI spec of this type.

See: https://github.com/kubernetes/kube-openapi/tree/master/pkg/generators

func (*Int64OrString) ProtoMessage added in v1.3.0 

func (*Int64OrString) ProtoMessage()

func (*Int64OrString) Reset added in v1.3.0 

func (m *Int64OrString) Reset()

func (*Int64OrString) Size added in v1.3.0 

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

func (*Int64OrString) String added in v1.3.0 

func (this *Int64OrString) String() string

func (*Int64OrString) Unmarshal added in v1.3.0 

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

func (*Int64OrString) UnmarshalJSON added in v1.3.0 

func (int64str *Int64OrString) UnmarshalJSON(value []byte) error

UnmarshalJSON implements the json.Unmarshaller interface.

func (*Int64OrString) XXX_DiscardUnknown added in v1.3.0 

func (m *Int64OrString) XXX_DiscardUnknown()

func (*Int64OrString) XXX_Marshal added in v1.3.0 

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

func (*Int64OrString) XXX_Merge added in v1.3.0 

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

func (*Int64OrString) XXX_Size added in v1.3.0 

func (m *Int64OrString) XXX_Size() int

func (*Int64OrString) XXX_Unmarshal added in v1.3.0 

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

type Metadata added in v1.1.0 

type Metadata struct {
	Annotations map[string]string `json:"annotations,omitempty" protobuf:"bytes,1,rep,name=annotations"`
	Labels      map[string]string `json:"labels,omitempty" protobuf:"bytes,2,rep,name=labels"`
}

Metadata holds the annotations and labels of an event source pod

func (*Metadata) DeepCopy added in v1.1.0 

func (in *Metadata) DeepCopy() *Metadata

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

func (*Metadata) DeepCopyInto added in v1.1.0 

func (in *Metadata) DeepCopyInto(out *Metadata)

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

func (*Metadata) Descriptor added in v1.1.0 

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

func (*Metadata) Marshal added in v1.1.0 

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

func (*Metadata) MarshalTo added in v1.1.0 

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

func (*Metadata) MarshalToSizedBuffer added in v1.1.0 

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

func (*Metadata) ProtoMessage added in v1.1.0 

func (*Metadata) ProtoMessage()

func (*Metadata) Reset added in v1.1.0 

func (m *Metadata) Reset()

func (*Metadata) Size added in v1.1.0 

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

func (*Metadata) String added in v1.1.0 

func (this *Metadata) String() string

func (*Metadata) Unmarshal added in v1.1.0 

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

func (*Metadata) XXX_DiscardUnknown added in v1.1.0 

func (m *Metadata) XXX_DiscardUnknown()

func (*Metadata) XXX_Marshal added in v1.1.0 

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

func (*Metadata) XXX_Merge added in v1.1.0 

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

func (*Metadata) XXX_Size added in v1.1.0 

func (m *Metadata) XXX_Size() int

func (*Metadata) XXX_Unmarshal added in v1.1.0 

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

type Resource added in v0.17.0 

type Resource struct {
	Value []byte `json:"value" protobuf:"bytes,1,opt,name=value"`
}

Resource represent arbitrary structured data.

func NewResource added in v0.17.0 

func NewResource(s interface{}) Resource

func (*Resource) DeepCopy added in v0.17.0 

func (in *Resource) DeepCopy() *Resource

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

func (*Resource) DeepCopyInto added in v0.17.0 

func (in *Resource) DeepCopyInto(out *Resource)

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

func (*Resource) Descriptor added in v0.17.0 

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

func (*Resource) Marshal added in v0.17.0 

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

func (Resource) MarshalJSON added in v0.17.0 

func (n Resource) MarshalJSON() ([]byte, error)

func (*Resource) MarshalTo added in v0.17.0 

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

func (*Resource) MarshalToSizedBuffer added in v0.17.0 

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

func (Resource) OpenAPISchemaFormat added in v0.17.0 

func (n Resource) OpenAPISchemaFormat() string

func (Resource) OpenAPISchemaType added in v0.17.0 

func (n Resource) OpenAPISchemaType() []string

func (*Resource) ProtoMessage added in v0.17.0 

func (*Resource) ProtoMessage()

func (*Resource) Reset added in v0.17.0 

func (m *Resource) Reset()

func (*Resource) Size added in v0.17.0 

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

func (*Resource) String added in v0.17.0 

func (this *Resource) String() string

func (*Resource) Unmarshal added in v0.17.0 

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

func (*Resource) UnmarshalJSON added in v0.17.0 

func (a *Resource) UnmarshalJSON(value []byte) error

func (*Resource) XXX_DiscardUnknown added in v0.17.0 

func (m *Resource) XXX_DiscardUnknown()

func (*Resource) XXX_Marshal added in v0.17.0 

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

func (*Resource) XXX_Merge added in v0.17.0 

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

func (*Resource) XXX_Size added in v0.17.0 

func (m *Resource) XXX_Size() int

func (*Resource) XXX_Unmarshal added in v0.17.0 

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

type S3Artifact 

type S3Artifact struct {
	Endpoint  string                    `json:"endpoint" protobuf:"bytes,1,opt,name=endpoint"`
	Bucket    *S3Bucket                 `json:"bucket" protobuf:"bytes,2,opt,name=bucket"`
	Region    string                    `json:"region,omitempty" protobuf:"bytes,3,opt,name=region"`
	Insecure  bool                      `json:"insecure,omitempty" protobuf:"varint,4,opt,name=insecure"`
	AccessKey *corev1.SecretKeySelector `json:"accessKey" protobuf:"bytes,5,opt,name=accessKey"`
	SecretKey *corev1.SecretKeySelector `json:"secretKey" protobuf:"bytes,6,opt,name=secretKey"`

	Events   []string          `json:"events,omitempty" protobuf:"bytes,7,rep,name=events"`
	Filter   *S3Filter         `json:"filter,omitempty" protobuf:"bytes,8,opt,name=filter"`
	Metadata map[string]string `json:"metadata,omitempty" protobuf:"bytes,9,opt,name=metadata"`
}

S3Artifact contains information about an S3 connection and bucket

func (*S3Artifact) DeepCopy 

func (in *S3Artifact) DeepCopy() *S3Artifact

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

func (*S3Artifact) DeepCopyInto 

func (in *S3Artifact) DeepCopyInto(out *S3Artifact)

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

func (*S3Artifact) Descriptor 

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

func (*S3Artifact) Marshal 

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

func (*S3Artifact) MarshalTo 

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

func (*S3Artifact) MarshalToSizedBuffer added in v0.17.0 

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

func (*S3Artifact) ProtoMessage 

func (*S3Artifact) ProtoMessage()

func (*S3Artifact) Reset 

func (m *S3Artifact) Reset()

func (*S3Artifact) Size 

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

func (*S3Artifact) String 

func (this *S3Artifact) String() string

func (*S3Artifact) Unmarshal 

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

func (*S3Artifact) XXX_DiscardUnknown 

func (m *S3Artifact) XXX_DiscardUnknown()

func (*S3Artifact) XXX_Marshal 

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

func (*S3Artifact) XXX_Merge 

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

func (*S3Artifact) XXX_Size 

func (m *S3Artifact) XXX_Size() int

func (*S3Artifact) XXX_Unmarshal 

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

type S3Bucket 

type S3Bucket struct {
	Key  string `json:"key,omitempty" protobuf:"bytes,1,opt,name=key"`
	Name string `json:"name" protobuf:"bytes,2,opt,name=name"`
}

S3Bucket contains information to describe an S3 Bucket

func (*S3Bucket) DeepCopy 

func (in *S3Bucket) DeepCopy() *S3Bucket

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

func (*S3Bucket) DeepCopyInto 

func (in *S3Bucket) DeepCopyInto(out *S3Bucket)

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

func (*S3Bucket) Descriptor 

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

func (*S3Bucket) Marshal 

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

func (*S3Bucket) MarshalTo 

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

func (*S3Bucket) MarshalToSizedBuffer added in v0.17.0 

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

func (*S3Bucket) ProtoMessage 

func (*S3Bucket) ProtoMessage()

func (*S3Bucket) Reset 

func (m *S3Bucket) Reset()

func (*S3Bucket) Size 

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

func (*S3Bucket) String 

func (this *S3Bucket) String() string

func (*S3Bucket) Unmarshal 

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

func (*S3Bucket) XXX_DiscardUnknown 

func (m *S3Bucket) XXX_DiscardUnknown()

func (*S3Bucket) XXX_Marshal 

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

func (*S3Bucket) XXX_Merge 

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

func (*S3Bucket) XXX_Size 

func (m *S3Bucket) XXX_Size() int

func (*S3Bucket) XXX_Unmarshal 

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

type S3Filter 

type S3Filter struct {
	Prefix string `json:"prefix" protobuf:"bytes,1,opt,name=prefix"`
	Suffix string `json:"suffix" protobuf:"bytes,2,opt,name=suffix"`
}

S3Filter represents filters to apply to bucket notifications for specifying constraints on objects

func (*S3Filter) DeepCopy 

func (in *S3Filter) DeepCopy() *S3Filter

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

func (*S3Filter) DeepCopyInto 

func (in *S3Filter) DeepCopyInto(out *S3Filter)

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

func (*S3Filter) Descriptor 

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

func (*S3Filter) Marshal 

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

func (*S3Filter) MarshalTo 

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

func (*S3Filter) MarshalToSizedBuffer added in v0.17.0 

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

func (*S3Filter) ProtoMessage 

func (*S3Filter) ProtoMessage()

func (*S3Filter) Reset 

func (m *S3Filter) Reset()

func (*S3Filter) Size 

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

func (*S3Filter) String 

func (this *S3Filter) String() string

func (*S3Filter) Unmarshal 

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

func (*S3Filter) XXX_DiscardUnknown 

func (m *S3Filter) XXX_DiscardUnknown()

func (*S3Filter) XXX_Marshal 

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

func (*S3Filter) XXX_Merge 

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

func (*S3Filter) XXX_Size 

func (m *S3Filter) XXX_Size() int

func (*S3Filter) XXX_Unmarshal 

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

type SASLConfig added in v1.4.0 

type SASLConfig struct {
	// SASLMechanism is the name of the enabled SASL mechanism.
	// Possible values: OAUTHBEARER, PLAIN (defaults to PLAIN).
	// +optional
	Mechanism string `json:"mechanism,omitempty" protobuf:"bytes,1,opt,name=mechanism"`
	// User is the authentication identity (authcid) to present for
	// SASL/PLAIN or SASL/SCRAM authentication
	UserSecret *corev1.SecretKeySelector `json:"userSecret,omitempty" protobuf:"bytes,2,opt,name=user"`
	// Password for SASL/PLAIN authentication
	PasswordSecret *corev1.SecretKeySelector `json:"passwordSecret,omitempty" protobuf:"bytes,3,opt,name=password"`
}

SASLConfig refers to SASL configuration for a client

func (*SASLConfig) DeepCopy added in v1.4.0 

func (in *SASLConfig) DeepCopy() *SASLConfig

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

func (*SASLConfig) DeepCopyInto added in v1.4.0 

func (in *SASLConfig) DeepCopyInto(out *SASLConfig)

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

func (*SASLConfig) Descriptor added in v1.4.0 

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

func (SASLConfig) GetMechanism added in v1.4.0 

func (s SASLConfig) GetMechanism() string

func (*SASLConfig) Marshal added in v1.4.0 

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

func (*SASLConfig) MarshalTo added in v1.4.0 

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

func (*SASLConfig) MarshalToSizedBuffer added in v1.4.0 

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

func (*SASLConfig) ProtoMessage added in v1.4.0 

func (*SASLConfig) ProtoMessage()

func (*SASLConfig) Reset added in v1.4.0 

func (m *SASLConfig) Reset()

func (*SASLConfig) Size added in v1.4.0 

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

func (*SASLConfig) String added in v1.4.0 

func (this *SASLConfig) String() string

func (*SASLConfig) Unmarshal added in v1.4.0 

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

func (*SASLConfig) XXX_DiscardUnknown added in v1.4.0 

func (m *SASLConfig) XXX_DiscardUnknown()

func (*SASLConfig) XXX_Marshal added in v1.4.0 

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

func (*SASLConfig) XXX_Merge added in v1.4.0 

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

func (*SASLConfig) XXX_Size added in v1.4.0 

func (m *SASLConfig) XXX_Size() int

func (*SASLConfig) XXX_Unmarshal added in v1.4.0 

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

type SecureHeader added in v1.4.0 

type SecureHeader struct {
	Name string `json:"name,omitempty" protobuf:"bytes,1,opt,name=name"`
	// Values can be read from either secrets or configmaps
	ValueFrom *ValueFromSource `json:"valueFrom,omitempty" protobuf:"bytes,2,opt,name=valueFrom"`
}

SecureHeader refers to HTTP Headers with auth tokens as values

func (*SecureHeader) DeepCopy added in v1.4.0 

func (in *SecureHeader) DeepCopy() *SecureHeader

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

func (*SecureHeader) DeepCopyInto added in v1.4.0 

func (in *SecureHeader) DeepCopyInto(out *SecureHeader)

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

func (*SecureHeader) Descriptor added in v1.4.0 

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

func (*SecureHeader) Marshal added in v1.4.0 

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

func (*SecureHeader) MarshalTo added in v1.4.0 

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

func (*SecureHeader) MarshalToSizedBuffer added in v1.4.0 

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

func (*SecureHeader) ProtoMessage added in v1.4.0 

func (*SecureHeader) ProtoMessage()

func (*SecureHeader) Reset added in v1.4.0 

func (m *SecureHeader) Reset()

func (*SecureHeader) Size added in v1.4.0 

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

func (*SecureHeader) String added in v1.4.0 

func (this *SecureHeader) String() string

func (*SecureHeader) Unmarshal added in v1.4.0 

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

func (*SecureHeader) XXX_DiscardUnknown added in v1.4.0 

func (m *SecureHeader) XXX_DiscardUnknown()

func (*SecureHeader) XXX_Marshal added in v1.4.0 

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

func (*SecureHeader) XXX_Merge added in v1.4.0 

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

func (*SecureHeader) XXX_Size added in v1.4.0 

func (m *SecureHeader) XXX_Size() int

func (*SecureHeader) XXX_Unmarshal added in v1.4.0 

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

type Status added in v0.16.0 

type Status struct {
	// Conditions are the latest available observations of a resource's current state.
	// +optional
	// +patchMergeKey=type
	// +patchStrategy=merge
	Conditions []Condition `json:"conditions,omitempty" patchStrategy:"merge" patchMergeKey:"type" protobuf:"bytes,1,rep,name=conditions"`
}

Status is a common structure which can be used for Status field.

func (*Status) DeepCopy added in v0.16.0 

func (in *Status) DeepCopy() *Status

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

func (*Status) DeepCopyInto added in v0.16.0 

func (in *Status) DeepCopyInto(out *Status)

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

func (*Status) Descriptor added in v0.17.0 

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

func (*Status) GetCondition added in v0.16.0 

func (s *Status) GetCondition(t ConditionType) *Condition

GetCondition returns the condition of a condtion type

func (*Status) InitializeConditions added in v0.17.0 

func (s *Status) InitializeConditions(conditionTypes ...ConditionType)

InitializeConditions initializes the contions to Unknown

func (*Status) IsReady added in v0.16.0 

func (s *Status) IsReady() bool

IsReady returns true when all the conditions are true

func (*Status) MarkFalse added in v0.16.0 

func (s *Status) MarkFalse(t ConditionType, reason, message string)

MarkFalse sets the status of t to fasle

func (*Status) MarkTrue added in v0.16.0 

func (s *Status) MarkTrue(t ConditionType)

MarkTrue sets the status of t to true

func (*Status) MarkTrueWithReason added in v0.16.0 

func (s *Status) MarkTrueWithReason(t ConditionType, reason, message string)

MarkTrueWithReason sets the status of t to true with reason

func (*Status) MarkUnknown added in v0.16.0 

func (s *Status) MarkUnknown(t ConditionType, reason, message string)

MarkUnknown sets the status of t to unknown

func (*Status) Marshal added in v0.17.0 

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

func (*Status) MarshalTo added in v0.17.0 

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

func (*Status) MarshalToSizedBuffer added in v0.17.0 

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

func (*Status) ProtoMessage added in v0.17.0 

func (*Status) ProtoMessage()

func (*Status) Reset added in v0.17.0 

func (m *Status) Reset()

func (*Status) SetCondition added in v0.16.0 

func (s *Status) SetCondition(condition Condition)

SetCondition sets a condition

func (*Status) Size added in v0.17.0 

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

func (*Status) String added in v0.17.0 

func (this *Status) String() string

func (*Status) Unmarshal added in v0.17.0 

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

func (*Status) XXX_DiscardUnknown added in v0.17.0 

func (m *Status) XXX_DiscardUnknown()

func (*Status) XXX_Marshal added in v0.17.0 

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

func (*Status) XXX_Merge added in v0.17.0 

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

func (*Status) XXX_Size added in v0.17.0 

func (m *Status) XXX_Size() int

func (*Status) XXX_Unmarshal added in v0.17.0 

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

type TLSConfig added in v1.0.0 

type TLSConfig struct {
	// CACertSecret refers to the secret that contains the CA cert
	CACertSecret *corev1.SecretKeySelector `json:"caCertSecret,omitempty" protobuf:"bytes,1,opt,name=caCertSecret"`
	// ClientCertSecret refers to the secret that contains the client cert
	ClientCertSecret *corev1.SecretKeySelector `json:"clientCertSecret,omitempty" protobuf:"bytes,2,opt,name=clientCertSecret"`
	// ClientKeySecret refers to the secret that contains the client key
	ClientKeySecret *corev1.SecretKeySelector `json:"clientKeySecret,omitempty" protobuf:"bytes,3,opt,name=clientKeySecret"`
}

TLSConfig refers to TLS configuration for a client.

func (*TLSConfig) DeepCopy added in v1.0.0 

func (in *TLSConfig) DeepCopy() *TLSConfig

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

func (*TLSConfig) DeepCopyInto added in v1.0.0 

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

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

func (*TLSConfig) Descriptor added in v1.0.0 

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

func (*TLSConfig) Marshal added in v1.0.0 

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

func (*TLSConfig) MarshalTo added in v1.0.0 

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

func (*TLSConfig) MarshalToSizedBuffer added in v1.0.0 

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

func (*TLSConfig) ProtoMessage added in v1.0.0 

func (*TLSConfig) ProtoMessage()

func (*TLSConfig) Reset added in v1.0.0 

func (m *TLSConfig) Reset()

func (*TLSConfig) Size added in v1.0.0 

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

func (*TLSConfig) String added in v1.0.0 

func (this *TLSConfig) String() string

func (*TLSConfig) Unmarshal added in v1.0.0 

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

func (*TLSConfig) XXX_DiscardUnknown added in v1.0.0 

func (m *TLSConfig) XXX_DiscardUnknown()

func (*TLSConfig) XXX_Marshal added in v1.0.0 

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

func (*TLSConfig) XXX_Merge added in v1.0.0 

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

func (*TLSConfig) XXX_Size added in v1.0.0 

func (m *TLSConfig) XXX_Size() int

func (*TLSConfig) XXX_Unmarshal added in v1.0.0 

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

type TriggerType added in v1.3.0 

type TriggerType string

TriggerType is the type of trigger 

var (
	OpenWhiskTrigger      TriggerType = "OpenWhisk"
	ArgoWorkflowTrigger   TriggerType = "ArgoWorkflow"
	LambdaTrigger         TriggerType = "Lambda"
	CustomTrigger         TriggerType = "Custom"
	HTTPTrigger           TriggerType = "HTTP"
	KafkaTrigger          TriggerType = "Kafka"
	PulsarTrigger         TriggerType = "Pulsar"
	LogTrigger            TriggerType = "Log"
	NATSTrigger           TriggerType = "NATS"
	SlackTrigger          TriggerType = "Slack"
	K8sTrigger            TriggerType = "Kubernetes"
	AzureEventHubsTrigger TriggerType = "AzureEventHubs"
)

possible trigger types

type Type added in v1.3.0 

type Type int64

Type represents the stored type of Int64OrString. 

const (
	Int64  Type = iota // The Int64OrString holds an int64.
	String             // The Int64OrString holds a string.
)

type ValueFromSource added in v1.4.0 

type ValueFromSource struct {
	SecretKeyRef    *corev1.SecretKeySelector    `json:"secretKeyRef,omitempty" protobuf:"bytes,1,opt,name=secretKeyRef"`
	ConfigMapKeyRef *corev1.ConfigMapKeySelector `json:"configMapKeyRef,omitempty" protobuf:"bytes,2,opt,name=configMapKeyRef"`
}

ValueFromSource allows you to reference keys from either a Configmap or Secret

func (*ValueFromSource) DeepCopy added in v1.4.0 

func (in *ValueFromSource) DeepCopy() *ValueFromSource

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

func (*ValueFromSource) DeepCopyInto added in v1.4.0 

func (in *ValueFromSource) DeepCopyInto(out *ValueFromSource)

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

func (*ValueFromSource) Descriptor added in v1.4.0 

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

func (*ValueFromSource) Marshal added in v1.4.0 

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

func (*ValueFromSource) MarshalTo added in v1.4.0 

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

func (*ValueFromSource) MarshalToSizedBuffer added in v1.4.0 

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

func (*ValueFromSource) ProtoMessage added in v1.4.0 

func (*ValueFromSource) ProtoMessage()

func (*ValueFromSource) Reset added in v1.4.0 

func (m *ValueFromSource) Reset()

func (*ValueFromSource) Size added in v1.4.0 

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

func (*ValueFromSource) String added in v1.4.0 

func (this *ValueFromSource) String() string

func (*ValueFromSource) Unmarshal added in v1.4.0 

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

func (*ValueFromSource) XXX_DiscardUnknown added in v1.4.0 

func (m *ValueFromSource) XXX_DiscardUnknown()

func (*ValueFromSource) XXX_Marshal added in v1.4.0 

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

func (*ValueFromSource) XXX_Merge added in v1.4.0 

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

func (*ValueFromSource) XXX_Size added in v1.4.0 

func (m *ValueFromSource) XXX_Size() int

func (*ValueFromSource) XXX_Unmarshal added in v1.4.0 

func (m *ValueFromSource) 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.