v1alpha1

Dec 6, 2021

Changes in this version

type KafkaSink

+ MaxInflight uint32

+ MessageTimeout *metav1.Duration

+ func (m *KafkaSink) GetMessageInflight() int

+ func (m *KafkaSink) GetMessageTimeoutMs() int

Nov 19, 2021

Changes in this version

type Git

+ InsecureIgnoreHostKey bool

Nov 1, 2021

Changes in this version

type Code

+ Image string

Oct 25, 2021

Changes in this version

type KafkaSource

+ GroupID string

+ func (m *KafkaSource) GetGroupID(defaultGroupID string) string

Oct 21, 2021

Changes in this version

type Sink

+ DeadLetterQueue bool

Oct 7, 2021

Changes in this version

type KafkaSink

+ EnableIdempotence bool

Oct 7, 2021

Changes in this version

+ type JetStream struct

+ Auth *NATSAuth

+ NATSURL string

+ Name string

+ Subject string

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

+ func (*JetStream) ProtoMessage()

+ func (in *JetStream) DeepCopy() *JetStream

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

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

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

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

+ func (m *JetStream) Reset()

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

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

+ func (m *JetStream) XXX_DiscardUnknown()

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

+ func (m *JetStream) XXX_Merge(src proto.Message)

+ func (m *JetStream) XXX_Size() int

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

+ func (this *JetStream) String() string

+ type JetStreamSink struct

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

+ func (*JetStreamSink) ProtoMessage()

+ func (in *JetStreamSink) DeepCopy() *JetStreamSink

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

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

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

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

+ func (m *JetStreamSink) Reset()

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

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

+ func (m *JetStreamSink) XXX_DiscardUnknown()

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

+ func (m *JetStreamSink) XXX_Merge(src proto.Message)

+ func (m *JetStreamSink) XXX_Size() int

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

+ func (this *JetStreamSink) String() string

+ type JetStreamSource struct

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

+ func (*JetStreamSource) ProtoMessage()

+ func (in *JetStreamSource) DeepCopy() *JetStreamSource

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

+ func (j JetStreamSource) GenURN(cluster, namespace string) string

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

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

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

+ func (m *JetStreamSource) Reset()

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

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

+ func (m *JetStreamSource) XXX_DiscardUnknown()

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

+ func (m *JetStreamSource) XXX_Merge(src proto.Message)

+ func (m *JetStreamSource) XXX_Size() int

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

+ func (this *JetStreamSource) String() string

type KafkaConfig

+ func (m *KafkaConfig) GetMessageMaxBytes() int

+ type NATSAuth struct

+ Token *corev1.SecretKeySelector

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

+ func (*NATSAuth) ProtoMessage()

+ func (in *NATSAuth) DeepCopy() *NATSAuth

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

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

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

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

+ func (m *NATSAuth) Reset()

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

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

+ func (m *NATSAuth) XXX_DiscardUnknown()

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

+ func (m *NATSAuth) XXX_Merge(src proto.Message)

+ func (m *NATSAuth) XXX_Size() int

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

+ func (this *NATSAuth) String() string

+ type NATSAuthStrategy string

+ var NATSAuthNone NATSAuthStrategy = "None"

+ var NATSAuthToken NATSAuthStrategy = "Token"

type Sink

+ JetStream *JetStreamSink

type Source

+ JetStream *JetStreamSource

Oct 5, 2021

Changes in this version

type KafkaOffset

+ func (k KafkaOffset) GetAutoOffsetReset() string

type KafkaSink

+ Acks *intstr.IntOrString

+ BatchSize *resource.Quantity

+ CompressionType string

+ Linger *metav1.Duration

+ func (m *KafkaSink) GetAcks() interface{}

+ func (m *KafkaSink) GetBatchSize() int

+ func (m *KafkaSink) GetLingerMs() int

+ func (m *KafkaSink) GetMessageMaxBytes() int

type KafkaSource

+ FetchMin *resource.Quantity

+ FetchWaitMax *metav1.Duration

+ func (m *KafkaSource) GetAutoOffsetReset() string

+ func (m *KafkaSource) GetFetchMinBytes() int

+ func (m *KafkaSource) GetFetchWaitMaxMs() int

Oct 1, 2021

Changes in this version

type KafkaNET

+ func (in *KafkaNET) GetSecurityProtocol() string

Sep 28, 2021

Changes in this version

+ type Meta struct

+ ID string

+ Source string

+ Time int64

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

+ func (*Meta) ProtoMessage()

+ func (in *Meta) DeepCopy() *Meta

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

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

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

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

+ func (m *Meta) Reset()

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

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

+ func (m *Meta) XXX_DiscardUnknown()

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

+ func (m *Meta) XXX_Merge(src proto.Message)

+ func (m *Meta) XXX_Size() int

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

+ func (this *Meta) String() string

Sep 16, 2021

Changes in this version

+ const EnvUnixDomainSocket

Sep 16, 2021

Changes in this version

+ const EnvCluster

+ const EnvPod

+ var MetaID = meta

+ var MetaSource = meta

+ var MetaTime = meta

+ func ContextWithMeta(ctx context.Context, source, id string, time time.Time) context.Context

+ func MetaExtract(ctx context.Context, h http.Header) context.Context

+ func MetaFromContext(ctx context.Context) (source, id string, t time.Time, err error)

+ func MetaInject(ctx context.Context, h http.Header) error

+ type AbstractVolumeSource corev1.VolumeSource

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

+ func (*AbstractVolumeSource) ProtoMessage()

+ func (in *AbstractVolumeSource) DeepCopy() *AbstractVolumeSource

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

+ func (in AbstractVolumeSource) GenURN(cluster, namespace string) string

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

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

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

+ func (m *AbstractVolumeSource) Reset()

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

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

+ func (m *AbstractVolumeSource) XXX_DiscardUnknown()

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

+ func (m *AbstractVolumeSource) XXX_Merge(src proto.Message)

+ func (m *AbstractVolumeSource) XXX_Size() int

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

+ func (this *AbstractVolumeSource) String() string

type Cron

+ func (in Cron) GenURN(cluster, namespace string) string

type Database

+ func (in Database) GenURN(cluster, namespace string) string

type GetPodSpecReq

+ Cluster string

+ Hostname string

+ Subdomain string

type HTTPSource

+ func (in HTTPSource) GenURN(cluster, namespace string) string

type Kafka

+ func (in Kafka) GenURN(cluster, namespace string) string

type S3

+ func (in S3) GenURN(cluster, namespace string) string

type STAN

+ func (s STAN) GenURN(cluster, namespace string) string

type Source

+ func (s Source) GenURN(cluster, namespace string) string

type Step

+ func (in Step) GetHeadlessServiceName(pipelineName string) string

+ func (in Step) GetServiceObj(serviceName, pipelineName string, isHeadless bool) *corev1.Service

Sep 8, 2021

Changes in this version

type HTTPSink

+ InsecureSkipVerify bool

Sep 2, 2021

Changes in this version

+ type AbstractStep struct

+ Resources corev1.ResourceRequirements

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

+ func (*AbstractStep) ProtoMessage()

+ func (in *AbstractStep) DeepCopy() *AbstractStep

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

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

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

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

+ func (m *AbstractStep) Reset()

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

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

+ func (m *AbstractStep) XXX_DiscardUnknown()

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

+ func (m *AbstractStep) XXX_Merge(src proto.Message)

+ func (m *AbstractStep) XXX_Size() int

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

+ func (this *AbstractStep) String() string

+ type KafkaAutoCommit struct

+ Enable bool

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

+ func (*KafkaAutoCommit) ProtoMessage()

+ func (in *KafkaAutoCommit) DeepCopy() *KafkaAutoCommit

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

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

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

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

+ func (m *KafkaAutoCommit) Reset()

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

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

+ func (m *KafkaAutoCommit) XXX_DiscardUnknown()

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

+ func (m *KafkaAutoCommit) XXX_Merge(src proto.Message)

+ func (m *KafkaAutoCommit) XXX_Size() int

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

+ func (this *KafkaAutoCommit) String() string

type KafkaConfig

+ MaxMessageBytes int32

type KafkaSource

+ AutoCommit KafkaAutoCommit

Aug 30, 2021

Changes in this version

type AWSCredentials

+ SessionToken corev1.SecretKeySelector

Aug 30, 2021

Changes in this version

type Filter

+ Expression string

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

+ func (*Filter) ProtoMessage()

+ func (in *Filter) DeepCopy() *Filter

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

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

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

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

+ func (m *Filter) Reset()

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

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

+ func (m *Filter) XXX_DiscardUnknown()

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

+ func (m *Filter) XXX_Merge(src proto.Message)

+ func (m *Filter) XXX_Size() int

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

+ func (this *Filter) String() string

type Map

+ Expression string

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

+ func (*Map) ProtoMessage()

+ func (in *Map) DeepCopy() *Map

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

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

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

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

+ func (m *Map) Reset()

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

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

+ func (m *Map) XXX_DiscardUnknown()

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

+ func (m *Map) XXX_Merge(src proto.Message)

+ func (m *Map) XXX_Size() int

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

+ func (this *Map) String() string

Aug 19, 2021

Changes in this version

type Metrics

+ TotalBytes uint64

type SourceStatus

+ func (in SourceStatus) GetTotalBytes() uint64

type SourceStatuses

+ func (in SourceStatuses) GetTotalBytes() uint64

Aug 18, 2021

Changes in this version

type S3Source

+ Concurrency uint32

type Sink

+ Volume *VolumeSink

type Source

+ Volume *VolumeSource

+ type VolumeSink corev1.VolumeSource

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

+ func (*VolumeSink) ProtoMessage()

+ func (in *VolumeSink) DeepCopy() *VolumeSink

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

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

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

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

+ func (m *VolumeSink) Reset()

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

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

+ func (m *VolumeSink) XXX_DiscardUnknown()

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

+ func (m *VolumeSink) XXX_Merge(src proto.Message)

+ func (m *VolumeSink) XXX_Size() int

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

+ func (this *VolumeSink) String() string

+ type VolumeSource struct

+ Concurrency uint32

+ PollPeriod *metav1.Duration

+ ReadOnly bool

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

+ func (*VolumeSource) ProtoMessage()

+ func (in *VolumeSource) DeepCopy() *VolumeSource

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

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

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

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

+ func (m *VolumeSource) Reset()

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

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

+ func (m *VolumeSource) XXX_DiscardUnknown()

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

+ func (m *VolumeSource) XXX_Merge(src proto.Message)

+ func (m *VolumeSource) XXX_Size() int

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

+ func (this *VolumeSource) String() string

Aug 16, 2021

Changes in this version

type PipelineSpec

+ DeletionDelay *metav1.Duration

type Scale

+ DesiredReplicas string

+ PeekDelay string

+ ScalingDelay string

type SourceStatus

+ LastPending *uint64

+ func (in SourceStatus) GetLeaderTotal() uint64

type SourceStatuses

+ func (in SourceStatuses) GetLastPending() uint64

Aug 12, 2021

Changes in this version

+ const EnvClusterName

+ const EnvDebug

+ const EnvImagePullSecrets

+ const PathAuthorization

type Backoff

+ Duration metav1.Duration

+ FactorPercentage uint32

+ type DBDataSource struct

+ Value string

+ ValueFrom *DBDataSourceFrom

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

+ func (*DBDataSource) ProtoMessage()

+ func (in *DBDataSource) DeepCopy() *DBDataSource

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

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

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

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

+ func (m *DBDataSource) Reset()

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

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

+ func (m *DBDataSource) XXX_DiscardUnknown()

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

+ func (m *DBDataSource) XXX_Merge(src proto.Message)

+ func (m *DBDataSource) XXX_Size() int

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

+ func (this *DBDataSource) String() string

+ type DBDataSourceFrom struct

+ SecretKeyRef *corev1.SecretKeySelector

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

+ func (*DBDataSourceFrom) ProtoMessage()

+ func (in *DBDataSourceFrom) DeepCopy() *DBDataSourceFrom

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

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

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

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

+ func (m *DBDataSourceFrom) Reset()

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

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

+ func (m *DBDataSourceFrom) XXX_DiscardUnknown()

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

+ func (m *DBDataSourceFrom) XXX_Merge(src proto.Message)

+ func (m *DBDataSourceFrom) XXX_Size() int

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

+ func (this *DBDataSourceFrom) String() string

+ type DBSink struct

+ Actions []SQLAction

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

+ func (*DBSink) ProtoMessage()

+ func (in *DBSink) DeepCopy() *DBSink

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

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

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

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

+ func (m *DBSink) Reset()

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

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

+ func (m *DBSink) XXX_DiscardUnknown()

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

+ func (m *DBSink) XXX_Merge(src proto.Message)

+ func (m *DBSink) XXX_Size() int

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

+ func (this *DBSink) String() string

+ type DBSource struct

+ CommitInterval metav1.Duration

+ InitSchema bool

+ OffsetColumn string

+ PollInterval metav1.Duration

+ Query string

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

+ func (*DBSource) ProtoMessage()

+ func (in *DBSource) DeepCopy() *DBSource

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

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

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

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

+ func (m *DBSource) Reset()

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

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

+ func (m *DBSource) XXX_DiscardUnknown()

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

+ func (m *DBSource) XXX_Merge(src proto.Message)

+ func (m *DBSource) XXX_Size() int

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

+ func (this *DBSource) String() string

+ type Database struct

+ DataSource *DBDataSource

+ Driver string

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

+ func (*Database) ProtoMessage()

+ func (in *Database) DeepCopy() *Database

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

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

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

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

+ func (m *Database) Reset()

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

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

+ func (m *Database) XXX_DiscardUnknown()

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

+ func (m *Database) XXX_Merge(src proto.Message)

+ func (m *Database) XXX_Size() int

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

+ func (this *Database) String() string

type GetPodSpecReq

+ ClusterName string

+ Debug bool

+ ImagePullSecrets []corev1.LocalObjectReference

+ Sidecar Sidecar

type Git

+ PasswordSecret *corev1.SecretKeySelector

+ SSHPrivateKeySecret *corev1.SecretKeySelector

+ UsernameSecret *corev1.SecretKeySelector

+ type KafkaConfig struct

+ Brokers []string

+ NET *KafkaNET

+ Version string

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

+ func (*KafkaConfig) ProtoMessage()

+ func (in *KafkaConfig) DeepCopy() *KafkaConfig

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

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

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

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

+ func (m *KafkaConfig) Reset()

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

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

+ func (m *KafkaConfig) XXX_DiscardUnknown()

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

+ func (m *KafkaConfig) XXX_Merge(src proto.Message)

+ func (m *KafkaConfig) XXX_Size() int

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

+ func (this *KafkaConfig) String() string

+ type KafkaSink struct

+ Async bool

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

+ func (*KafkaSink) ProtoMessage()

+ func (in *KafkaSink) DeepCopy() *KafkaSink

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

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

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

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

+ func (m *KafkaSink) Reset()

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

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

+ func (m *KafkaSink) XXX_DiscardUnknown()

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

+ func (m *KafkaSink) XXX_Merge(src proto.Message)

+ func (m *KafkaSink) XXX_Size() int

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

+ func (this *KafkaSink) String() string

type Log

+ Truncate *uint64

+ type SQLAction struct

+ OnError *SQLStatement

+ OnRecordNotFound *SQLStatement

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

+ func (*SQLAction) ProtoMessage()

+ func (in *SQLAction) DeepCopy() *SQLAction

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

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

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

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

+ func (m *SQLAction) Reset()

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

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

+ func (m *SQLAction) XXX_DiscardUnknown()

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

+ func (m *SQLAction) XXX_Merge(src proto.Message)

+ func (m *SQLAction) XXX_Size() int

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

+ func (this *SQLAction) String() string

+ type SQLStatement struct

+ Args []string

+ SQL string

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

+ func (*SQLStatement) ProtoMessage()

+ func (in *SQLStatement) DeepCopy() *SQLStatement

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

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

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

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

+ func (m *SQLStatement) Reset()

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

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

+ func (m *SQLStatement) XXX_DiscardUnknown()

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

+ func (m *SQLStatement) XXX_Merge(src proto.Message)

+ func (m *SQLStatement) XXX_Size() int

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

+ func (this *SQLStatement) String() string

+ type Sidecar struct

+ Resources corev1.ResourceRequirements

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

+ func (*Sidecar) ProtoMessage()

+ func (in *Sidecar) DeepCopy() *Sidecar

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

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

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

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

+ func (m *Sidecar) Reset()

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

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

+ func (m *Sidecar) XXX_DiscardUnknown()

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

+ func (m *Sidecar) XXX_Merge(src proto.Message)

+ func (m *Sidecar) XXX_Size() int

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

+ func (this *Sidecar) String() string

type Sink

+ DB *DBSink

type Source

+ DB *DBSource

type StepSpec

+ ImagePullSecrets []corev1.LocalObjectReference

+ Sidecar Sidecar

+ func (in StepSpec) WithOutReplicas() StepSpec

Jul 27, 2021

Changes in this version

+ type S3 struct

+ Bucket string

+ Credentials *AWSCredentials

+ Endpoint *AWSEndpoint

+ Name string

+ Region string

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

+ func (*S3) ProtoMessage()

+ func (in *S3) DeepCopy() *S3

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

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

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

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

+ func (m *S3) Reset()

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

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

+ func (m *S3) XXX_DiscardUnknown()

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

+ func (m *S3) XXX_Merge(src proto.Message)

+ func (m *S3) XXX_Size() int

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

+ func (this *S3) String() string

+ type S3Sink struct

+ Key string

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

+ func (*S3Sink) ProtoMessage()

+ func (in *S3Sink) DeepCopy() *S3Sink

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

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

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

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

+ func (m *S3Sink) Reset()

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

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

+ func (m *S3Sink) XXX_DiscardUnknown()

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

+ func (m *S3Sink) XXX_Merge(src proto.Message)

+ func (m *S3Sink) XXX_Size() int

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

+ func (this *S3Sink) String() string

type Sink

+ S3 *S3Sink

Jul 26, 2021

Changes in this version

+ const EnvBearerToken

+ type AWSCredentials struct

+ AccessKeyID corev1.SecretKeySelector

+ SecretAccessKey corev1.SecretKeySelector

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

+ func (*AWSCredentials) ProtoMessage()

+ func (in *AWSCredentials) DeepCopy() *AWSCredentials

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

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

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

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

+ func (m *AWSCredentials) Reset()

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

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

+ func (m *AWSCredentials) XXX_DiscardUnknown()

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

+ func (m *AWSCredentials) XXX_Merge(src proto.Message)

+ func (m *AWSCredentials) XXX_Size() int

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

+ func (this *AWSCredentials) String() string

+ type AWSEndpoint struct

+ URL string

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

+ func (*AWSEndpoint) ProtoMessage()

+ func (in *AWSEndpoint) DeepCopy() *AWSEndpoint

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

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

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

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

+ func (m *AWSEndpoint) Reset()

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

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

+ func (m *AWSEndpoint) XXX_DiscardUnknown()

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

+ func (m *AWSEndpoint) XXX_Merge(src proto.Message)

+ func (m *AWSEndpoint) XXX_Size() int

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

+ func (this *AWSEndpoint) String() string

type Git

+ SSHPrivateKey *corev1.SecretKeySelector

+ type S3Source struct

+ Bucket string

+ Credentials *AWSCredentials

+ Endpoint *AWSEndpoint

+ Name string

+ PollPeriod metav1.Duration

+ Region string

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

+ func (*S3Source) ProtoMessage()

+ func (in *S3Source) DeepCopy() *S3Source

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

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

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

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

+ func (m *S3Source) Reset()

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

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

+ func (m *S3Source) XXX_DiscardUnknown()

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

+ func (m *S3Source) XXX_Merge(src proto.Message)

+ func (m *S3Source) XXX_Size() int

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

+ func (this *S3Source) String() string

type Source

+ S3 *S3Source

Jul 23, 2021

Changes in this version

type KafkaNET

+ SASL *SASL

+ type SASL struct

+ Mechanism SASLMechanism

+ PasswordSecret *corev1.SecretKeySelector

+ UserSecret *corev1.SecretKeySelector

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

+ func (*SASL) ProtoMessage()

+ func (in *SASL) DeepCopy() *SASL

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

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

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

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

+ func (m *SASL) Reset()

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

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

+ func (m *SASL) XXX_DiscardUnknown()

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

+ func (m *SASL) XXX_Merge(src proto.Message)

+ func (m *SASL) XXX_Size() int

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

+ func (s SASL) GetMechanism() SASLMechanism

+ func (this *SASL) String() string

+ type SASLMechanism string

+ var GSSAPI SASLMechanism = "GSSAPI"

+ var OAUTHBEARER SASLMechanism = "SASLMechanism"

+ var PLAIN SASLMechanism = "PLAIN"

+ var SCRAMSHA256 SASLMechanism = "SCRAM-SHA-256"

+ var SCRAMSHA512 SASLMechanism = "SCRAM-SHA-512"

type TLS

+ CACertSecret *corev1.SecretKeySelector

+ CertSecret *corev1.SecretKeySelector

+ KeySecret *corev1.SecretKeySelector

Jul 21, 2021

Changes in this version

type SourceStatuses

+ func (in SourceStatuses) GetErrors() uint64

Jul 20, 2021

Changes in this version

+ type Code struct

+ Runtime Runtime

+ Source string

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

+ func (*Code) ProtoMessage()

+ func (in *Code) DeepCopy() *Code

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

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

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

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

+ func (m *Code) Reset()

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

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

+ func (m *Code) XXX_DiscardUnknown()

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

+ func (m *Code) XXX_Merge(src proto.Message)

+ func (m *Code) XXX_Size() int

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

+ func (this *Code) String() string

type StepSpec

+ Code *Code

Jul 16, 2021

Changes in this version

+ type KafkaOffset string

+ type KafkaSource struct

+ StartOffset KafkaOffset

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

+ func (*KafkaSource) ProtoMessage()

+ func (in *KafkaSource) DeepCopy() *KafkaSource

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

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

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

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

+ func (m *KafkaSource) Reset()

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

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

+ func (m *KafkaSource) XXX_DiscardUnknown()

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

+ func (m *KafkaSource) XXX_Merge(src proto.Message)

+ func (m *KafkaSource) XXX_Size() int

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

+ func (this *KafkaSource) String() string

type STAN

+ MaxInflight uint32

+ func (s *STAN) GetMaxInflight() int

Jul 14, 2021

Changes in this version

+ const CommitN

type SourceStatus

+ func (in SourceStatus) GetRetries() uint64

type SourceStatuses

+ func (in SourceStatuses) IncrRetries(name string, replica int)

Jul 12, 2021

Changes in this version

type Container

+ Resources corev1.ResourceRequirements

Jul 12, 2021

Changes in this version

+ const EnvDeletionDelay

+ const EnvImagePrefix

+ const KeyFinalizer

+ type Backoff struct

+ Cap metav1.Duration

+ JitterPercentage uint32

+ Steps uint64

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

+ func (*Backoff) ProtoMessage()

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

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

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

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

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

+ func (m *Backoff) Reset()

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

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

+ func (m *Backoff) XXX_DiscardUnknown()

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

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

+ func (m *Backoff) XXX_Size() int

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

+ func (this *Backoff) String() string

+ type HTTPHeader struct

+ Name string

+ Value string

+ ValueFrom *HTTPHeaderSource

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

+ func (*HTTPHeader) ProtoMessage()

+ func (in *HTTPHeader) DeepCopy() *HTTPHeader

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

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

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

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

+ func (m *HTTPHeader) Reset()

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

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

+ func (m *HTTPHeader) XXX_DiscardUnknown()

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

+ func (m *HTTPHeader) XXX_Merge(src proto.Message)

+ func (m *HTTPHeader) XXX_Size() int

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

+ func (this *HTTPHeader) String() string

+ type HTTPHeaderSource struct

+ SecretKeyRef corev1.SecretKeySelector

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

+ func (*HTTPHeaderSource) ProtoMessage()

+ func (in *HTTPHeaderSource) DeepCopy() *HTTPHeaderSource

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

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

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

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

+ func (m *HTTPHeaderSource) Reset()

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

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

+ func (m *HTTPHeaderSource) XXX_DiscardUnknown()

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

+ func (m *HTTPHeaderSource) XXX_Merge(src proto.Message)

+ func (m *HTTPHeaderSource) XXX_Size() int

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

+ func (this *HTTPHeaderSource) String() string

type HTTPSink

+ Headers []HTTPHeader

type Metrics

+ Retries uint64

type PipelineStatus

+ LastUpdated metav1.Time

type STAN

+ Auth *STANAuth

+ func (s *STAN) AuthStrategy() STANAuthStrategy

+ type STANAuth struct

+ Token *corev1.SecretKeySelector

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

+ func (*STANAuth) ProtoMessage()

+ func (in *STANAuth) DeepCopy() *STANAuth

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

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

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

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

+ func (m *STANAuth) Reset()

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

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

+ func (m *STANAuth) XXX_DiscardUnknown()

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

+ func (m *STANAuth) XXX_Merge(src proto.Message)

+ func (m *STANAuth) XXX_Size() int

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

+ func (this *STANAuth) String() string

+ type STANAuthStrategy string

+ var STANAuthNone STANAuthStrategy = "None"

+ var STANAuthToken STANAuthStrategy = "Token"

type Source

+ Retry Backoff

type SourceStatus

+ func (in SourceStatus) GetRetryCount() uint64

type SourceStatuses

+ func (in SourceStatuses) IncrRetryCount(name string, replica int)

Jun 25, 2021

Changes in this version

+ const EnvDefaultResourceRequirements

+ type Dedupe struct

+ MaxSize resource.Quantity

+ UID string

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

+ func (*Dedupe) ProtoMessage()

+ func (in *Dedupe) DeepCopy() *Dedupe

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

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

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

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

+ func (m *Dedupe) Reset()

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

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

+ func (m *Dedupe) XXX_DiscardUnknown()

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

+ func (m *Dedupe) XXX_Merge(src proto.Message)

+ func (m *Dedupe) XXX_Size() int

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

+ func (this *Dedupe) String() string

type GetPodSpecReq

+ ResourceRequirements corev1.ResourceRequirements

type StepSpec

+ Dedupe *Dedupe

Jun 17, 2021

Changes in this version

+ const KeyDescription

+ const KeyOwner

type HTTPSource

+ ServiceName string

Jun 15, 2021

Changes in this version

+ const ConditionRecentErrors

type SourceStatus

+ func (in SourceStatus) RecentErrors() bool

type SourceStatuses

+ func (in SourceStatuses) RecentErrors() bool

type StepStatus

+ func (in StepStatus) RecentErrors() bool

Jun 8, 2021

Changes in this version

type STAN

+ NATSMonitoringURL string

type SourceStatuses

+ func (in SourceStatuses) IncrErrors(name string, replica int, err error)

+ func (in SourceStatuses) IncrTotal(name string, replica int, msg string, rate resource.Quantity)

Jun 8, 2021

Changes in this version

+ type RetryPolicy string

+ const RetryAlways

+ const RetryNever

type Source

+ RetryPolicy RetryPolicy

Jun 8, 2021

Changes in this version

+ const EnvStep

type Step

+ func (in Step) GetPodSpec(req GetPodSpecReq) corev1.PodSpec

Jun 4, 2021

Changes in this version

type SourceStatus

+ func (in SourceStatus) AnySunk() bool

+ func (m SourceStatus) GetMetrics(replica int) Metrics

type SourceStatuses

+ func (in SourceStatuses) Get(name string) SourceStatus

Jun 4, 2021

Changes in this version

type SourceStatus

+ func (in SourceStatus) GetErrors() uint64

+ func (in SourceStatus) GetTotal() uint64

+ func (m SourceStatus) GetPending() uint64

type SourceStatuses

+ func (in SourceStatuses) AnySunk() bool

+ func (in SourceStatuses) GetTotal() uint64

Jun 4, 2021

Changes in this version

type SinkStatuses

+ func (in SinkStatuses) GetErrors() uint64

+ func (in SinkStatuses) GetTotal() uint64

Jun 3, 2021

Changes in this version

+ const EnvDataflowBearerToken

type GetPodSpecReq

+ BearerToken string

May 25, 2021

Changes in this version

+ const PathPreStop

May 20, 2021

Changes in this version

+ const EnvStepStatus

type GetPodSpecReq

+ StepStatus StepStatus

type Kafka

+ Parallel uint32

type Metrics

+ Rate uint64

type STAN

+ Parallel uint32

type StepStatus

+ SourceStatuses SourceStatuses

May 19, 2021

Changes in this version

type StepPhaseMessage

+ func (m StepPhaseMessage) GetReason() string

type StepStatus

+ Reason string

May 18, 2021

Changes in this version

+ type HTTPSink struct

+ URL string

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

+ func (*HTTPSink) ProtoMessage()

+ func (in *HTTPSink) DeepCopy() *HTTPSink

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

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

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

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

+ func (m *HTTPSink) Reset()

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

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

+ func (m *HTTPSink) XXX_DiscardUnknown()

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

+ func (m *HTTPSink) XXX_Merge(src proto.Message)

+ func (m *HTTPSink) XXX_Size() int

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

+ func (this *HTTPSink) String() string

+ type HTTPSource struct

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

+ func (*HTTPSource) ProtoMessage()

+ func (in *HTTPSource) DeepCopy() *HTTPSource

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

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

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

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

+ func (m *HTTPSource) Reset()

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

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

+ func (m *HTTPSource) XXX_DiscardUnknown()

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

+ func (m *HTTPSource) XXX_Merge(src proto.Message)

+ func (m *HTTPSource) XXX_Size() int

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

+ func (this *HTTPSource) String() string

type Sink

+ HTTP *HTTPSink

type Source

+ HTTP *HTTPSource

+ type Sources []Source

+ func (in Sources) DeepCopy() Sources

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

+ func (ss Sources) Any(fn func(value Source) bool) bool

May 17, 2021

Changes in this version

type Cron

+ Layout string

+ type Expand struct

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

+ func (*Expand) ProtoMessage()

+ func (in *Expand) DeepCopy() *Expand

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

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

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

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

+ func (m *Expand) Reset()

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

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

+ func (m *Expand) XXX_DiscardUnknown()

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

+ func (m *Expand) XXX_Merge(src proto.Message)

+ func (m *Expand) XXX_Size() int

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

+ func (this *Expand) String() string

+ type Flatten struct

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

+ func (*Flatten) ProtoMessage()

+ func (in *Flatten) DeepCopy() *Flatten

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

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

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

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

+ func (m *Flatten) Reset()

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

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

+ func (m *Flatten) XXX_DiscardUnknown()

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

+ func (m *Flatten) XXX_Merge(src proto.Message)

+ func (m *Flatten) XXX_Size() int

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

+ func (this *Flatten) String() string

+ type Scale struct

+ MaxReplicas *uint32

+ MinReplicas int32

+ ReplicaRatio uint32

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

+ func (*Scale) ProtoMessage()

+ func (in *Scale) DeepCopy() *Scale

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

+ func (in Scale) Calculate(pending int) int

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

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

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

+ func (m *Scale) Reset()

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

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

+ func (m *Scale) XXX_DiscardUnknown()

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

+ func (m *Scale) XXX_Merge(src proto.Message)

+ func (m *Scale) XXX_Size() int

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

+ func (this *Scale) String() string

type StepSpec

+ Expand *Expand

+ Flatten *Flatten

+ Scale *Scale

+ func (in *StepSpec) CalculateReplicas(pending int) int

type StepStatus

+ Selector string

May 13, 2021

Changes in this version

+ const EnvPeekDelay

+ const EnvScalingDelay

+ type Error struct

+ Message string

+ Time metav1.Time

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

+ func (*Error) ProtoMessage()

+ func (in *Error) DeepCopy() *Error

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

+ 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 (m *Error) Reset()

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

+ 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

+ func (this *Error) String() string

+ type GetPodSpecReq struct

+ ImageFormat string

+ Namespace string

+ PipelineName string

+ PullPolicy corev1.PullPolicy

+ Replica int32

+ RunnerImage string

+ UpdateInterval time.Duration

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

+ func (*GetPodSpecReq) ProtoMessage()

+ func (in *GetPodSpecReq) DeepCopy() *GetPodSpecReq

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

+ 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 (m *GetPodSpecReq) Reset()

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

+ 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

+ func (this *GetPodSpecReq) String() string

type SinkStatus

+ LastError *Error

type SinkStatuses

+ func (in SinkStatuses) IncErrors(name string, replica int, err error)

type SourceStatus

+ LastError *Error

May 11, 2021

Changes in this version

+ const ConditionCompleted

+ const ConditionErrors

+ const ConditionRunning

+ const ConditionSunkMessages

+ const ConditionTerminating

+ const CtrInit

+ const CtrMain

+ const CtrSidecar

+ const EnvImageFormat

+ const EnvInstaller

+ const EnvInstallerImages

+ const EnvNamespace

+ const EnvPipelineName

+ const EnvPullPolicy

+ const EnvReplica

+ const EnvStepSpec

+ const EnvUpdateInterval

+ const KeyDefaultContainer

+ const KeyHash

+ const KeyPipelineName

+ const KeyReplica

+ const KeyStepName

+ const PathCheckout

+ const PathFIFOIn

+ const PathFIFOOut

+ const PathGroups

+ const PathHandlerFile

+ const PathKill

+ const PathVarRun

+ const PathWorkingDir

+ var AddToScheme = SchemeBuilder.AddToScheme

+ var DefaultInterface = &Interface

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

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

+ var ErrUnexpectedEndOfGroupGenerated = fmt.Errorf("proto: unexpected end of group")

+ var GroupVersion = schema.GroupVersion

+ var KeyKillCmd = func(x string) string

+ var LargeResourceRequirements = corev1.ResourceRequirements

+ var PipelineGroupVersionKind = GroupVersion.WithKind("Pipeline")

+ var PipelineGroupVersionResource = GroupVersion.WithResource("pipelines")

+ var SchemeBuilder = &scheme.Builder

+ var SmallResourceRequirements = corev1.ResourceRequirements

+ var StepGroupVersionKind = GroupVersion.WithKind("Step")

+ var StepGroupVersionResource = GroupVersion.WithResource("steps")

+ func IgnoreAlreadyExists(err error) error

+ func IgnoreConflict(err error) error

+ func IgnoreContainerNotFound(err error) error

+ func IgnoreExist(err error) error

+ func IgnoreNotFound(err error) error

+ func IgnorePermission(err error) error

+ func RequeueAfter(currentReplicas, targetReplicas int) time.Duration

+ func StringOr(a, b string) string

+ func StringsOr(a, b []string) []string

+ type Cat struct

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

+ func (*Cat) ProtoMessage()

+ func (in *Cat) DeepCopy() *Cat

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

+ 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 (m *Cat) Reset()

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

+ 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

+ func (this *Cat) String() string

+ type Container struct

+ Args []string

+ Command []string

+ Env []corev1.EnvVar

+ Image string

+ In *Interface

+ VolumeMounts []corev1.VolumeMount

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

+ func (*Container) ProtoMessage()

+ func (in *Container) DeepCopy() *Container

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

+ 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 (m *Container) Reset()

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

+ 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

+ func (this *Container) String() string

+ type Cron struct

+ Schedule string

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

+ func (*Cron) ProtoMessage()

+ func (in *Cron) DeepCopy() *Cron

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

+ 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 (m *Cron) Reset()

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

+ 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

+ func (this *Cron) String() string

+ type Filter string

+ type Git struct

+ Branch string

+ Command []string

+ Env []corev1.EnvVar

+ Image string

+ Path string

+ URL string

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

+ func (*Git) ProtoMessage()

+ func (in *Git) DeepCopy() *Git

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

+ 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 (m *Git) Reset()

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

+ 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

+ func (this *Git) String() string

+ type Group struct

+ EndOfGroup string

+ Format GroupFormat

+ Key string

+ Storage *Storage

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

+ func (*Group) ProtoMessage()

+ func (in *Group) DeepCopy() *Group

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

+ 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 (m *Group) Reset()

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

+ 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

+ func (this *Group) String() string

+ type GroupFormat string

+ const GroupFormatJSONBytesArray

+ const GroupFormatJSONStringArray

+ const GroupFormatUnknown

+ type HTTP struct

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

+ func (*HTTP) ProtoMessage()

+ func (in *HTTP) DeepCopy() *HTTP

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

+ 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 (m *HTTP) Reset()

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

+ 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

+ func (this *HTTP) String() string

+ type Handler struct

+ Code string

+ Runtime Runtime

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

+ func (*Handler) ProtoMessage()

+ func (in *Handler) DeepCopy() *Handler

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

+ 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 (m *Handler) Reset()

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

+ 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

+ func (this *Handler) String() string

+ type Interface struct

+ FIFO bool

+ HTTP *HTTP

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

+ func (*Interface) ProtoMessage()

+ func (in *Interface) DeepCopy() *Interface

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

+ 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 (m *Interface) Reset()

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

+ 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

+ func (this *Interface) String() string

+ type Kafka struct

+ Brokers []string

+ NET *KafkaNET

+ Name string

+ Topic string

+ Version string

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

+ func (*Kafka) ProtoMessage()

+ func (in *Kafka) DeepCopy() *Kafka

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

+ 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 (m *Kafka) Reset()

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

+ 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

+ func (this *Kafka) String() string

+ type KafkaNET struct

+ TLS *TLS

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

+ func (*KafkaNET) ProtoMessage()

+ func (in *KafkaNET) DeepCopy() *KafkaNET

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

+ 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 (m *KafkaNET) Reset()

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

+ 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

+ func (this *KafkaNET) String() string

+ type Log struct

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

+ func (*Log) ProtoMessage()

+ func (in *Log) DeepCopy() *Log

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

+ 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 (m *Log) Reset()

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

+ 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

+ func (this *Log) String() string

+ type Map string

+ type Message struct

+ Data string

+ Time metav1.Time

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

+ func (*Message) ProtoMessage()

+ func (in *Message) DeepCopy() *Message

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

+ 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 (m *Message) Reset()

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

+ 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

+ func (this *Message) String() string

+ type Metadata struct

+ Annotations map[string]string

+ Labels map[string]string

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

+ func (*Metadata) ProtoMessage()

+ func (in *Metadata) DeepCopy() *Metadata

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

+ 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 (m *Metadata) Reset()

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

+ 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

+ func (this *Metadata) String() string

+ type Metrics struct

+ Errors uint64

+ Total uint64

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

+ func (*Metrics) ProtoMessage()

+ func (in *Metrics) DeepCopy() *Metrics

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

+ 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 (m *Metrics) Reset()

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

+ 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

+ func (this *Metrics) String() string

+ type Pipeline struct

+ Spec PipelineSpec

+ Status *PipelineStatus

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

+ func (*Pipeline) ProtoMessage()

+ func (in *Pipeline) DeepCopy() *Pipeline

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

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

+ 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 (m *Pipeline) Reset()

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

+ 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

+ func (this *Pipeline) String() string

+ type PipelineList struct

+ Items []Pipeline

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

+ func (*PipelineList) ProtoMessage()

+ func (in *PipelineList) DeepCopy() *PipelineList

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

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

+ 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 (m *PipelineList) Reset()

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

+ 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

+ func (this *PipelineList) String() string

+ type PipelinePhase string

+ const PipelineFailed

+ const PipelinePending

+ const PipelineRunning

+ const PipelineSucceeded

+ const PipelineUnknown

+ func MinPipelinePhase(v ...PipelinePhase) PipelinePhase

+ func (p PipelinePhase) Completed() bool

+ type PipelineSpec struct

+ Steps []StepSpec

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

+ func (*PipelineSpec) ProtoMessage()

+ func (in *PipelineSpec) DeepCopy() *PipelineSpec

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

+ 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 (m *PipelineSpec) Reset()

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

+ 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

+ func (this *PipelineSpec) String() string

+ type PipelineStatus struct

+ Conditions []metav1.Condition

+ Message string

+ Phase PipelinePhase

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

+ func (*PipelineStatus) ProtoMessage()

+ func (in *PipelineStatus) DeepCopy() *PipelineStatus

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

+ 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 (m *PipelineStatus) Reset()

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

+ 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

+ func (this *PipelineStatus) String() string

+ type Replicas struct

+ Max *uint32

+ Min int32

+ Ratio uint32

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

+ func (*Replicas) ProtoMessage()

+ func (in *Replicas) DeepCopy() *Replicas

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

+ func (in Replicas) Calculate(pending int) 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 (m *Replicas) Reset()

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

+ 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

+ func (this *Replicas) String() string

+ type Runtime string

+ type STAN struct

+ ClusterID string

+ NATSURL string

+ Name string

+ Subject string

+ SubjectPrefix SubjectPrefix

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

+ func (*STAN) ProtoMessage()

+ func (in *STAN) DeepCopy() *STAN

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

+ 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 (m *STAN) Reset()

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

+ 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

+ func (this *STAN) String() string

+ type Sink struct

+ Kafka *Kafka

+ Log *Log

+ Name string

+ STAN *STAN

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

+ func (*Sink) ProtoMessage()

+ func (in *Sink) DeepCopy() *Sink

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

+ 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 (m *Sink) Reset()

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

+ 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

+ func (this *Sink) String() string

+ type SinkStatus struct

+ LastMessage *Message

+ Metrics map[string]Metrics

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

+ func (*SinkStatus) ProtoMessage()

+ func (in *SinkStatus) AnyErrors() bool

+ func (in *SinkStatus) DeepCopy() *SinkStatus

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

+ 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 (m *SinkStatus) Reset()

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

+ 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

+ func (this *SinkStatus) String() string

+ type SinkStatuses map[string]SinkStatus

+ func (in SinkStatuses) AnyErrors() bool

+ func (in SinkStatuses) AnySunk() bool

+ func (in SinkStatuses) DeepCopy() SinkStatuses

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

+ func (in SinkStatuses) Set(name string, replica int, short string)

+ type Source struct

+ Cron *Cron

+ Kafka *Kafka

+ Name string

+ STAN *STAN

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

+ func (*Source) ProtoMessage()

+ func (in *Source) DeepCopy() *Source

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

+ 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 (m *Source) Reset()

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

+ 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

+ func (this *Source) String() string

+ type SourceStatus struct

+ LastMessage *Message

+ Metrics map[string]Metrics

+ Pending *uint64

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

+ func (*SourceStatus) ProtoMessage()

+ func (in *SourceStatus) AnyErrors() bool

+ func (in *SourceStatus) DeepCopy() *SourceStatus

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

+ 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 (m *SourceStatus) Reset()

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

+ 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

+ func (this *SourceStatus) String() string

+ type SourceStatuses map[string]SourceStatus

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

+ func (in SourceStatuses) Set(name string, replica int, short string)

+ func (in SourceStatuses) SetPending(name string, pending uint64)

+ type Step struct

+ Spec StepSpec

+ Status *StepStatus

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

+ func (*Step) ProtoMessage()

+ func (in *Step) DeepCopy() *Step

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

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

+ func (in *Step) GetTargetReplicas() 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 (m *Step) Reset()

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

+ 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

+ func (this *Step) String() string

+ type StepList struct

+ Items []Step

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

+ func (*StepList) ProtoMessage()

+ func (in *StepList) DeepCopy() *StepList

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

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

+ 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 (m *StepList) Reset()

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

+ 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

+ func (this *StepList) String() string

+ type StepPhase string

+ const StepFailed

+ const StepPending

+ const StepRunning

+ const StepSucceeded

+ const StepUnknown

+ func (p StepPhase) Completed() bool

+ type StepPhaseMessage string

+ func MinStepPhaseMessage(v ...StepPhaseMessage) StepPhaseMessage

+ func NewStepPhaseMessage(p StepPhase, m string) StepPhaseMessage

+ func (m StepPhaseMessage) GetMessage() string

+ func (m StepPhaseMessage) GetPhase() StepPhase

+ type StepSpec struct

+ Affinity *corev1.Affinity

+ Cat *Cat

+ Container *Container

+ Filter Filter

+ Git *Git

+ Group *Group

+ Handler *Handler

+ Map Map

+ Metadata *Metadata

+ Name string

+ NodeSelector map[string]string

+ Replicas *Replicas

+ RestartPolicy corev1.RestartPolicy

+ ServiceAccountName string

+ Sinks []Sink

+ Sources []Source

+ Terminator bool

+ Tolerations []corev1.Toleration

+ Volumes []corev1.Volume

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

+ func (*StepSpec) ProtoMessage()

+ func (in *StepSpec) DeepCopy() *StepSpec

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

+ func (in *StepSpec) GetContainer(imageFormat, runnerImage string, policy corev1.PullPolicy, ...) corev1.Container

+ func (in *StepSpec) GetIn() *Interface

+ func (in *StepSpec) GetPodSpec(pipelineName, namespace string, replica int) 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 (m *StepSpec) Reset()

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

+ 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

+ func (this *StepSpec) String() string

+ type StepStatus struct

+ LastScaledAt *metav1.Time

+ Message string

+ Phase StepPhase

+ Replicas uint32

+ SinkStatues SinkStatuses

+ SourceStatues SourceStatuses

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

+ func (*StepStatus) ProtoMessage()

+ func (in *StepStatus) AnyErrors() bool

+ func (in *StepStatus) DeepCopy() *StepStatus

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

+ 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 (m *StepStatus) Reset()

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

+ 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

+ func (this *StepStatus) String() string

+ type Storage struct

+ Name string

+ SubPath string

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

+ func (*Storage) ProtoMessage()

+ func (in *Storage) DeepCopy() *Storage

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

+ 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 (m *Storage) Reset()

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

+ 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

+ func (this *Storage) String() string

+ type SubjectPrefix string

+ const SubjectPrefixNamespaceName

+ const SubjectPrefixNamespacedPipelineName

+ const SubjectPrefixNone

+ func SubjectPrefixOr(a, b SubjectPrefix) SubjectPrefix

+ type TLS struct

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

+ func (*TLS) ProtoMessage()

+ func (in *TLS) DeepCopy() *TLS

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

+ 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 (m *TLS) Reset()

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

+ 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

+ func (this *TLS) String() string