Documentation ¶
Overview ¶
Package v1alpha1 contains API Schema definitions for the dataflow v1alpha1 API group +kubebuilder:object:generate=true +groupName=dataflow.argoproj.io
Index ¶
- Constants
- Variables
- func RequeueAfter(currentReplicas, targetReplicas int, scalingDelay time.Duration) time.Duration
- func StringOr(a, b string) string
- func StringsOr(a, b []string) []string
- type Cat
- func (in *Cat) DeepCopy() *Cat
- func (in *Cat) DeepCopyInto(out *Cat)
- func (*Cat) Descriptor() ([]byte, []int)
- func (m *Cat) Marshal() (dAtA []byte, err error)
- func (m *Cat) MarshalTo(dAtA []byte) (int, error)
- func (m *Cat) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Cat) ProtoMessage()
- func (m *Cat) Reset()
- func (m *Cat) Size() (n int)
- func (this *Cat) String() string
- func (m *Cat) Unmarshal(dAtA []byte) error
- func (m *Cat) XXX_DiscardUnknown()
- func (m *Cat) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Cat) XXX_Merge(src proto.Message)
- func (m *Cat) XXX_Size() int
- func (m *Cat) XXX_Unmarshal(b []byte) error
- type Container
- func (in *Container) DeepCopy() *Container
- func (in *Container) DeepCopyInto(out *Container)
- func (*Container) Descriptor() ([]byte, []int)
- func (in *Container) GetIn() *Interface
- func (m *Container) Marshal() (dAtA []byte, err error)
- func (m *Container) MarshalTo(dAtA []byte) (int, error)
- func (m *Container) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Container) ProtoMessage()
- func (m *Container) Reset()
- func (m *Container) Size() (n int)
- func (this *Container) String() string
- func (m *Container) Unmarshal(dAtA []byte) error
- func (m *Container) XXX_DiscardUnknown()
- func (m *Container) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Container) XXX_Merge(src proto.Message)
- func (m *Container) XXX_Size() int
- func (m *Container) XXX_Unmarshal(b []byte) error
- type Cron
- func (in *Cron) DeepCopy() *Cron
- func (in *Cron) DeepCopyInto(out *Cron)
- func (*Cron) Descriptor() ([]byte, []int)
- func (m *Cron) Marshal() (dAtA []byte, err error)
- func (m *Cron) MarshalTo(dAtA []byte) (int, error)
- func (m *Cron) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Cron) ProtoMessage()
- func (m *Cron) Reset()
- func (m *Cron) Size() (n int)
- func (this *Cron) String() string
- func (m *Cron) Unmarshal(dAtA []byte) error
- func (m *Cron) XXX_DiscardUnknown()
- func (m *Cron) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Cron) XXX_Merge(src proto.Message)
- func (m *Cron) XXX_Size() int
- func (m *Cron) XXX_Unmarshal(b []byte) error
- type Error
- func (in *Error) DeepCopy() *Error
- func (in *Error) DeepCopyInto(out *Error)
- func (*Error) Descriptor() ([]byte, []int)
- func (m *Error) Marshal() (dAtA []byte, err error)
- func (m *Error) MarshalTo(dAtA []byte) (int, error)
- func (m *Error) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Error) ProtoMessage()
- func (m *Error) Reset()
- func (m *Error) Size() (n int)
- func (this *Error) String() string
- func (m *Error) Unmarshal(dAtA []byte) error
- func (m *Error) XXX_DiscardUnknown()
- func (m *Error) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Error) XXX_Merge(src proto.Message)
- func (m *Error) XXX_Size() int
- func (m *Error) XXX_Unmarshal(b []byte) error
- type Filter
- type GetPodSpecReq
- func (in *GetPodSpecReq) DeepCopy() *GetPodSpecReq
- func (in *GetPodSpecReq) DeepCopyInto(out *GetPodSpecReq)
- func (*GetPodSpecReq) Descriptor() ([]byte, []int)
- func (m *GetPodSpecReq) Marshal() (dAtA []byte, err error)
- func (m *GetPodSpecReq) MarshalTo(dAtA []byte) (int, error)
- func (m *GetPodSpecReq) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetPodSpecReq) ProtoMessage()
- func (m *GetPodSpecReq) Reset()
- func (m *GetPodSpecReq) Size() (n int)
- func (this *GetPodSpecReq) String() string
- func (m *GetPodSpecReq) Unmarshal(dAtA []byte) error
- func (m *GetPodSpecReq) XXX_DiscardUnknown()
- func (m *GetPodSpecReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetPodSpecReq) XXX_Merge(src proto.Message)
- func (m *GetPodSpecReq) XXX_Size() int
- func (m *GetPodSpecReq) XXX_Unmarshal(b []byte) error
- type Git
- func (in *Git) DeepCopy() *Git
- func (in *Git) DeepCopyInto(out *Git)
- func (*Git) Descriptor() ([]byte, []int)
- func (m *Git) Marshal() (dAtA []byte, err error)
- func (m *Git) MarshalTo(dAtA []byte) (int, error)
- func (m *Git) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Git) ProtoMessage()
- func (m *Git) Reset()
- func (m *Git) Size() (n int)
- func (this *Git) String() string
- func (m *Git) Unmarshal(dAtA []byte) error
- func (m *Git) XXX_DiscardUnknown()
- func (m *Git) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Git) XXX_Merge(src proto.Message)
- func (m *Git) XXX_Size() int
- func (m *Git) XXX_Unmarshal(b []byte) error
- type Group
- func (in *Group) DeepCopy() *Group
- func (in *Group) DeepCopyInto(out *Group)
- func (*Group) Descriptor() ([]byte, []int)
- func (m *Group) Marshal() (dAtA []byte, err error)
- func (m *Group) MarshalTo(dAtA []byte) (int, error)
- func (m *Group) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Group) ProtoMessage()
- func (m *Group) Reset()
- func (m *Group) Size() (n int)
- func (this *Group) String() string
- func (m *Group) Unmarshal(dAtA []byte) error
- func (m *Group) XXX_DiscardUnknown()
- func (m *Group) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Group) XXX_Merge(src proto.Message)
- func (m *Group) XXX_Size() int
- func (m *Group) XXX_Unmarshal(b []byte) error
- type GroupFormat
- type HTTP
- func (in *HTTP) DeepCopy() *HTTP
- func (in *HTTP) DeepCopyInto(out *HTTP)
- func (*HTTP) Descriptor() ([]byte, []int)
- func (m *HTTP) Marshal() (dAtA []byte, err error)
- func (m *HTTP) MarshalTo(dAtA []byte) (int, error)
- func (m *HTTP) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*HTTP) ProtoMessage()
- func (m *HTTP) Reset()
- func (m *HTTP) Size() (n int)
- func (this *HTTP) String() string
- func (m *HTTP) Unmarshal(dAtA []byte) error
- func (m *HTTP) XXX_DiscardUnknown()
- func (m *HTTP) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *HTTP) XXX_Merge(src proto.Message)
- func (m *HTTP) XXX_Size() int
- func (m *HTTP) XXX_Unmarshal(b []byte) error
- type Handler
- func (in *Handler) DeepCopy() *Handler
- func (in *Handler) DeepCopyInto(out *Handler)
- func (*Handler) Descriptor() ([]byte, []int)
- func (m *Handler) Marshal() (dAtA []byte, err error)
- func (m *Handler) MarshalTo(dAtA []byte) (int, error)
- func (m *Handler) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Handler) ProtoMessage()
- func (m *Handler) Reset()
- func (m *Handler) Size() (n int)
- func (this *Handler) String() string
- func (m *Handler) Unmarshal(dAtA []byte) error
- func (m *Handler) XXX_DiscardUnknown()
- func (m *Handler) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Handler) XXX_Merge(src proto.Message)
- func (m *Handler) XXX_Size() int
- func (m *Handler) XXX_Unmarshal(b []byte) error
- type Interface
- func (in *Interface) DeepCopy() *Interface
- func (in *Interface) DeepCopyInto(out *Interface)
- func (*Interface) Descriptor() ([]byte, []int)
- func (m *Interface) Marshal() (dAtA []byte, err error)
- func (m *Interface) MarshalTo(dAtA []byte) (int, error)
- func (m *Interface) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Interface) ProtoMessage()
- func (m *Interface) Reset()
- func (m *Interface) Size() (n int)
- func (this *Interface) String() string
- func (m *Interface) Unmarshal(dAtA []byte) error
- func (m *Interface) XXX_DiscardUnknown()
- func (m *Interface) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Interface) XXX_Merge(src proto.Message)
- func (m *Interface) XXX_Size() int
- func (m *Interface) XXX_Unmarshal(b []byte) error
- type Kafka
- func (in *Kafka) DeepCopy() *Kafka
- func (in *Kafka) DeepCopyInto(out *Kafka)
- func (*Kafka) Descriptor() ([]byte, []int)
- func (m *Kafka) Marshal() (dAtA []byte, err error)
- func (m *Kafka) MarshalTo(dAtA []byte) (int, error)
- func (m *Kafka) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Kafka) ProtoMessage()
- func (m *Kafka) Reset()
- func (m *Kafka) Size() (n int)
- func (this *Kafka) String() string
- func (m *Kafka) Unmarshal(dAtA []byte) error
- func (m *Kafka) XXX_DiscardUnknown()
- func (m *Kafka) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Kafka) XXX_Merge(src proto.Message)
- func (m *Kafka) XXX_Size() int
- func (m *Kafka) XXX_Unmarshal(b []byte) error
- type KafkaNET
- func (in *KafkaNET) DeepCopy() *KafkaNET
- func (in *KafkaNET) DeepCopyInto(out *KafkaNET)
- func (*KafkaNET) Descriptor() ([]byte, []int)
- func (m *KafkaNET) Marshal() (dAtA []byte, err error)
- func (m *KafkaNET) MarshalTo(dAtA []byte) (int, error)
- func (m *KafkaNET) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*KafkaNET) ProtoMessage()
- func (m *KafkaNET) Reset()
- func (m *KafkaNET) Size() (n int)
- func (this *KafkaNET) String() string
- func (m *KafkaNET) Unmarshal(dAtA []byte) error
- func (m *KafkaNET) XXX_DiscardUnknown()
- func (m *KafkaNET) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *KafkaNET) XXX_Merge(src proto.Message)
- func (m *KafkaNET) XXX_Size() int
- func (m *KafkaNET) XXX_Unmarshal(b []byte) error
- type Log
- func (in *Log) DeepCopy() *Log
- func (in *Log) DeepCopyInto(out *Log)
- func (*Log) Descriptor() ([]byte, []int)
- func (m *Log) Marshal() (dAtA []byte, err error)
- func (m *Log) MarshalTo(dAtA []byte) (int, error)
- func (m *Log) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Log) ProtoMessage()
- func (m *Log) Reset()
- func (m *Log) Size() (n int)
- func (this *Log) String() string
- func (m *Log) Unmarshal(dAtA []byte) error
- func (m *Log) XXX_DiscardUnknown()
- func (m *Log) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Log) XXX_Merge(src proto.Message)
- func (m *Log) XXX_Size() int
- func (m *Log) XXX_Unmarshal(b []byte) error
- type Map
- type Message
- func (in *Message) DeepCopy() *Message
- func (in *Message) DeepCopyInto(out *Message)
- func (*Message) Descriptor() ([]byte, []int)
- func (m *Message) Marshal() (dAtA []byte, err error)
- func (m *Message) MarshalTo(dAtA []byte) (int, error)
- func (m *Message) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Message) ProtoMessage()
- func (m *Message) Reset()
- func (m *Message) Size() (n int)
- func (this *Message) String() string
- func (m *Message) Unmarshal(dAtA []byte) error
- func (m *Message) XXX_DiscardUnknown()
- func (m *Message) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Message) XXX_Merge(src proto.Message)
- func (m *Message) XXX_Size() int
- func (m *Message) XXX_Unmarshal(b []byte) error
- type Metadata
- func (in *Metadata) DeepCopy() *Metadata
- func (in *Metadata) DeepCopyInto(out *Metadata)
- func (*Metadata) Descriptor() ([]byte, []int)
- func (m *Metadata) Marshal() (dAtA []byte, err error)
- func (m *Metadata) MarshalTo(dAtA []byte) (int, error)
- func (m *Metadata) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Metadata) ProtoMessage()
- func (m *Metadata) Reset()
- func (m *Metadata) Size() (n int)
- func (this *Metadata) String() string
- func (m *Metadata) Unmarshal(dAtA []byte) error
- func (m *Metadata) XXX_DiscardUnknown()
- func (m *Metadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Metadata) XXX_Merge(src proto.Message)
- func (m *Metadata) XXX_Size() int
- func (m *Metadata) XXX_Unmarshal(b []byte) error
- type Metrics
- func (in *Metrics) DeepCopy() *Metrics
- func (in *Metrics) DeepCopyInto(out *Metrics)
- func (*Metrics) Descriptor() ([]byte, []int)
- func (m *Metrics) Marshal() (dAtA []byte, err error)
- func (m *Metrics) MarshalTo(dAtA []byte) (int, error)
- func (m *Metrics) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Metrics) ProtoMessage()
- func (m *Metrics) Reset()
- func (m *Metrics) Size() (n int)
- func (this *Metrics) String() string
- func (m *Metrics) Unmarshal(dAtA []byte) error
- func (m *Metrics) XXX_DiscardUnknown()
- func (m *Metrics) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Metrics) XXX_Merge(src proto.Message)
- func (m *Metrics) XXX_Size() int
- func (m *Metrics) XXX_Unmarshal(b []byte) error
- type Pipeline
- func (in *Pipeline) DeepCopy() *Pipeline
- func (in *Pipeline) DeepCopyInto(out *Pipeline)
- func (in *Pipeline) DeepCopyObject() runtime.Object
- func (*Pipeline) Descriptor() ([]byte, []int)
- func (m *Pipeline) Marshal() (dAtA []byte, err error)
- func (m *Pipeline) MarshalTo(dAtA []byte) (int, error)
- func (m *Pipeline) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Pipeline) ProtoMessage()
- func (m *Pipeline) Reset()
- func (m *Pipeline) Size() (n int)
- func (this *Pipeline) String() string
- func (m *Pipeline) Unmarshal(dAtA []byte) error
- func (m *Pipeline) XXX_DiscardUnknown()
- func (m *Pipeline) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Pipeline) XXX_Merge(src proto.Message)
- func (m *Pipeline) XXX_Size() int
- func (m *Pipeline) XXX_Unmarshal(b []byte) error
- type PipelineList
- func (in *PipelineList) DeepCopy() *PipelineList
- func (in *PipelineList) DeepCopyInto(out *PipelineList)
- func (in *PipelineList) DeepCopyObject() runtime.Object
- func (*PipelineList) Descriptor() ([]byte, []int)
- func (m *PipelineList) Marshal() (dAtA []byte, err error)
- func (m *PipelineList) MarshalTo(dAtA []byte) (int, error)
- func (m *PipelineList) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PipelineList) ProtoMessage()
- func (m *PipelineList) Reset()
- func (m *PipelineList) Size() (n int)
- func (this *PipelineList) String() string
- func (m *PipelineList) Unmarshal(dAtA []byte) error
- func (m *PipelineList) XXX_DiscardUnknown()
- func (m *PipelineList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PipelineList) XXX_Merge(src proto.Message)
- func (m *PipelineList) XXX_Size() int
- func (m *PipelineList) XXX_Unmarshal(b []byte) error
- type PipelinePhase
- type PipelineSpec
- func (in *PipelineSpec) DeepCopy() *PipelineSpec
- func (in *PipelineSpec) DeepCopyInto(out *PipelineSpec)
- func (*PipelineSpec) Descriptor() ([]byte, []int)
- func (in *PipelineSpec) HasStep(name string) bool
- func (m *PipelineSpec) Marshal() (dAtA []byte, err error)
- func (m *PipelineSpec) MarshalTo(dAtA []byte) (int, error)
- func (m *PipelineSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PipelineSpec) ProtoMessage()
- func (m *PipelineSpec) Reset()
- func (m *PipelineSpec) Size() (n int)
- func (this *PipelineSpec) String() string
- func (m *PipelineSpec) Unmarshal(dAtA []byte) error
- func (m *PipelineSpec) XXX_DiscardUnknown()
- func (m *PipelineSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PipelineSpec) XXX_Merge(src proto.Message)
- func (m *PipelineSpec) XXX_Size() int
- func (m *PipelineSpec) XXX_Unmarshal(b []byte) error
- type PipelineStatus
- func (in *PipelineStatus) DeepCopy() *PipelineStatus
- func (in *PipelineStatus) DeepCopyInto(out *PipelineStatus)
- func (*PipelineStatus) Descriptor() ([]byte, []int)
- func (m *PipelineStatus) Marshal() (dAtA []byte, err error)
- func (m *PipelineStatus) MarshalTo(dAtA []byte) (int, error)
- func (m *PipelineStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PipelineStatus) ProtoMessage()
- func (m *PipelineStatus) Reset()
- func (m *PipelineStatus) Size() (n int)
- func (this *PipelineStatus) String() string
- func (m *PipelineStatus) Unmarshal(dAtA []byte) error
- func (m *PipelineStatus) XXX_DiscardUnknown()
- func (m *PipelineStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PipelineStatus) XXX_Merge(src proto.Message)
- func (m *PipelineStatus) XXX_Size() int
- func (m *PipelineStatus) XXX_Unmarshal(b []byte) error
- type Replicas
- func (in Replicas) Calculate(pending int) int
- func (in *Replicas) DeepCopy() *Replicas
- func (in *Replicas) DeepCopyInto(out *Replicas)
- func (*Replicas) Descriptor() ([]byte, []int)
- func (m *Replicas) Marshal() (dAtA []byte, err error)
- func (m *Replicas) MarshalTo(dAtA []byte) (int, error)
- func (m *Replicas) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Replicas) ProtoMessage()
- func (m *Replicas) Reset()
- func (m *Replicas) Size() (n int)
- func (this *Replicas) String() string
- func (m *Replicas) Unmarshal(dAtA []byte) error
- func (m *Replicas) XXX_DiscardUnknown()
- func (m *Replicas) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Replicas) XXX_Merge(src proto.Message)
- func (m *Replicas) XXX_Size() int
- func (m *Replicas) XXX_Unmarshal(b []byte) error
- type Runtime
- type STAN
- func (in *STAN) DeepCopy() *STAN
- func (in *STAN) DeepCopyInto(out *STAN)
- func (*STAN) Descriptor() ([]byte, []int)
- func (m *STAN) Marshal() (dAtA []byte, err error)
- func (m *STAN) MarshalTo(dAtA []byte) (int, error)
- func (m *STAN) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*STAN) ProtoMessage()
- func (m *STAN) Reset()
- func (m *STAN) Size() (n int)
- func (this *STAN) String() string
- func (m *STAN) Unmarshal(dAtA []byte) error
- func (m *STAN) XXX_DiscardUnknown()
- func (m *STAN) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *STAN) XXX_Merge(src proto.Message)
- func (m *STAN) XXX_Size() int
- func (m *STAN) XXX_Unmarshal(b []byte) error
- type Sink
- func (in *Sink) DeepCopy() *Sink
- func (in *Sink) DeepCopyInto(out *Sink)
- func (*Sink) Descriptor() ([]byte, []int)
- func (m *Sink) Marshal() (dAtA []byte, err error)
- func (m *Sink) MarshalTo(dAtA []byte) (int, error)
- func (m *Sink) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Sink) ProtoMessage()
- func (m *Sink) Reset()
- func (m *Sink) Size() (n int)
- func (this *Sink) String() string
- func (m *Sink) Unmarshal(dAtA []byte) error
- func (m *Sink) XXX_DiscardUnknown()
- func (m *Sink) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Sink) XXX_Merge(src proto.Message)
- func (m *Sink) XXX_Size() int
- func (m *Sink) XXX_Unmarshal(b []byte) error
- type SinkStatus
- func (in *SinkStatus) AnyErrors() bool
- func (in *SinkStatus) DeepCopy() *SinkStatus
- func (in *SinkStatus) DeepCopyInto(out *SinkStatus)
- func (*SinkStatus) Descriptor() ([]byte, []int)
- func (m *SinkStatus) Marshal() (dAtA []byte, err error)
- func (m *SinkStatus) MarshalTo(dAtA []byte) (int, error)
- func (m *SinkStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SinkStatus) ProtoMessage()
- func (m *SinkStatus) Reset()
- func (m *SinkStatus) Size() (n int)
- func (this *SinkStatus) String() string
- func (m *SinkStatus) Unmarshal(dAtA []byte) error
- func (m *SinkStatus) XXX_DiscardUnknown()
- func (m *SinkStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SinkStatus) XXX_Merge(src proto.Message)
- func (m *SinkStatus) XXX_Size() int
- func (m *SinkStatus) XXX_Unmarshal(b []byte) error
- type SinkStatuses
- func (in SinkStatuses) AnyErrors() bool
- func (in SinkStatuses) AnySunk() bool
- func (in SinkStatuses) DeepCopy() SinkStatuses
- func (in SinkStatuses) DeepCopyInto(out *SinkStatuses)
- func (in SinkStatuses) IncErrors(name string, replica int, err error)
- func (in SinkStatuses) Set(name string, replica int, msg string)
- type Source
- func (in *Source) DeepCopy() *Source
- func (in *Source) DeepCopyInto(out *Source)
- func (*Source) Descriptor() ([]byte, []int)
- func (m *Source) Marshal() (dAtA []byte, err error)
- func (m *Source) MarshalTo(dAtA []byte) (int, error)
- func (m *Source) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Source) ProtoMessage()
- func (m *Source) Reset()
- func (m *Source) Size() (n int)
- func (this *Source) String() string
- func (m *Source) Unmarshal(dAtA []byte) error
- func (m *Source) XXX_DiscardUnknown()
- func (m *Source) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Source) XXX_Merge(src proto.Message)
- func (m *Source) XXX_Size() int
- func (m *Source) XXX_Unmarshal(b []byte) error
- type SourceStatus
- func (in *SourceStatus) AnyErrors() bool
- func (in *SourceStatus) DeepCopy() *SourceStatus
- func (in *SourceStatus) DeepCopyInto(out *SourceStatus)
- func (*SourceStatus) Descriptor() ([]byte, []int)
- func (m *SourceStatus) Marshal() (dAtA []byte, err error)
- func (m *SourceStatus) MarshalTo(dAtA []byte) (int, error)
- func (m *SourceStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SourceStatus) ProtoMessage()
- func (m *SourceStatus) Reset()
- func (m *SourceStatus) Size() (n int)
- func (this *SourceStatus) String() string
- func (m *SourceStatus) Unmarshal(dAtA []byte) error
- func (m *SourceStatus) XXX_DiscardUnknown()
- func (m *SourceStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SourceStatus) XXX_Merge(src proto.Message)
- func (m *SourceStatus) XXX_Size() int
- func (m *SourceStatus) XXX_Unmarshal(b []byte) error
- type SourceStatuses
- func (in SourceStatuses) AnyErrors() bool
- func (in SourceStatuses) DeepCopy() SourceStatuses
- func (in SourceStatuses) DeepCopyInto(out *SourceStatuses)
- func (in SourceStatuses) GetPending() int
- func (in SourceStatuses) IncErrors(name string, replica int, err error)
- func (in SourceStatuses) Set(name string, replica int, msg string)
- func (in SourceStatuses) SetPending(name string, pending uint64)
- type Step
- func (in *Step) DeepCopy() *Step
- func (in *Step) DeepCopyInto(out *Step)
- func (in *Step) DeepCopyObject() runtime.Object
- func (*Step) Descriptor() ([]byte, []int)
- func (in *Step) GetTargetReplicas(scalingDelay, peekDelay time.Duration) int
- func (m *Step) Marshal() (dAtA []byte, err error)
- func (m *Step) MarshalTo(dAtA []byte) (int, error)
- func (m *Step) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Step) ProtoMessage()
- func (m *Step) Reset()
- func (m *Step) Size() (n int)
- func (this *Step) String() string
- func (m *Step) Unmarshal(dAtA []byte) error
- func (m *Step) XXX_DiscardUnknown()
- func (m *Step) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Step) XXX_Merge(src proto.Message)
- func (m *Step) XXX_Size() int
- func (m *Step) XXX_Unmarshal(b []byte) error
- type StepList
- func (in *StepList) DeepCopy() *StepList
- func (in *StepList) DeepCopyInto(out *StepList)
- func (in *StepList) DeepCopyObject() runtime.Object
- func (*StepList) Descriptor() ([]byte, []int)
- func (m *StepList) Marshal() (dAtA []byte, err error)
- func (m *StepList) MarshalTo(dAtA []byte) (int, error)
- func (m *StepList) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*StepList) ProtoMessage()
- func (m *StepList) Reset()
- func (m *StepList) Size() (n int)
- func (this *StepList) String() string
- func (m *StepList) Unmarshal(dAtA []byte) error
- func (m *StepList) XXX_DiscardUnknown()
- func (m *StepList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StepList) XXX_Merge(src proto.Message)
- func (m *StepList) XXX_Size() int
- func (m *StepList) XXX_Unmarshal(b []byte) error
- type StepPhase
- type StepPhaseMessage
- type StepSpec
- func (in *StepSpec) DeepCopy() *StepSpec
- func (in *StepSpec) DeepCopyInto(out *StepSpec)
- func (*StepSpec) Descriptor() ([]byte, []int)
- func (in *StepSpec) GetContainer(imageFormat, runnerImage string, policy corev1.PullPolicy, ...) corev1.Container
- func (in *StepSpec) GetIn() *Interface
- func (in *StepSpec) GetPodSpec(req GetPodSpecReq) corev1.PodSpec
- func (in *StepSpec) GetReplicas() Replicas
- func (m *StepSpec) Marshal() (dAtA []byte, err error)
- func (m *StepSpec) MarshalTo(dAtA []byte) (int, error)
- func (m *StepSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*StepSpec) ProtoMessage()
- func (m *StepSpec) Reset()
- func (m *StepSpec) Size() (n int)
- func (this *StepSpec) String() string
- func (m *StepSpec) Unmarshal(dAtA []byte) error
- func (m *StepSpec) XXX_DiscardUnknown()
- func (m *StepSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StepSpec) XXX_Merge(src proto.Message)
- func (m *StepSpec) XXX_Size() int
- func (m *StepSpec) XXX_Unmarshal(b []byte) error
- type StepStatus
- func (in *StepStatus) AnyErrors() bool
- func (in *StepStatus) DeepCopy() *StepStatus
- func (in *StepStatus) DeepCopyInto(out *StepStatus)
- func (*StepStatus) Descriptor() ([]byte, []int)
- func (m *StepStatus) GetLastScaledAt() time.Time
- func (m *StepStatus) GetReplicas() int
- func (m *StepStatus) GetSourceStatues() SourceStatuses
- func (m *StepStatus) Marshal() (dAtA []byte, err error)
- func (m *StepStatus) MarshalTo(dAtA []byte) (int, error)
- func (m *StepStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*StepStatus) ProtoMessage()
- func (m *StepStatus) Reset()
- func (m *StepStatus) Size() (n int)
- func (this *StepStatus) String() string
- func (m *StepStatus) Unmarshal(dAtA []byte) error
- func (m *StepStatus) XXX_DiscardUnknown()
- func (m *StepStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StepStatus) XXX_Merge(src proto.Message)
- func (m *StepStatus) XXX_Size() int
- func (m *StepStatus) XXX_Unmarshal(b []byte) error
- type Storage
- func (in *Storage) DeepCopy() *Storage
- func (in *Storage) DeepCopyInto(out *Storage)
- func (*Storage) Descriptor() ([]byte, []int)
- func (m *Storage) Marshal() (dAtA []byte, err error)
- func (m *Storage) MarshalTo(dAtA []byte) (int, error)
- func (m *Storage) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Storage) ProtoMessage()
- func (m *Storage) Reset()
- func (m *Storage) Size() (n int)
- func (this *Storage) String() string
- func (m *Storage) Unmarshal(dAtA []byte) error
- func (m *Storage) XXX_DiscardUnknown()
- func (m *Storage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Storage) XXX_Merge(src proto.Message)
- func (m *Storage) XXX_Size() int
- func (m *Storage) XXX_Unmarshal(b []byte) error
- type SubjectPrefix
- type TLS
- func (in *TLS) DeepCopy() *TLS
- func (in *TLS) DeepCopyInto(out *TLS)
- func (*TLS) Descriptor() ([]byte, []int)
- func (m *TLS) Marshal() (dAtA []byte, err error)
- func (m *TLS) MarshalTo(dAtA []byte) (int, error)
- func (m *TLS) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*TLS) ProtoMessage()
- func (m *TLS) Reset()
- func (m *TLS) Size() (n int)
- func (this *TLS) String() string
- func (m *TLS) Unmarshal(dAtA []byte) error
- func (m *TLS) XXX_DiscardUnknown()
- func (m *TLS) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TLS) XXX_Merge(src proto.Message)
- func (m *TLS) XXX_Size() int
- func (m *TLS) XXX_Unmarshal(b []byte) error
Constants ¶
const ( // conditions ConditionCompleted = "Completed" // the pipeline completed ConditionErrors = "Errors" // added if any step encounters an error ConditionRunning = "Running" // added if any step is currently running ConditionSunkMessages = "SunkMessages" // added if any messages have been written to a sink for any step ConditionTerminating = "Terminating" // added if any terminator step terminated // container names CtrInit = "init" CtrMain = "main" CtrSidecar = "sidecar" // env vars EnvImageFormat = "ARGO_DATAFLOW_IMAGE_FORMAT" // default "quay.io/argoproj/%s:latest" EnvInstaller = "ARGO_DATAFLOW_INSTALLER" // default "true" /* default { "nats-streaming": "docker.io/nats-streaming", "nats": "docker.io/nats", "quay.io/argoproj/dataflow-runner": "quay.io/argoproj/dataflow-runner", "solsson/kafka-initutils": "docker.io/solsson/kafka-initutils", "solsson/kafka": "docker.io/solsson/kafka" } */ EnvInstallerImages = "ARGO_DATAFLOW_INSTALLER_IMAGES" EnvNamespace = "ARGO_DATAFLOW_NAMESPACE" EnvPipelineName = "ARGO_DATAFLOW_PIPELINE_NAME" EnvReplica = "ARGO_DATAFLOW_REPLICA" EnvStepSpec = "ARGO_DATAFLOW_STEP_SPEC" EnvPeekDelay = "ARGO_DATAFLOW_PEEK_DELAY" // how long between peeking (default 4m) EnvPullPolicy = "ARGO_DATAFLOW_PULL_POLICY" // default "" EnvScalingDelay = "ARGO_DATAFLOW_SCALING_DELAY" // // how long to wait between any scaling events (including peeking) default "4m" EnvUpdateInterval = "ARGO_DATAFLOW_UPDATE_INTERVAL" // default "15s" // label/annotation keys KeyDefaultContainer = "kubectl.kubernetes.io/default-container" KeyPipelineName = "dataflow.argoproj.io/pipeline-name" KeyReplica = "dataflow.argoproj.io/replica" KeyStepName = "dataflow.argoproj.io/step-name" // the step name without pipeline name prefix KeyHash = "dataflow.argoproj.io/hash" // hash of the object // paths PathCheckout = "/var/run/argo-dataflow/checkout" PathFIFOIn = "/var/run/argo-dataflow/in" PathFIFOOut = "/var/run/argo-dataflow/out" PathGroups = "/var/run/argo-dataflow/groups" PathHandlerFile = "/var/run/argo-dataflow/handler" PathKill = "/var/run/argo-dataflow/kill" PathWorkingDir = "/var/run/argo-dataflow/wd" PathVarRun = "/var/run/argo-dataflow" )
Variables ¶
var ( ErrInvalidLengthGenerated = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowGenerated = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupGenerated = fmt.Errorf("proto: unexpected end of group") )
var ( // GroupVersion is group version used to register these objects GroupVersion = schema.GroupVersion{Group: "dataflow.argoproj.io", Version: "v1alpha1"} // SchemeBuilder is used to add go types to the GroupVersionKind scheme SchemeBuilder = &scheme.Builder{GroupVersion: GroupVersion} // AddToScheme adds the types in this group-version to the given scheme. AddToScheme = SchemeBuilder.AddToScheme PipelineGroupVersionResource = GroupVersion.WithResource("pipelines") PipelineGroupVersionKind = GroupVersion.WithKind("Pipeline") StepGroupVersionKind = GroupVersion.WithKind("Step") StepGroupVersionResource = GroupVersion.WithResource("steps") )
var ( SmallResourceRequirements = corev1.ResourceRequirements{ Limits: corev1.ResourceList{ "cpu": resource.MustParse("50m"), "memory": resource.MustParse("256Mi"), }, Requests: corev1.ResourceList{ "cpu": resource.MustParse("50m"), "memory": resource.MustParse("64Mi"), }, } LargeResourceRequirements = corev1.ResourceRequirements{ Limits: corev1.ResourceList{ "cpu": resource.MustParse("100m"), "memory": resource.MustParse("256Mi"), }, Requests: corev1.ResourceList{ "cpu": resource.MustParse("100m"), "memory": resource.MustParse("256Mi"), }, } )
var DefaultInterface = &Interface{HTTP: &HTTP{}}
var KeyKillCmd = func(x string) string { return fmt.Sprintf("dataflow.argoproj.io/kill-cmd.%s", x) }
Functions ¶
func RequeueAfter ¶
Types ¶
type Cat ¶
type Cat struct{}
func (*Cat) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Cat.
func (*Cat) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Cat) Descriptor ¶
func (*Cat) ProtoMessage ¶
func (*Cat) ProtoMessage()
func (*Cat) XXX_DiscardUnknown ¶
func (m *Cat) XXX_DiscardUnknown()
func (*Cat) XXX_Unmarshal ¶
type Container ¶
type Container struct { Image string `json:"image" protobuf:"bytes,1,opt,name=image"` VolumeMounts []corev1.VolumeMount `json:"volumeMounts,omitempty" protobuf:"bytes,5,rep,name=volumeMounts"` In *Interface `json:"in,omitempty" protobuf:"bytes,3,opt,name=in"` Command []string `json:"command,omitempty" protobuf:"bytes,6,rep,name=command"` Args []string `json:"args,omitempty" protobuf:"bytes,7,rep,name=args"` Env []corev1.EnvVar `json:"env,omitempty" protobuf:"bytes,8,rep,name=env"` }
func (*Container) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Container.
func (*Container) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Container) Descriptor ¶
func (*Container) MarshalToSizedBuffer ¶
func (*Container) ProtoMessage ¶
func (*Container) ProtoMessage()
func (*Container) XXX_DiscardUnknown ¶
func (m *Container) XXX_DiscardUnknown()
func (*Container) XXX_Marshal ¶
func (*Container) XXX_Unmarshal ¶
type Cron ¶
type Cron struct {
Schedule string `json:"schedule" protobuf:"bytes,1,opt,name=schedule"`
}
func (*Cron) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Cron.
func (*Cron) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Cron) Descriptor ¶
func (*Cron) ProtoMessage ¶
func (*Cron) ProtoMessage()
func (*Cron) XXX_DiscardUnknown ¶
func (m *Cron) XXX_DiscardUnknown()
func (*Cron) XXX_Unmarshal ¶
type Error ¶ added in v0.0.4
type Error struct { // +kubebuilder:validation:MaxLength=32 Message string `json:"message" protobuf:"bytes,1,opt,name=message"` Time metav1.Time `json:"time" protobuf:"bytes,2,opt,name=time"` }
func (*Error) DeepCopy ¶ added in v0.0.4
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Error.
func (*Error) DeepCopyInto ¶ added in v0.0.4
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Error) Descriptor ¶ added in v0.0.4
func (*Error) MarshalToSizedBuffer ¶ added in v0.0.4
func (*Error) ProtoMessage ¶ added in v0.0.4
func (*Error) ProtoMessage()
func (*Error) XXX_DiscardUnknown ¶ added in v0.0.4
func (m *Error) XXX_DiscardUnknown()
func (*Error) XXX_Marshal ¶ added in v0.0.4
func (*Error) XXX_Unmarshal ¶ added in v0.0.4
type GetPodSpecReq ¶ added in v0.0.4
type GetPodSpecReq struct { PipelineName string `protobuf:"bytes,1,opt,name=pipelineName"` Namespace string `protobuf:"bytes,2,opt,name=namespace"` Replica int32 `protobuf:"varint,3,opt,name=replica"` ImageFormat string `protobuf:"bytes,4,opt,name=imageFormat"` RunnerImage string `protobuf:"bytes,5,opt,name=runnerImage"` PullPolicy corev1.PullPolicy `protobuf:"bytes,6,opt,name=pullPolicy,casttype=k8s.io/api/core/v1.PullPolicy"` UpdateInterval time.Duration `protobuf:"varint,7,opt,name=updateInterval,casttype=time.Duration"` }
+kubebuilder:skipversion
func (*GetPodSpecReq) DeepCopy ¶ added in v0.0.4
func (in *GetPodSpecReq) DeepCopy() *GetPodSpecReq
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GetPodSpecReq.
func (*GetPodSpecReq) DeepCopyInto ¶ added in v0.0.4
func (in *GetPodSpecReq) DeepCopyInto(out *GetPodSpecReq)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*GetPodSpecReq) Descriptor ¶ added in v0.0.4
func (*GetPodSpecReq) Descriptor() ([]byte, []int)
func (*GetPodSpecReq) Marshal ¶ added in v0.0.4
func (m *GetPodSpecReq) Marshal() (dAtA []byte, err error)
func (*GetPodSpecReq) MarshalTo ¶ added in v0.0.4
func (m *GetPodSpecReq) MarshalTo(dAtA []byte) (int, error)
func (*GetPodSpecReq) MarshalToSizedBuffer ¶ added in v0.0.4
func (m *GetPodSpecReq) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GetPodSpecReq) ProtoMessage ¶ added in v0.0.4
func (*GetPodSpecReq) ProtoMessage()
func (*GetPodSpecReq) Reset ¶ added in v0.0.4
func (m *GetPodSpecReq) Reset()
func (*GetPodSpecReq) Size ¶ added in v0.0.4
func (m *GetPodSpecReq) Size() (n int)
func (*GetPodSpecReq) String ¶ added in v0.0.4
func (this *GetPodSpecReq) String() string
func (*GetPodSpecReq) Unmarshal ¶ added in v0.0.4
func (m *GetPodSpecReq) Unmarshal(dAtA []byte) error
func (*GetPodSpecReq) XXX_DiscardUnknown ¶ added in v0.0.4
func (m *GetPodSpecReq) XXX_DiscardUnknown()
func (*GetPodSpecReq) XXX_Marshal ¶ added in v0.0.4
func (m *GetPodSpecReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetPodSpecReq) XXX_Merge ¶ added in v0.0.4
func (m *GetPodSpecReq) XXX_Merge(src proto.Message)
func (*GetPodSpecReq) XXX_Size ¶ added in v0.0.4
func (m *GetPodSpecReq) XXX_Size() int
func (*GetPodSpecReq) XXX_Unmarshal ¶ added in v0.0.4
func (m *GetPodSpecReq) XXX_Unmarshal(b []byte) error
type Git ¶
type Git struct { Image string `json:"image" protobuf:"bytes,1,opt,name=image"` Command []string `json:"command,omitempty" protobuf:"bytes,6,rep,name=command"` URL string `json:"url" protobuf:"bytes,2,opt,name=url"` // +kubebuilder:default=. Path string `json:"path,omitempty" protobuf:"bytes,3,opt,name=path"` // +kubebuilder:default=main Branch string `json:"branch,omitempty" protobuf:"bytes,4,opt,name=branch"` Env []corev1.EnvVar `json:"env,omitempty" protobuf:"bytes,5,rep,name=env"` }
func (*Git) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Git.
func (*Git) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Git) Descriptor ¶
func (*Git) ProtoMessage ¶
func (*Git) ProtoMessage()
func (*Git) XXX_DiscardUnknown ¶
func (m *Git) XXX_DiscardUnknown()
func (*Git) XXX_Unmarshal ¶
type Group ¶
type Group struct { Key string `json:"key" protobuf:"bytes,1,opt,name=key"` EndOfGroup string `json:"endOfGroup" protobuf:"bytes,2,opt,name=endOfGroup"` Format GroupFormat `json:"format,omitempty" protobuf:"bytes,3,opt,name=format,casttype=GroupFormat"` Storage *Storage `json:"storage,omitempty" protobuf:"bytes,4,opt,name=storage"` }
func (*Group) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Group.
func (*Group) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Group) Descriptor ¶
func (*Group) ProtoMessage ¶
func (*Group) ProtoMessage()
func (*Group) XXX_DiscardUnknown ¶
func (m *Group) XXX_DiscardUnknown()
func (*Group) XXX_Marshal ¶
func (*Group) XXX_Unmarshal ¶
type GroupFormat ¶
type GroupFormat string
+kubebuilder:validation:Enum="";JSONBytesArray;JSONStringArray
const ( GroupFormatUnknown GroupFormat = "" // all messages are sent one by one - probably not what you want GroupFormatJSONBytesArray GroupFormat = "JSONBytesArray" // messages are sent as an array where each element is a base 64 encoded GroupFormatJSONStringArray GroupFormat = "JSONStringArray" // messages are sent as an array where each element is a string )
type HTTP ¶
type HTTP struct{}
func (*HTTP) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new HTTP.
func (*HTTP) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*HTTP) Descriptor ¶
func (*HTTP) ProtoMessage ¶
func (*HTTP) ProtoMessage()
func (*HTTP) XXX_DiscardUnknown ¶
func (m *HTTP) XXX_DiscardUnknown()
func (*HTTP) XXX_Unmarshal ¶
type Handler ¶
type Handler struct { Runtime Runtime `json:"runtime" protobuf:"bytes,4,opt,name=runtime,casttype=Runtime"` Code string `json:"code" protobuf:"bytes,3,opt,name=code"` }
func (*Handler) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Handler.
func (*Handler) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Handler) Descriptor ¶
func (*Handler) MarshalToSizedBuffer ¶
func (*Handler) ProtoMessage ¶
func (*Handler) ProtoMessage()
func (*Handler) XXX_DiscardUnknown ¶
func (m *Handler) XXX_DiscardUnknown()
func (*Handler) XXX_Marshal ¶
func (*Handler) XXX_Unmarshal ¶
type Interface ¶
type Interface struct { FIFO bool `json:"fifo,omitempty" protobuf:"varint,1,opt,name=fifo"` HTTP *HTTP `json:"http,omitempty" protobuf:"bytes,2,opt,name=http"` }
func (*Interface) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Interface.
func (*Interface) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Interface) Descriptor ¶
func (*Interface) MarshalToSizedBuffer ¶
func (*Interface) ProtoMessage ¶
func (*Interface) ProtoMessage()
func (*Interface) XXX_DiscardUnknown ¶
func (m *Interface) XXX_DiscardUnknown()
func (*Interface) XXX_Marshal ¶
func (*Interface) XXX_Unmarshal ¶
type Kafka ¶
type Kafka struct { // +kubebuilder:default=default Name string `json:"name,omitempty" protobuf:"bytes,1,opt,name=name"` Brokers []string `json:"brokers,omitempty" protobuf:"bytes,2,opt,name=brokers"` Topic string `json:"topic" protobuf:"bytes,3,opt,name=topic"` Version string `json:"version,omitempty" protobuf:"bytes,4,opt,name=version"` NET *KafkaNET `json:"net,omitempty" protobuf:"bytes,5,opt,name=net"` }
func (*Kafka) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Kafka.
func (*Kafka) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Kafka) Descriptor ¶
func (*Kafka) ProtoMessage ¶
func (*Kafka) ProtoMessage()
func (*Kafka) XXX_DiscardUnknown ¶
func (m *Kafka) XXX_DiscardUnknown()
func (*Kafka) XXX_Marshal ¶
func (*Kafka) XXX_Unmarshal ¶
type KafkaNET ¶
type KafkaNET struct {
TLS *TLS `json:"tls,omitempty" protobuf:"bytes,1,opt,name=tls"`
}
func (*KafkaNET) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KafkaNET.
func (*KafkaNET) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*KafkaNET) Descriptor ¶
func (*KafkaNET) MarshalToSizedBuffer ¶
func (*KafkaNET) ProtoMessage ¶
func (*KafkaNET) ProtoMessage()
func (*KafkaNET) XXX_DiscardUnknown ¶
func (m *KafkaNET) XXX_DiscardUnknown()
func (*KafkaNET) XXX_Marshal ¶
func (*KafkaNET) XXX_Unmarshal ¶
type Log ¶
type Log struct{}
func (*Log) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Log.
func (*Log) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Log) Descriptor ¶
func (*Log) ProtoMessage ¶
func (*Log) ProtoMessage()
func (*Log) XXX_DiscardUnknown ¶
func (m *Log) XXX_DiscardUnknown()
func (*Log) XXX_Unmarshal ¶
type Message ¶
type Message struct { // +kubebuilder:validation:MaxLength=32 Data string `json:"data" protobuf:"bytes,1,opt,name=data"` Time metav1.Time `json:"time" protobuf:"bytes,2,opt,name=time"` }
func (*Message) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Message.
func (*Message) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Message) Descriptor ¶
func (*Message) MarshalToSizedBuffer ¶
func (*Message) ProtoMessage ¶
func (*Message) ProtoMessage()
func (*Message) XXX_DiscardUnknown ¶
func (m *Message) XXX_DiscardUnknown()
func (*Message) XXX_Marshal ¶
func (*Message) XXX_Unmarshal ¶
type Metadata ¶
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"` }
func (*Metadata) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Metadata.
func (*Metadata) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Metadata) Descriptor ¶
func (*Metadata) MarshalToSizedBuffer ¶
func (*Metadata) ProtoMessage ¶
func (*Metadata) ProtoMessage()
func (*Metadata) XXX_DiscardUnknown ¶
func (m *Metadata) XXX_DiscardUnknown()
func (*Metadata) XXX_Marshal ¶
func (*Metadata) XXX_Unmarshal ¶
type Metrics ¶
type Metrics struct { Total uint64 `json:"total,omitempty" protobuf:"varint,1,opt,name=total"` Errors uint64 `json:"errors,omitempty" protobuf:"varint,5,opt,name=errors"` }
func (*Metrics) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Metrics.
func (*Metrics) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Metrics) Descriptor ¶
func (*Metrics) MarshalToSizedBuffer ¶
func (*Metrics) ProtoMessage ¶
func (*Metrics) ProtoMessage()
func (*Metrics) XXX_DiscardUnknown ¶
func (m *Metrics) XXX_DiscardUnknown()
func (*Metrics) XXX_Marshal ¶
func (*Metrics) XXX_Unmarshal ¶
type Pipeline ¶
type Pipeline struct { metav1.TypeMeta `json:",inline"` metav1.ObjectMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"` Spec PipelineSpec `json:"spec" protobuf:"bytes,2,opt,name=spec"` Status *PipelineStatus `json:"status,omitempty" protobuf:"bytes,3,opt,name=status"` }
+kubebuilder:object:root=true +kubebuilder:resource:shortName=pl +kubebuilder:subresource:status +kubebuilder:printcolumn:name="Phase",type=string,JSONPath=`.status.phase` +kubebuilder:printcolumn:name="Message",type=string,JSONPath=`.status.message`
func (*Pipeline) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Pipeline.
func (*Pipeline) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Pipeline) DeepCopyObject ¶
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*Pipeline) Descriptor ¶
func (*Pipeline) MarshalToSizedBuffer ¶
func (*Pipeline) ProtoMessage ¶
func (*Pipeline) ProtoMessage()
func (*Pipeline) XXX_DiscardUnknown ¶
func (m *Pipeline) XXX_DiscardUnknown()
func (*Pipeline) XXX_Marshal ¶
func (*Pipeline) XXX_Unmarshal ¶
type PipelineList ¶
type PipelineList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"` Items []Pipeline `json:"items" protobuf:"bytes,2,rep,name=items"` }
func (*PipelineList) DeepCopy ¶
func (in *PipelineList) DeepCopy() *PipelineList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PipelineList.
func (*PipelineList) DeepCopyInto ¶
func (in *PipelineList) DeepCopyInto(out *PipelineList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*PipelineList) DeepCopyObject ¶
func (in *PipelineList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*PipelineList) Descriptor ¶
func (*PipelineList) Descriptor() ([]byte, []int)
func (*PipelineList) Marshal ¶
func (m *PipelineList) Marshal() (dAtA []byte, err error)
func (*PipelineList) MarshalToSizedBuffer ¶
func (m *PipelineList) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PipelineList) ProtoMessage ¶
func (*PipelineList) ProtoMessage()
func (*PipelineList) Reset ¶
func (m *PipelineList) Reset()
func (*PipelineList) Size ¶
func (m *PipelineList) Size() (n int)
func (*PipelineList) String ¶
func (this *PipelineList) String() string
func (*PipelineList) Unmarshal ¶
func (m *PipelineList) Unmarshal(dAtA []byte) error
func (*PipelineList) XXX_DiscardUnknown ¶
func (m *PipelineList) XXX_DiscardUnknown()
func (*PipelineList) XXX_Marshal ¶
func (m *PipelineList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PipelineList) XXX_Merge ¶
func (m *PipelineList) XXX_Merge(src proto.Message)
func (*PipelineList) XXX_Size ¶
func (m *PipelineList) XXX_Size() int
func (*PipelineList) XXX_Unmarshal ¶
func (m *PipelineList) XXX_Unmarshal(b []byte) error
type PipelinePhase ¶
type PipelinePhase string
+kubebuilder:validation:Enum="";Pending;Running;Succeeded;Failed
const ( PipelineUnknown PipelinePhase = "" PipelinePending PipelinePhase = "Pending" PipelineRunning PipelinePhase = "Running" PipelineSucceeded PipelinePhase = "Succeeded" PipelineFailed PipelinePhase = "Failed" )
func MinPipelinePhase ¶
func MinPipelinePhase(v ...PipelinePhase) PipelinePhase
func (PipelinePhase) Completed ¶
func (p PipelinePhase) Completed() bool
type PipelineSpec ¶
type PipelineSpec struct { // +patchStrategy=merge // +patchMergeKey=name Steps []StepSpec `json:"steps,omitempty" protobuf:"bytes,1,rep,name=steps"` }
func (*PipelineSpec) DeepCopy ¶
func (in *PipelineSpec) DeepCopy() *PipelineSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PipelineSpec.
func (*PipelineSpec) DeepCopyInto ¶
func (in *PipelineSpec) DeepCopyInto(out *PipelineSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*PipelineSpec) Descriptor ¶
func (*PipelineSpec) Descriptor() ([]byte, []int)
func (*PipelineSpec) HasStep ¶
func (in *PipelineSpec) HasStep(name string) bool
func (*PipelineSpec) Marshal ¶
func (m *PipelineSpec) Marshal() (dAtA []byte, err error)
func (*PipelineSpec) MarshalToSizedBuffer ¶
func (m *PipelineSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PipelineSpec) ProtoMessage ¶
func (*PipelineSpec) ProtoMessage()
func (*PipelineSpec) Reset ¶
func (m *PipelineSpec) Reset()
func (*PipelineSpec) Size ¶
func (m *PipelineSpec) Size() (n int)
func (*PipelineSpec) String ¶
func (this *PipelineSpec) String() string
func (*PipelineSpec) Unmarshal ¶
func (m *PipelineSpec) Unmarshal(dAtA []byte) error
func (*PipelineSpec) XXX_DiscardUnknown ¶
func (m *PipelineSpec) XXX_DiscardUnknown()
func (*PipelineSpec) XXX_Marshal ¶
func (m *PipelineSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PipelineSpec) XXX_Merge ¶
func (m *PipelineSpec) XXX_Merge(src proto.Message)
func (*PipelineSpec) XXX_Size ¶
func (m *PipelineSpec) XXX_Size() int
func (*PipelineSpec) XXX_Unmarshal ¶
func (m *PipelineSpec) XXX_Unmarshal(b []byte) error
type PipelineStatus ¶
type PipelineStatus struct { Phase PipelinePhase `json:"phase,omitempty" protobuf:"bytes,1,opt,name=phase,casttype=PipelinePhase"` Message string `json:"message,omitempty" protobuf:"bytes,2,opt,name=message"` Conditions []metav1.Condition `json:"conditions,omitempty" protobuf:"bytes,3,rep,name=conditions"` }
func (*PipelineStatus) DeepCopy ¶
func (in *PipelineStatus) DeepCopy() *PipelineStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PipelineStatus.
func (*PipelineStatus) DeepCopyInto ¶
func (in *PipelineStatus) DeepCopyInto(out *PipelineStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*PipelineStatus) Descriptor ¶
func (*PipelineStatus) Descriptor() ([]byte, []int)
func (*PipelineStatus) Marshal ¶
func (m *PipelineStatus) Marshal() (dAtA []byte, err error)
func (*PipelineStatus) MarshalToSizedBuffer ¶
func (m *PipelineStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PipelineStatus) ProtoMessage ¶
func (*PipelineStatus) ProtoMessage()
func (*PipelineStatus) Reset ¶
func (m *PipelineStatus) Reset()
func (*PipelineStatus) Size ¶
func (m *PipelineStatus) Size() (n int)
func (*PipelineStatus) String ¶
func (this *PipelineStatus) String() string
func (*PipelineStatus) Unmarshal ¶
func (m *PipelineStatus) Unmarshal(dAtA []byte) error
func (*PipelineStatus) XXX_DiscardUnknown ¶
func (m *PipelineStatus) XXX_DiscardUnknown()
func (*PipelineStatus) XXX_Marshal ¶
func (m *PipelineStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PipelineStatus) XXX_Merge ¶
func (m *PipelineStatus) XXX_Merge(src proto.Message)
func (*PipelineStatus) XXX_Size ¶
func (m *PipelineStatus) XXX_Size() int
func (*PipelineStatus) XXX_Unmarshal ¶
func (m *PipelineStatus) XXX_Unmarshal(b []byte) error
type Replicas ¶
type Replicas struct { // +kubebuilder:default=1 Min int32 `json:"min" protobuf:"varint,1,opt,name=min"` // this is both the min, and the initial value Max *uint32 `json:"max,omitempty" protobuf:"varint,2,opt,name=max"` // takes precedence over min Ratio uint32 `json:"ratio,omitempty" protobuf:"bytes,3,opt,name=ratio"` }
Used to calculate the number of replicas. min(r.max, max(r.min, pending/ratio)) Example: min=1, max=4, ratio=100 pending=0, replicas=1 pending=100, replicas=1 pending=200, replicas=2 pending=300, replicas=3 pending=400, replicas=4 pending=500, replicas=4
func (*Replicas) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Replicas.
func (*Replicas) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Replicas) Descriptor ¶
func (*Replicas) MarshalToSizedBuffer ¶
func (*Replicas) ProtoMessage ¶
func (*Replicas) ProtoMessage()
func (*Replicas) XXX_DiscardUnknown ¶
func (m *Replicas) XXX_DiscardUnknown()
func (*Replicas) XXX_Marshal ¶
func (*Replicas) XXX_Unmarshal ¶
type STAN ¶
type STAN struct { // +kubebuilder:default=default Name string `json:"name,omitempty" protobuf:"bytes,1,opt,name=name"` NATSURL string `json:"natsUrl,omitempty" protobuf:"bytes,4,opt,name=natsUrl"` ClusterID string `json:"clusterId,omitempty" protobuf:"bytes,5,opt,name=clusterId"` Subject string `json:"subject" protobuf:"bytes,3,opt,name=subject"` SubjectPrefix SubjectPrefix `json:"subjectPrefix,omitempty" protobuf:"bytes,6,opt,name=subjectPrefix,casttype=SubjectPrefix"` }
func (*STAN) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new STAN.
func (*STAN) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*STAN) Descriptor ¶
func (*STAN) ProtoMessage ¶
func (*STAN) ProtoMessage()
func (*STAN) XXX_DiscardUnknown ¶
func (m *STAN) XXX_DiscardUnknown()
func (*STAN) XXX_Unmarshal ¶
type Sink ¶
type Sink struct { // +kubebuilder:default=default Name string `json:"name,omitempty" protobuf:"bytes,1,opt,name=name"` STAN *STAN `json:"stan,omitempty" protobuf:"bytes,2,opt,name=stan"` Kafka *Kafka `json:"kafka,omitempty" protobuf:"bytes,3,opt,name=kafka"` Log *Log `json:"log,omitempty" protobuf:"bytes,4,opt,name=log"` }
func (*Sink) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Sink.
func (*Sink) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Sink) Descriptor ¶
func (*Sink) ProtoMessage ¶
func (*Sink) ProtoMessage()
func (*Sink) XXX_DiscardUnknown ¶
func (m *Sink) XXX_DiscardUnknown()
func (*Sink) XXX_Unmarshal ¶
type SinkStatus ¶
type SinkStatus struct { LastMessage *Message `json:"lastMessage,omitempty" protobuf:"bytes,2,opt,name=lastMessage"` LastError *Error `json:"lastError,omitempty" protobuf:"bytes,4,opt,name=lastError"` Metrics map[string]Metrics `json:"metrics,omitempty" protobuf:"bytes,3,rep,name=metrics"` }
func (*SinkStatus) AnyErrors ¶
func (in *SinkStatus) AnyErrors() bool
func (*SinkStatus) DeepCopy ¶
func (in *SinkStatus) DeepCopy() *SinkStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SinkStatus.
func (*SinkStatus) DeepCopyInto ¶
func (in *SinkStatus) DeepCopyInto(out *SinkStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*SinkStatus) Descriptor ¶
func (*SinkStatus) Descriptor() ([]byte, []int)
func (*SinkStatus) Marshal ¶
func (m *SinkStatus) Marshal() (dAtA []byte, err error)
func (*SinkStatus) MarshalToSizedBuffer ¶
func (m *SinkStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SinkStatus) ProtoMessage ¶
func (*SinkStatus) ProtoMessage()
func (*SinkStatus) Reset ¶
func (m *SinkStatus) Reset()
func (*SinkStatus) Size ¶
func (m *SinkStatus) Size() (n int)
func (*SinkStatus) String ¶
func (this *SinkStatus) String() string
func (*SinkStatus) Unmarshal ¶
func (m *SinkStatus) Unmarshal(dAtA []byte) error
func (*SinkStatus) XXX_DiscardUnknown ¶
func (m *SinkStatus) XXX_DiscardUnknown()
func (*SinkStatus) XXX_Marshal ¶
func (m *SinkStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SinkStatus) XXX_Merge ¶
func (m *SinkStatus) XXX_Merge(src proto.Message)
func (*SinkStatus) XXX_Size ¶
func (m *SinkStatus) XXX_Size() int
func (*SinkStatus) XXX_Unmarshal ¶
func (m *SinkStatus) XXX_Unmarshal(b []byte) error
type SinkStatuses ¶
type SinkStatuses map[string]SinkStatus
func (SinkStatuses) AnyErrors ¶
func (in SinkStatuses) AnyErrors() bool
func (SinkStatuses) AnySunk ¶
func (in SinkStatuses) AnySunk() bool
func (SinkStatuses) DeepCopy ¶
func (in SinkStatuses) DeepCopy() SinkStatuses
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SinkStatuses.
func (SinkStatuses) DeepCopyInto ¶
func (in SinkStatuses) DeepCopyInto(out *SinkStatuses)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type Source ¶
type Source struct { // +kubebuilder:default=default Name string `json:"name,omitempty" protobuf:"bytes,1,opt,name=name"` Cron *Cron `json:"cron,omitempty" protobuf:"bytes,2,opt,name=cron"` STAN *STAN `json:"stan,omitempty" protobuf:"bytes,3,opt,name=stan"` Kafka *Kafka `json:"kafka,omitempty" protobuf:"bytes,4,opt,name=kafka"` }
func (*Source) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Source.
func (*Source) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Source) Descriptor ¶
func (*Source) MarshalToSizedBuffer ¶
func (*Source) ProtoMessage ¶
func (*Source) ProtoMessage()
func (*Source) XXX_DiscardUnknown ¶
func (m *Source) XXX_DiscardUnknown()
func (*Source) XXX_Marshal ¶
func (*Source) XXX_Unmarshal ¶
type SourceStatus ¶
type SourceStatus struct { LastMessage *Message `json:"lastMessage,omitempty" protobuf:"bytes,2,opt,name=lastMessage"` LastError *Error `json:"lastError,omitempty" protobuf:"bytes,5,opt,name=lastError"` Pending *uint64 `json:"pending,omitempty" protobuf:"varint,3,opt,name=pending"` Metrics map[string]Metrics `json:"metrics,omitempty" protobuf:"bytes,4,rep,name=metrics"` }
func (*SourceStatus) AnyErrors ¶
func (in *SourceStatus) AnyErrors() bool
func (*SourceStatus) DeepCopy ¶
func (in *SourceStatus) DeepCopy() *SourceStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SourceStatus.
func (*SourceStatus) DeepCopyInto ¶
func (in *SourceStatus) DeepCopyInto(out *SourceStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*SourceStatus) Descriptor ¶
func (*SourceStatus) Descriptor() ([]byte, []int)
func (*SourceStatus) Marshal ¶
func (m *SourceStatus) Marshal() (dAtA []byte, err error)
func (*SourceStatus) MarshalToSizedBuffer ¶
func (m *SourceStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SourceStatus) ProtoMessage ¶
func (*SourceStatus) ProtoMessage()
func (*SourceStatus) Reset ¶
func (m *SourceStatus) Reset()
func (*SourceStatus) Size ¶
func (m *SourceStatus) Size() (n int)
func (*SourceStatus) String ¶
func (this *SourceStatus) String() string
func (*SourceStatus) Unmarshal ¶
func (m *SourceStatus) Unmarshal(dAtA []byte) error
func (*SourceStatus) XXX_DiscardUnknown ¶
func (m *SourceStatus) XXX_DiscardUnknown()
func (*SourceStatus) XXX_Marshal ¶
func (m *SourceStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SourceStatus) XXX_Merge ¶
func (m *SourceStatus) XXX_Merge(src proto.Message)
func (*SourceStatus) XXX_Size ¶
func (m *SourceStatus) XXX_Size() int
func (*SourceStatus) XXX_Unmarshal ¶
func (m *SourceStatus) XXX_Unmarshal(b []byte) error
type SourceStatuses ¶
type SourceStatuses map[string]SourceStatus
func (SourceStatuses) AnyErrors ¶
func (in SourceStatuses) AnyErrors() bool
func (SourceStatuses) DeepCopy ¶
func (in SourceStatuses) DeepCopy() SourceStatuses
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SourceStatuses.
func (SourceStatuses) DeepCopyInto ¶
func (in SourceStatuses) DeepCopyInto(out *SourceStatuses)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (SourceStatuses) GetPending ¶
func (in SourceStatuses) GetPending() int
func (SourceStatuses) IncErrors ¶
func (in SourceStatuses) IncErrors(name string, replica int, err error)
func (SourceStatuses) SetPending ¶
func (in SourceStatuses) SetPending(name string, pending uint64)
type Step ¶
type Step struct { metav1.TypeMeta `json:",inline"` metav1.ObjectMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"` Spec StepSpec `json:"spec" protobuf:"bytes,2,opt,name=spec"` Status *StepStatus `json:"status,omitempty" protobuf:"bytes,3,opt,name=status"` }
+kubebuilder:object:root=true +kubebuilder:subresource:status +kubebuilder:printcolumn:name="Phase",type=string,JSONPath=`.status.phase` +kubebuilder:printcolumn:name="Message",type=string,JSONPath=`.status.message` +kubebuilder:printcolumn:name="Replicas",type=string,JSONPath=`.status.replicas`
func (*Step) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Step.
func (*Step) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Step) DeepCopyObject ¶
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*Step) Descriptor ¶
func (*Step) GetTargetReplicas ¶
func (*Step) ProtoMessage ¶
func (*Step) ProtoMessage()
func (*Step) XXX_DiscardUnknown ¶
func (m *Step) XXX_DiscardUnknown()
func (*Step) XXX_Unmarshal ¶
type StepList ¶
type StepList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"` Items []Step `json:"items" protobuf:"bytes,2,rep,name=items"` }
func (*StepList) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StepList.
func (*StepList) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*StepList) DeepCopyObject ¶
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*StepList) Descriptor ¶
func (*StepList) MarshalToSizedBuffer ¶
func (*StepList) ProtoMessage ¶
func (*StepList) ProtoMessage()
func (*StepList) XXX_DiscardUnknown ¶
func (m *StepList) XXX_DiscardUnknown()
func (*StepList) XXX_Marshal ¶
func (*StepList) XXX_Unmarshal ¶
type StepPhase ¶
type StepPhase string
+kubebuilder:validation:Enum="";Pending;Running;Succeeded;Failed
type StepPhaseMessage ¶
type StepPhaseMessage string
func MinStepPhaseMessage ¶
func MinStepPhaseMessage(v ...StepPhaseMessage) StepPhaseMessage
func NewStepPhaseMessage ¶
func NewStepPhaseMessage(p StepPhase, m string) StepPhaseMessage
func (StepPhaseMessage) GetMessage ¶
func (m StepPhaseMessage) GetMessage() string
func (StepPhaseMessage) GetPhase ¶
func (m StepPhaseMessage) GetPhase() StepPhase
type StepSpec ¶
type StepSpec struct { // +kubebuilder:default=default Name string `json:"name" protobuf:"bytes,6,opt,name=name"` Cat *Cat `json:"cat,omitempty" protobuf:"bytes,15,opt,name=cat"` Container *Container `json:"container,omitempty" protobuf:"bytes,1,opt,name=container"` Handler *Handler `json:"handler,omitempty" protobuf:"bytes,7,opt,name=handler"` Git *Git `json:"git,omitempty" protobuf:"bytes,12,opt,name=git"` Filter Filter `json:"filter,omitempty" protobuf:"bytes,8,opt,name=filter,casttype=Filter"` Map Map `json:"map,omitempty" protobuf:"bytes,9,opt,name=map,casttype=Map"` Group *Group `json:"group,omitempty" protobuf:"bytes,11,opt,name=group"` Replicas *Replicas `json:"replicas,omitempty" protobuf:"bytes,2,opt,name=replicas"` // +patchStrategy=merge // +patchMergeKey=name Sources []Source `json:"sources,omitempty" protobuf:"bytes,3,rep,name=sources"` // +patchStrategy=merge // +patchMergeKey=name Sinks []Sink `json:"sinks,omitempty" protobuf:"bytes,4,rep,name=sinks"` // +kubebuilder:default=OnFailure RestartPolicy corev1.RestartPolicy `json:"restartPolicy,omitempty" protobuf:"bytes,5,opt,name=restartPolicy,casttype=k8s.io/api/core/v1.RestartPolicy"` Terminator bool `json:"terminator,omitempty" protobuf:"varint,10,opt,name=terminator"` // if this step terminates, terminate all steps in the pipeline // +patchStrategy=merge // +patchMergeKey=name Volumes []corev1.Volume `json:"volumes,omitempty" protobuf:"bytes,13,rep,name=volumes"` // +kubebuilder:default=pipeline ServiceAccountName string `json:"serviceAccountName,omitempty" protobuf:"bytes,14,opt,name=serviceAccountName"` Metadata *Metadata `json:"metadata,omitempty" protobuf:"bytes,16,opt,name=metadata"` NodeSelector map[string]string `json:"nodeSelector,omitempty" protobuf:"bytes,17,rep,name=nodeSelector"` Affinity *corev1.Affinity `json:"affinity,omitempty" protobuf:"bytes,18,opt,name=affinity"` Tolerations []corev1.Toleration `json:"tolerations,omitempty" protobuf:"bytes,19,rep,name=tolerations"` }
func (*StepSpec) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StepSpec.
func (*StepSpec) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*StepSpec) Descriptor ¶
func (*StepSpec) GetContainer ¶
func (in *StepSpec) GetContainer(imageFormat, runnerImage string, policy corev1.PullPolicy, mnt corev1.VolumeMount) corev1.Container
func (*StepSpec) GetPodSpec ¶
func (in *StepSpec) GetPodSpec(req GetPodSpecReq) corev1.PodSpec
func (*StepSpec) GetReplicas ¶
func (*StepSpec) MarshalToSizedBuffer ¶
func (*StepSpec) ProtoMessage ¶
func (*StepSpec) ProtoMessage()
func (*StepSpec) XXX_DiscardUnknown ¶
func (m *StepSpec) XXX_DiscardUnknown()
func (*StepSpec) XXX_Marshal ¶
func (*StepSpec) XXX_Unmarshal ¶
type StepStatus ¶
type StepStatus struct { Phase StepPhase `json:"phase" protobuf:"bytes,1,opt,name=phase,casttype=StepPhase"` Message string `json:"message,omitempty" protobuf:"bytes,2,opt,name=message"` Replicas uint32 `json:"replicas" protobuf:"varint,5,opt,name=replicas"` LastScaledAt *metav1.Time `json:"lastScaledAt,omitempty" protobuf:"bytes,6,opt,name=lastScaledAt"` SourceStatues SourceStatuses `json:"sourceStatuses,omitempty" protobuf:"bytes,3,rep,name=sourceStatuses"` SinkStatues SinkStatuses `json:"sinkStatuses,omitempty" protobuf:"bytes,4,rep,name=sinkStatuses"` }
func (*StepStatus) AnyErrors ¶
func (in *StepStatus) AnyErrors() bool
func (*StepStatus) DeepCopy ¶
func (in *StepStatus) DeepCopy() *StepStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StepStatus.
func (*StepStatus) DeepCopyInto ¶
func (in *StepStatus) DeepCopyInto(out *StepStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*StepStatus) Descriptor ¶
func (*StepStatus) Descriptor() ([]byte, []int)
func (*StepStatus) GetLastScaledAt ¶
func (m *StepStatus) GetLastScaledAt() time.Time
func (*StepStatus) GetReplicas ¶
func (m *StepStatus) GetReplicas() int
func (*StepStatus) GetSourceStatues ¶
func (m *StepStatus) GetSourceStatues() SourceStatuses
func (*StepStatus) Marshal ¶
func (m *StepStatus) Marshal() (dAtA []byte, err error)
func (*StepStatus) MarshalToSizedBuffer ¶
func (m *StepStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*StepStatus) ProtoMessage ¶
func (*StepStatus) ProtoMessage()
func (*StepStatus) Reset ¶
func (m *StepStatus) Reset()
func (*StepStatus) Size ¶
func (m *StepStatus) Size() (n int)
func (*StepStatus) String ¶
func (this *StepStatus) String() string
func (*StepStatus) Unmarshal ¶
func (m *StepStatus) Unmarshal(dAtA []byte) error
func (*StepStatus) XXX_DiscardUnknown ¶
func (m *StepStatus) XXX_DiscardUnknown()
func (*StepStatus) XXX_Marshal ¶
func (m *StepStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StepStatus) XXX_Merge ¶
func (m *StepStatus) XXX_Merge(src proto.Message)
func (*StepStatus) XXX_Size ¶
func (m *StepStatus) XXX_Size() int
func (*StepStatus) XXX_Unmarshal ¶
func (m *StepStatus) XXX_Unmarshal(b []byte) error
type Storage ¶
type Storage struct { Name string `json:"name" protobuf:"bytes,1,opt,name=name"` // volume name SubPath string `json:"subPath,omitempty" protobuf:"bytes,2,opt,name=subPath"` }
func (*Storage) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Storage.
func (*Storage) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Storage) Descriptor ¶
func (*Storage) MarshalToSizedBuffer ¶
func (*Storage) ProtoMessage ¶
func (*Storage) ProtoMessage()
func (*Storage) XXX_DiscardUnknown ¶
func (m *Storage) XXX_DiscardUnknown()
func (*Storage) XXX_Marshal ¶
func (*Storage) XXX_Unmarshal ¶
type SubjectPrefix ¶
type SubjectPrefix string
+kubebuilder:validation:Enum="";None;NamespaceName;NamespacedPipelineName
const ( SubjectPrefixNone SubjectPrefix = "None" SubjectPrefixNamespaceName SubjectPrefix = "NamespaceName" SubjectPrefixNamespacedPipelineName SubjectPrefix = "NamespacedPipelineName" )
func SubjectPrefixOr ¶
func SubjectPrefixOr(a, b SubjectPrefix) SubjectPrefix
type TLS ¶
type TLS struct{}
func (*TLS) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TLS.
func (*TLS) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*TLS) Descriptor ¶
func (*TLS) ProtoMessage ¶
func (*TLS) ProtoMessage()
func (*TLS) XXX_DiscardUnknown ¶
func (m *TLS) XXX_DiscardUnknown()
func (*TLS) XXX_Unmarshal ¶
Source Files ¶
- cat.go
- const.go
- container.go
- container_supplier.go
- cron.go
- error.go
- filter.go
- generated.pb.go
- git.go
- group.go
- group_format.go
- groupversion_info.go
- handler.go
- http.go
- interface.go
- kafka.go
- log.go
- map.go
- message.go
- metadata.go
- metrics.go
- pipeline_phase.go
- pipeline_spec.go
- pipeline_status.go
- pipeline_types.go
- replicas.go
- resources.go
- runtime.go
- sink.go
- sink_status.go
- sink_statuses.go
- source.go
- source_status.go
- source_statuses.go
- stan.go
- step_phase.go
- step_phase_message.go
- step_spec.go
- step_status.go
- step_types.go
- string.go
- subject_prefix.go
- tls.go
- trunc.go
- zz_generated.deepcopy.go