diff --git a/api/v1alpha1/generated.pb.go b/api/v1alpha1/generated.pb.go index b9acde22..709564d1 100644 --- a/api/v1alpha1/generated.pb.go +++ b/api/v1alpha1/generated.pb.go @@ -35,10 +35,12 @@ import ( ) // Reference imports to suppress errors if they are not otherwise used. -var _ = proto.Marshal -var _ = fmt.Errorf -var _ = math.Inf -var _ = time.Kitchen +var ( + _ = proto.Marshal + _ = fmt.Errorf + _ = math.Inf + _ = time.Kitchen +) // This is a compile-time assertion to ensure that this generated file // is compatible with the proto package it is being compiled against. @@ -51,9 +53,11 @@ func (*AWSCredentials) ProtoMessage() {} func (*AWSCredentials) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{0} } + func (m *AWSCredentials) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } + func (m *AWSCredentials) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { b = b[:cap(b)] n, err := m.MarshalToSizedBuffer(b) @@ -62,12 +66,15 @@ func (m *AWSCredentials) XXX_Marshal(b []byte, deterministic bool) ([]byte, erro } return b[:n], nil } + func (m *AWSCredentials) XXX_Merge(src proto.Message) { xxx_messageInfo_AWSCredentials.Merge(m, src) } + func (m *AWSCredentials) XXX_Size() int { return m.Size() } + func (m *AWSCredentials) XXX_DiscardUnknown() { xxx_messageInfo_AWSCredentials.DiscardUnknown(m) } @@ -79,9 +86,11 @@ func (*AWSEndpoint) ProtoMessage() {} func (*AWSEndpoint) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{1} } + func (m *AWSEndpoint) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } + func (m *AWSEndpoint) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { b = b[:cap(b)] n, err := m.MarshalToSizedBuffer(b) @@ -90,12 +99,15 @@ func (m *AWSEndpoint) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) } return b[:n], nil } + func (m *AWSEndpoint) XXX_Merge(src proto.Message) { xxx_messageInfo_AWSEndpoint.Merge(m, src) } + func (m *AWSEndpoint) XXX_Size() int { return m.Size() } + func (m *AWSEndpoint) XXX_DiscardUnknown() { xxx_messageInfo_AWSEndpoint.DiscardUnknown(m) } @@ -107,9 +119,11 @@ func (*Backoff) ProtoMessage() {} func (*Backoff) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{2} } + func (m *Backoff) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } + func (m *Backoff) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { b = b[:cap(b)] n, err := m.MarshalToSizedBuffer(b) @@ -118,12 +132,15 @@ func (m *Backoff) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { } return b[:n], nil } + func (m *Backoff) XXX_Merge(src proto.Message) { xxx_messageInfo_Backoff.Merge(m, src) } + func (m *Backoff) XXX_Size() int { return m.Size() } + func (m *Backoff) XXX_DiscardUnknown() { xxx_messageInfo_Backoff.DiscardUnknown(m) } @@ -135,9 +152,11 @@ func (*Cat) ProtoMessage() {} func (*Cat) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{3} } + func (m *Cat) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } + func (m *Cat) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { b = b[:cap(b)] n, err := m.MarshalToSizedBuffer(b) @@ -146,12 +165,15 @@ func (m *Cat) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { } return b[:n], nil } + func (m *Cat) XXX_Merge(src proto.Message) { xxx_messageInfo_Cat.Merge(m, src) } + func (m *Cat) XXX_Size() int { return m.Size() } + func (m *Cat) XXX_DiscardUnknown() { xxx_messageInfo_Cat.DiscardUnknown(m) } @@ -163,9 +185,11 @@ func (*Code) ProtoMessage() {} func (*Code) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{4} } + func (m *Code) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } + func (m *Code) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { b = b[:cap(b)] n, err := m.MarshalToSizedBuffer(b) @@ -174,12 +198,15 @@ func (m *Code) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { } return b[:n], nil } + func (m *Code) XXX_Merge(src proto.Message) { xxx_messageInfo_Code.Merge(m, src) } + func (m *Code) XXX_Size() int { return m.Size() } + func (m *Code) XXX_DiscardUnknown() { xxx_messageInfo_Code.DiscardUnknown(m) } @@ -191,9 +218,11 @@ func (*Container) ProtoMessage() {} func (*Container) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{5} } + func (m *Container) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } + func (m *Container) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { b = b[:cap(b)] n, err := m.MarshalToSizedBuffer(b) @@ -202,12 +231,15 @@ func (m *Container) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { } return b[:n], nil } + func (m *Container) XXX_Merge(src proto.Message) { xxx_messageInfo_Container.Merge(m, src) } + func (m *Container) XXX_Size() int { return m.Size() } + func (m *Container) XXX_DiscardUnknown() { xxx_messageInfo_Container.DiscardUnknown(m) } @@ -219,9 +251,11 @@ func (*Cron) ProtoMessage() {} func (*Cron) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{6} } + func (m *Cron) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } + func (m *Cron) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { b = b[:cap(b)] n, err := m.MarshalToSizedBuffer(b) @@ -230,12 +264,15 @@ func (m *Cron) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { } return b[:n], nil } + func (m *Cron) XXX_Merge(src proto.Message) { xxx_messageInfo_Cron.Merge(m, src) } + func (m *Cron) XXX_Size() int { return m.Size() } + func (m *Cron) XXX_DiscardUnknown() { xxx_messageInfo_Cron.DiscardUnknown(m) } @@ -247,9 +284,11 @@ func (*DBDataSource) ProtoMessage() {} func (*DBDataSource) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{7} } + func (m *DBDataSource) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } + func (m *DBDataSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { b = b[:cap(b)] n, err := m.MarshalToSizedBuffer(b) @@ -258,12 +297,15 @@ func (m *DBDataSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) } return b[:n], nil } + func (m *DBDataSource) XXX_Merge(src proto.Message) { xxx_messageInfo_DBDataSource.Merge(m, src) } + func (m *DBDataSource) XXX_Size() int { return m.Size() } + func (m *DBDataSource) XXX_DiscardUnknown() { xxx_messageInfo_DBDataSource.DiscardUnknown(m) } @@ -275,9 +317,11 @@ func (*DBDataSourceFrom) ProtoMessage() {} func (*DBDataSourceFrom) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{8} } + func (m *DBDataSourceFrom) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } + func (m *DBDataSourceFrom) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { b = b[:cap(b)] n, err := m.MarshalToSizedBuffer(b) @@ -286,12 +330,15 @@ func (m *DBDataSourceFrom) XXX_Marshal(b []byte, deterministic bool) ([]byte, er } return b[:n], nil } + func (m *DBDataSourceFrom) XXX_Merge(src proto.Message) { xxx_messageInfo_DBDataSourceFrom.Merge(m, src) } + func (m *DBDataSourceFrom) XXX_Size() int { return m.Size() } + func (m *DBDataSourceFrom) XXX_DiscardUnknown() { xxx_messageInfo_DBDataSourceFrom.DiscardUnknown(m) } @@ -303,9 +350,11 @@ func (*DBSink) ProtoMessage() {} func (*DBSink) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{9} } + func (m *DBSink) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } + func (m *DBSink) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { b = b[:cap(b)] n, err := m.MarshalToSizedBuffer(b) @@ -314,12 +363,15 @@ func (m *DBSink) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { } return b[:n], nil } + func (m *DBSink) XXX_Merge(src proto.Message) { xxx_messageInfo_DBSink.Merge(m, src) } + func (m *DBSink) XXX_Size() int { return m.Size() } + func (m *DBSink) XXX_DiscardUnknown() { xxx_messageInfo_DBSink.DiscardUnknown(m) } @@ -331,9 +383,11 @@ func (*DBSource) ProtoMessage() {} func (*DBSource) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{10} } + func (m *DBSource) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } + func (m *DBSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { b = b[:cap(b)] n, err := m.MarshalToSizedBuffer(b) @@ -342,12 +396,15 @@ func (m *DBSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { } return b[:n], nil } + func (m *DBSource) XXX_Merge(src proto.Message) { xxx_messageInfo_DBSource.Merge(m, src) } + func (m *DBSource) XXX_Size() int { return m.Size() } + func (m *DBSource) XXX_DiscardUnknown() { xxx_messageInfo_DBSource.DiscardUnknown(m) } @@ -359,9 +416,11 @@ func (*Database) ProtoMessage() {} func (*Database) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{11} } + func (m *Database) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } + func (m *Database) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { b = b[:cap(b)] n, err := m.MarshalToSizedBuffer(b) @@ -370,12 +429,15 @@ func (m *Database) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { } return b[:n], nil } + func (m *Database) XXX_Merge(src proto.Message) { xxx_messageInfo_Database.Merge(m, src) } + func (m *Database) XXX_Size() int { return m.Size() } + func (m *Database) XXX_DiscardUnknown() { xxx_messageInfo_Database.DiscardUnknown(m) } @@ -387,9 +449,11 @@ func (*Dedupe) ProtoMessage() {} func (*Dedupe) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{12} } + func (m *Dedupe) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } + func (m *Dedupe) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { b = b[:cap(b)] n, err := m.MarshalToSizedBuffer(b) @@ -398,12 +462,15 @@ func (m *Dedupe) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { } return b[:n], nil } + func (m *Dedupe) XXX_Merge(src proto.Message) { xxx_messageInfo_Dedupe.Merge(m, src) } + func (m *Dedupe) XXX_Size() int { return m.Size() } + func (m *Dedupe) XXX_DiscardUnknown() { xxx_messageInfo_Dedupe.DiscardUnknown(m) } @@ -415,9 +482,11 @@ func (*Expand) ProtoMessage() {} func (*Expand) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{13} } + func (m *Expand) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } + func (m *Expand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { b = b[:cap(b)] n, err := m.MarshalToSizedBuffer(b) @@ -426,12 +495,15 @@ func (m *Expand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { } return b[:n], nil } + func (m *Expand) XXX_Merge(src proto.Message) { xxx_messageInfo_Expand.Merge(m, src) } + func (m *Expand) XXX_Size() int { return m.Size() } + func (m *Expand) XXX_DiscardUnknown() { xxx_messageInfo_Expand.DiscardUnknown(m) } @@ -443,9 +515,11 @@ func (*Flatten) ProtoMessage() {} func (*Flatten) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{14} } + func (m *Flatten) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } + func (m *Flatten) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { b = b[:cap(b)] n, err := m.MarshalToSizedBuffer(b) @@ -454,12 +528,15 @@ func (m *Flatten) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { } return b[:n], nil } + func (m *Flatten) XXX_Merge(src proto.Message) { xxx_messageInfo_Flatten.Merge(m, src) } + func (m *Flatten) XXX_Size() int { return m.Size() } + func (m *Flatten) XXX_DiscardUnknown() { xxx_messageInfo_Flatten.DiscardUnknown(m) } @@ -471,9 +548,11 @@ func (*GetPodSpecReq) ProtoMessage() {} func (*GetPodSpecReq) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{15} } + func (m *GetPodSpecReq) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } + func (m *GetPodSpecReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { b = b[:cap(b)] n, err := m.MarshalToSizedBuffer(b) @@ -482,12 +561,15 @@ func (m *GetPodSpecReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error } return b[:n], nil } + func (m *GetPodSpecReq) XXX_Merge(src proto.Message) { xxx_messageInfo_GetPodSpecReq.Merge(m, src) } + func (m *GetPodSpecReq) XXX_Size() int { return m.Size() } + func (m *GetPodSpecReq) XXX_DiscardUnknown() { xxx_messageInfo_GetPodSpecReq.DiscardUnknown(m) } @@ -499,9 +581,11 @@ func (*Git) ProtoMessage() {} func (*Git) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{16} } + func (m *Git) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } + func (m *Git) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { b = b[:cap(b)] n, err := m.MarshalToSizedBuffer(b) @@ -510,12 +594,15 @@ func (m *Git) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { } return b[:n], nil } + func (m *Git) XXX_Merge(src proto.Message) { xxx_messageInfo_Git.Merge(m, src) } + func (m *Git) XXX_Size() int { return m.Size() } + func (m *Git) XXX_DiscardUnknown() { xxx_messageInfo_Git.DiscardUnknown(m) } @@ -527,9 +614,11 @@ func (*Group) ProtoMessage() {} func (*Group) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{17} } + func (m *Group) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } + func (m *Group) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { b = b[:cap(b)] n, err := m.MarshalToSizedBuffer(b) @@ -538,12 +627,15 @@ func (m *Group) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { } return b[:n], nil } + func (m *Group) XXX_Merge(src proto.Message) { xxx_messageInfo_Group.Merge(m, src) } + func (m *Group) XXX_Size() int { return m.Size() } + func (m *Group) XXX_DiscardUnknown() { xxx_messageInfo_Group.DiscardUnknown(m) } @@ -555,9 +647,11 @@ func (*HTTP) ProtoMessage() {} func (*HTTP) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{18} } + func (m *HTTP) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } + func (m *HTTP) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { b = b[:cap(b)] n, err := m.MarshalToSizedBuffer(b) @@ -566,12 +660,15 @@ func (m *HTTP) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { } return b[:n], nil } + func (m *HTTP) XXX_Merge(src proto.Message) { xxx_messageInfo_HTTP.Merge(m, src) } + func (m *HTTP) XXX_Size() int { return m.Size() } + func (m *HTTP) XXX_DiscardUnknown() { xxx_messageInfo_HTTP.DiscardUnknown(m) } @@ -583,9 +680,11 @@ func (*HTTPHeader) ProtoMessage() {} func (*HTTPHeader) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{19} } + func (m *HTTPHeader) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } + func (m *HTTPHeader) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { b = b[:cap(b)] n, err := m.MarshalToSizedBuffer(b) @@ -594,12 +693,15 @@ func (m *HTTPHeader) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { } return b[:n], nil } + func (m *HTTPHeader) XXX_Merge(src proto.Message) { xxx_messageInfo_HTTPHeader.Merge(m, src) } + func (m *HTTPHeader) XXX_Size() int { return m.Size() } + func (m *HTTPHeader) XXX_DiscardUnknown() { xxx_messageInfo_HTTPHeader.DiscardUnknown(m) } @@ -611,9 +713,11 @@ func (*HTTPHeaderSource) ProtoMessage() {} func (*HTTPHeaderSource) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{20} } + func (m *HTTPHeaderSource) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } + func (m *HTTPHeaderSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { b = b[:cap(b)] n, err := m.MarshalToSizedBuffer(b) @@ -622,12 +726,15 @@ func (m *HTTPHeaderSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, er } return b[:n], nil } + func (m *HTTPHeaderSource) XXX_Merge(src proto.Message) { xxx_messageInfo_HTTPHeaderSource.Merge(m, src) } + func (m *HTTPHeaderSource) XXX_Size() int { return m.Size() } + func (m *HTTPHeaderSource) XXX_DiscardUnknown() { xxx_messageInfo_HTTPHeaderSource.DiscardUnknown(m) } @@ -639,9 +746,11 @@ func (*HTTPSink) ProtoMessage() {} func (*HTTPSink) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{21} } + func (m *HTTPSink) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } + func (m *HTTPSink) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { b = b[:cap(b)] n, err := m.MarshalToSizedBuffer(b) @@ -650,12 +759,15 @@ func (m *HTTPSink) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { } return b[:n], nil } + func (m *HTTPSink) XXX_Merge(src proto.Message) { xxx_messageInfo_HTTPSink.Merge(m, src) } + func (m *HTTPSink) XXX_Size() int { return m.Size() } + func (m *HTTPSink) XXX_DiscardUnknown() { xxx_messageInfo_HTTPSink.DiscardUnknown(m) } @@ -667,9 +779,11 @@ func (*HTTPSource) ProtoMessage() {} func (*HTTPSource) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{22} } + func (m *HTTPSource) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } + func (m *HTTPSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { b = b[:cap(b)] n, err := m.MarshalToSizedBuffer(b) @@ -678,12 +792,15 @@ func (m *HTTPSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { } return b[:n], nil } + func (m *HTTPSource) XXX_Merge(src proto.Message) { xxx_messageInfo_HTTPSource.Merge(m, src) } + func (m *HTTPSource) XXX_Size() int { return m.Size() } + func (m *HTTPSource) XXX_DiscardUnknown() { xxx_messageInfo_HTTPSource.DiscardUnknown(m) } @@ -695,9 +812,11 @@ func (*Interface) ProtoMessage() {} func (*Interface) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{23} } + func (m *Interface) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } + func (m *Interface) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { b = b[:cap(b)] n, err := m.MarshalToSizedBuffer(b) @@ -706,12 +825,15 @@ func (m *Interface) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { } return b[:n], nil } + func (m *Interface) XXX_Merge(src proto.Message) { xxx_messageInfo_Interface.Merge(m, src) } + func (m *Interface) XXX_Size() int { return m.Size() } + func (m *Interface) XXX_DiscardUnknown() { xxx_messageInfo_Interface.DiscardUnknown(m) } @@ -723,9 +845,11 @@ func (*Kafka) ProtoMessage() {} func (*Kafka) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{24} } + func (m *Kafka) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } + func (m *Kafka) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { b = b[:cap(b)] n, err := m.MarshalToSizedBuffer(b) @@ -734,12 +858,15 @@ func (m *Kafka) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { } return b[:n], nil } + func (m *Kafka) XXX_Merge(src proto.Message) { xxx_messageInfo_Kafka.Merge(m, src) } + func (m *Kafka) XXX_Size() int { return m.Size() } + func (m *Kafka) XXX_DiscardUnknown() { xxx_messageInfo_Kafka.DiscardUnknown(m) } @@ -751,9 +878,11 @@ func (*KafkaConfig) ProtoMessage() {} func (*KafkaConfig) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{25} } + func (m *KafkaConfig) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } + func (m *KafkaConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { b = b[:cap(b)] n, err := m.MarshalToSizedBuffer(b) @@ -762,12 +891,15 @@ func (m *KafkaConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) } return b[:n], nil } + func (m *KafkaConfig) XXX_Merge(src proto.Message) { xxx_messageInfo_KafkaConfig.Merge(m, src) } + func (m *KafkaConfig) XXX_Size() int { return m.Size() } + func (m *KafkaConfig) XXX_DiscardUnknown() { xxx_messageInfo_KafkaConfig.DiscardUnknown(m) } @@ -779,9 +911,11 @@ func (*KafkaNET) ProtoMessage() {} func (*KafkaNET) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{26} } + func (m *KafkaNET) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } + func (m *KafkaNET) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { b = b[:cap(b)] n, err := m.MarshalToSizedBuffer(b) @@ -790,12 +924,15 @@ func (m *KafkaNET) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { } return b[:n], nil } + func (m *KafkaNET) XXX_Merge(src proto.Message) { xxx_messageInfo_KafkaNET.Merge(m, src) } + func (m *KafkaNET) XXX_Size() int { return m.Size() } + func (m *KafkaNET) XXX_DiscardUnknown() { xxx_messageInfo_KafkaNET.DiscardUnknown(m) } @@ -807,9 +944,11 @@ func (*KafkaSink) ProtoMessage() {} func (*KafkaSink) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{27} } + func (m *KafkaSink) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } + func (m *KafkaSink) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { b = b[:cap(b)] n, err := m.MarshalToSizedBuffer(b) @@ -818,12 +957,15 @@ func (m *KafkaSink) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { } return b[:n], nil } + func (m *KafkaSink) XXX_Merge(src proto.Message) { xxx_messageInfo_KafkaSink.Merge(m, src) } + func (m *KafkaSink) XXX_Size() int { return m.Size() } + func (m *KafkaSink) XXX_DiscardUnknown() { xxx_messageInfo_KafkaSink.DiscardUnknown(m) } @@ -835,9 +977,11 @@ func (*KafkaSource) ProtoMessage() {} func (*KafkaSource) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{28} } + func (m *KafkaSource) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } + func (m *KafkaSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { b = b[:cap(b)] n, err := m.MarshalToSizedBuffer(b) @@ -846,12 +990,15 @@ func (m *KafkaSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) } return b[:n], nil } + func (m *KafkaSource) XXX_Merge(src proto.Message) { xxx_messageInfo_KafkaSource.Merge(m, src) } + func (m *KafkaSource) XXX_Size() int { return m.Size() } + func (m *KafkaSource) XXX_DiscardUnknown() { xxx_messageInfo_KafkaSource.DiscardUnknown(m) } @@ -863,9 +1010,11 @@ func (*Log) ProtoMessage() {} func (*Log) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{29} } + func (m *Log) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } + func (m *Log) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { b = b[:cap(b)] n, err := m.MarshalToSizedBuffer(b) @@ -874,12 +1023,15 @@ func (m *Log) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { } return b[:n], nil } + func (m *Log) XXX_Merge(src proto.Message) { xxx_messageInfo_Log.Merge(m, src) } + func (m *Log) XXX_Size() int { return m.Size() } + func (m *Log) XXX_DiscardUnknown() { xxx_messageInfo_Log.DiscardUnknown(m) } @@ -891,9 +1043,11 @@ func (*Metadata) ProtoMessage() {} func (*Metadata) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{30} } + func (m *Metadata) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } + func (m *Metadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { b = b[:cap(b)] n, err := m.MarshalToSizedBuffer(b) @@ -902,12 +1056,15 @@ func (m *Metadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { } return b[:n], nil } + func (m *Metadata) XXX_Merge(src proto.Message) { xxx_messageInfo_Metadata.Merge(m, src) } + func (m *Metadata) XXX_Size() int { return m.Size() } + func (m *Metadata) XXX_DiscardUnknown() { xxx_messageInfo_Metadata.DiscardUnknown(m) } @@ -919,9 +1076,11 @@ func (*Metrics) ProtoMessage() {} func (*Metrics) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{31} } + func (m *Metrics) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } + func (m *Metrics) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { b = b[:cap(b)] n, err := m.MarshalToSizedBuffer(b) @@ -930,12 +1089,15 @@ func (m *Metrics) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { } return b[:n], nil } + func (m *Metrics) XXX_Merge(src proto.Message) { xxx_messageInfo_Metrics.Merge(m, src) } + func (m *Metrics) XXX_Size() int { return m.Size() } + func (m *Metrics) XXX_DiscardUnknown() { xxx_messageInfo_Metrics.DiscardUnknown(m) } @@ -947,9 +1109,11 @@ func (*Pipeline) ProtoMessage() {} func (*Pipeline) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{32} } + func (m *Pipeline) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } + func (m *Pipeline) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { b = b[:cap(b)] n, err := m.MarshalToSizedBuffer(b) @@ -958,12 +1122,15 @@ func (m *Pipeline) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { } return b[:n], nil } + func (m *Pipeline) XXX_Merge(src proto.Message) { xxx_messageInfo_Pipeline.Merge(m, src) } + func (m *Pipeline) XXX_Size() int { return m.Size() } + func (m *Pipeline) XXX_DiscardUnknown() { xxx_messageInfo_Pipeline.DiscardUnknown(m) } @@ -975,9 +1142,11 @@ func (*PipelineList) ProtoMessage() {} func (*PipelineList) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{33} } + func (m *PipelineList) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } + func (m *PipelineList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { b = b[:cap(b)] n, err := m.MarshalToSizedBuffer(b) @@ -986,12 +1155,15 @@ func (m *PipelineList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) } return b[:n], nil } + func (m *PipelineList) XXX_Merge(src proto.Message) { xxx_messageInfo_PipelineList.Merge(m, src) } + func (m *PipelineList) XXX_Size() int { return m.Size() } + func (m *PipelineList) XXX_DiscardUnknown() { xxx_messageInfo_PipelineList.DiscardUnknown(m) } @@ -1003,9 +1175,11 @@ func (*PipelineSpec) ProtoMessage() {} func (*PipelineSpec) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{34} } + func (m *PipelineSpec) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } + func (m *PipelineSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { b = b[:cap(b)] n, err := m.MarshalToSizedBuffer(b) @@ -1014,12 +1188,15 @@ func (m *PipelineSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) } return b[:n], nil } + func (m *PipelineSpec) XXX_Merge(src proto.Message) { xxx_messageInfo_PipelineSpec.Merge(m, src) } + func (m *PipelineSpec) XXX_Size() int { return m.Size() } + func (m *PipelineSpec) XXX_DiscardUnknown() { xxx_messageInfo_PipelineSpec.DiscardUnknown(m) } @@ -1031,9 +1208,11 @@ func (*PipelineStatus) ProtoMessage() {} func (*PipelineStatus) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{35} } + func (m *PipelineStatus) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } + func (m *PipelineStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { b = b[:cap(b)] n, err := m.MarshalToSizedBuffer(b) @@ -1042,12 +1221,15 @@ func (m *PipelineStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, erro } return b[:n], nil } + func (m *PipelineStatus) XXX_Merge(src proto.Message) { xxx_messageInfo_PipelineStatus.Merge(m, src) } + func (m *PipelineStatus) XXX_Size() int { return m.Size() } + func (m *PipelineStatus) XXX_DiscardUnknown() { xxx_messageInfo_PipelineStatus.DiscardUnknown(m) } @@ -1059,9 +1241,11 @@ func (*S3) ProtoMessage() {} func (*S3) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{36} } + func (m *S3) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } + func (m *S3) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { b = b[:cap(b)] n, err := m.MarshalToSizedBuffer(b) @@ -1070,12 +1254,15 @@ func (m *S3) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { } return b[:n], nil } + func (m *S3) XXX_Merge(src proto.Message) { xxx_messageInfo_S3.Merge(m, src) } + func (m *S3) XXX_Size() int { return m.Size() } + func (m *S3) XXX_DiscardUnknown() { xxx_messageInfo_S3.DiscardUnknown(m) } @@ -1087,9 +1274,11 @@ func (*S3Sink) ProtoMessage() {} func (*S3Sink) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{37} } + func (m *S3Sink) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } + func (m *S3Sink) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { b = b[:cap(b)] n, err := m.MarshalToSizedBuffer(b) @@ -1098,12 +1287,15 @@ func (m *S3Sink) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { } return b[:n], nil } + func (m *S3Sink) XXX_Merge(src proto.Message) { xxx_messageInfo_S3Sink.Merge(m, src) } + func (m *S3Sink) XXX_Size() int { return m.Size() } + func (m *S3Sink) XXX_DiscardUnknown() { xxx_messageInfo_S3Sink.DiscardUnknown(m) } @@ -1115,9 +1307,11 @@ func (*S3Source) ProtoMessage() {} func (*S3Source) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{38} } + func (m *S3Source) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } + func (m *S3Source) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { b = b[:cap(b)] n, err := m.MarshalToSizedBuffer(b) @@ -1126,12 +1320,15 @@ func (m *S3Source) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { } return b[:n], nil } + func (m *S3Source) XXX_Merge(src proto.Message) { xxx_messageInfo_S3Source.Merge(m, src) } + func (m *S3Source) XXX_Size() int { return m.Size() } + func (m *S3Source) XXX_DiscardUnknown() { xxx_messageInfo_S3Source.DiscardUnknown(m) } @@ -1143,9 +1340,11 @@ func (*SASL) ProtoMessage() {} func (*SASL) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{39} } + func (m *SASL) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } + func (m *SASL) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { b = b[:cap(b)] n, err := m.MarshalToSizedBuffer(b) @@ -1154,12 +1353,15 @@ func (m *SASL) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { } return b[:n], nil } + func (m *SASL) XXX_Merge(src proto.Message) { xxx_messageInfo_SASL.Merge(m, src) } + func (m *SASL) XXX_Size() int { return m.Size() } + func (m *SASL) XXX_DiscardUnknown() { xxx_messageInfo_SASL.DiscardUnknown(m) } @@ -1171,9 +1373,11 @@ func (*SQLAction) ProtoMessage() {} func (*SQLAction) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{40} } + func (m *SQLAction) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } + func (m *SQLAction) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { b = b[:cap(b)] n, err := m.MarshalToSizedBuffer(b) @@ -1182,12 +1386,15 @@ func (m *SQLAction) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { } return b[:n], nil } + func (m *SQLAction) XXX_Merge(src proto.Message) { xxx_messageInfo_SQLAction.Merge(m, src) } + func (m *SQLAction) XXX_Size() int { return m.Size() } + func (m *SQLAction) XXX_DiscardUnknown() { xxx_messageInfo_SQLAction.DiscardUnknown(m) } @@ -1199,9 +1406,11 @@ func (*SQLStatement) ProtoMessage() {} func (*SQLStatement) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{41} } + func (m *SQLStatement) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } + func (m *SQLStatement) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { b = b[:cap(b)] n, err := m.MarshalToSizedBuffer(b) @@ -1210,12 +1419,15 @@ func (m *SQLStatement) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) } return b[:n], nil } + func (m *SQLStatement) XXX_Merge(src proto.Message) { xxx_messageInfo_SQLStatement.Merge(m, src) } + func (m *SQLStatement) XXX_Size() int { return m.Size() } + func (m *SQLStatement) XXX_DiscardUnknown() { xxx_messageInfo_SQLStatement.DiscardUnknown(m) } @@ -1227,9 +1439,11 @@ func (*STAN) ProtoMessage() {} func (*STAN) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{42} } + func (m *STAN) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } + func (m *STAN) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { b = b[:cap(b)] n, err := m.MarshalToSizedBuffer(b) @@ -1238,12 +1452,15 @@ func (m *STAN) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { } return b[:n], nil } + func (m *STAN) XXX_Merge(src proto.Message) { xxx_messageInfo_STAN.Merge(m, src) } + func (m *STAN) XXX_Size() int { return m.Size() } + func (m *STAN) XXX_DiscardUnknown() { xxx_messageInfo_STAN.DiscardUnknown(m) } @@ -1255,9 +1472,11 @@ func (*STANAuth) ProtoMessage() {} func (*STANAuth) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{43} } + func (m *STANAuth) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } + func (m *STANAuth) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { b = b[:cap(b)] n, err := m.MarshalToSizedBuffer(b) @@ -1266,12 +1485,15 @@ func (m *STANAuth) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { } return b[:n], nil } + func (m *STANAuth) XXX_Merge(src proto.Message) { xxx_messageInfo_STANAuth.Merge(m, src) } + func (m *STANAuth) XXX_Size() int { return m.Size() } + func (m *STANAuth) XXX_DiscardUnknown() { xxx_messageInfo_STANAuth.DiscardUnknown(m) } @@ -1283,9 +1505,11 @@ func (*Scale) ProtoMessage() {} func (*Scale) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{44} } + func (m *Scale) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } + func (m *Scale) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { b = b[:cap(b)] n, err := m.MarshalToSizedBuffer(b) @@ -1294,12 +1518,15 @@ func (m *Scale) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { } return b[:n], nil } + func (m *Scale) XXX_Merge(src proto.Message) { xxx_messageInfo_Scale.Merge(m, src) } + func (m *Scale) XXX_Size() int { return m.Size() } + func (m *Scale) XXX_DiscardUnknown() { xxx_messageInfo_Scale.DiscardUnknown(m) } @@ -1311,9 +1538,11 @@ func (*Sidecar) ProtoMessage() {} func (*Sidecar) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{45} } + func (m *Sidecar) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } + func (m *Sidecar) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { b = b[:cap(b)] n, err := m.MarshalToSizedBuffer(b) @@ -1322,12 +1551,15 @@ func (m *Sidecar) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { } return b[:n], nil } + func (m *Sidecar) XXX_Merge(src proto.Message) { xxx_messageInfo_Sidecar.Merge(m, src) } + func (m *Sidecar) XXX_Size() int { return m.Size() } + func (m *Sidecar) XXX_DiscardUnknown() { xxx_messageInfo_Sidecar.DiscardUnknown(m) } @@ -1339,9 +1571,11 @@ func (*Sink) ProtoMessage() {} func (*Sink) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{46} } + func (m *Sink) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } + func (m *Sink) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { b = b[:cap(b)] n, err := m.MarshalToSizedBuffer(b) @@ -1350,12 +1584,15 @@ func (m *Sink) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { } return b[:n], nil } + func (m *Sink) XXX_Merge(src proto.Message) { xxx_messageInfo_Sink.Merge(m, src) } + func (m *Sink) XXX_Size() int { return m.Size() } + func (m *Sink) XXX_DiscardUnknown() { xxx_messageInfo_Sink.DiscardUnknown(m) } @@ -1367,9 +1604,11 @@ func (*Source) ProtoMessage() {} func (*Source) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{47} } + func (m *Source) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } + func (m *Source) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { b = b[:cap(b)] n, err := m.MarshalToSizedBuffer(b) @@ -1378,12 +1617,15 @@ func (m *Source) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { } return b[:n], nil } + func (m *Source) XXX_Merge(src proto.Message) { xxx_messageInfo_Source.Merge(m, src) } + func (m *Source) XXX_Size() int { return m.Size() } + func (m *Source) XXX_DiscardUnknown() { xxx_messageInfo_Source.DiscardUnknown(m) } @@ -1395,9 +1637,11 @@ func (*SourceStatus) ProtoMessage() {} func (*SourceStatus) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{48} } + func (m *SourceStatus) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } + func (m *SourceStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { b = b[:cap(b)] n, err := m.MarshalToSizedBuffer(b) @@ -1406,12 +1650,15 @@ func (m *SourceStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) } return b[:n], nil } + func (m *SourceStatus) XXX_Merge(src proto.Message) { xxx_messageInfo_SourceStatus.Merge(m, src) } + func (m *SourceStatus) XXX_Size() int { return m.Size() } + func (m *SourceStatus) XXX_DiscardUnknown() { xxx_messageInfo_SourceStatus.DiscardUnknown(m) } @@ -1423,9 +1670,11 @@ func (*Step) ProtoMessage() {} func (*Step) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{49} } + func (m *Step) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } + func (m *Step) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { b = b[:cap(b)] n, err := m.MarshalToSizedBuffer(b) @@ -1434,12 +1683,15 @@ func (m *Step) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { } return b[:n], nil } + func (m *Step) XXX_Merge(src proto.Message) { xxx_messageInfo_Step.Merge(m, src) } + func (m *Step) XXX_Size() int { return m.Size() } + func (m *Step) XXX_DiscardUnknown() { xxx_messageInfo_Step.DiscardUnknown(m) } @@ -1451,9 +1703,11 @@ func (*StepList) ProtoMessage() {} func (*StepList) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{50} } + func (m *StepList) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } + func (m *StepList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { b = b[:cap(b)] n, err := m.MarshalToSizedBuffer(b) @@ -1462,12 +1716,15 @@ func (m *StepList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { } return b[:n], nil } + func (m *StepList) XXX_Merge(src proto.Message) { xxx_messageInfo_StepList.Merge(m, src) } + func (m *StepList) XXX_Size() int { return m.Size() } + func (m *StepList) XXX_DiscardUnknown() { xxx_messageInfo_StepList.DiscardUnknown(m) } @@ -1479,9 +1736,11 @@ func (*StepSpec) ProtoMessage() {} func (*StepSpec) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{51} } + func (m *StepSpec) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } + func (m *StepSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { b = b[:cap(b)] n, err := m.MarshalToSizedBuffer(b) @@ -1490,12 +1749,15 @@ func (m *StepSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { } return b[:n], nil } + func (m *StepSpec) XXX_Merge(src proto.Message) { xxx_messageInfo_StepSpec.Merge(m, src) } + func (m *StepSpec) XXX_Size() int { return m.Size() } + func (m *StepSpec) XXX_DiscardUnknown() { xxx_messageInfo_StepSpec.DiscardUnknown(m) } @@ -1507,9 +1769,11 @@ func (*StepStatus) ProtoMessage() {} func (*StepStatus) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{52} } + func (m *StepStatus) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } + func (m *StepStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { b = b[:cap(b)] n, err := m.MarshalToSizedBuffer(b) @@ -1518,12 +1782,15 @@ func (m *StepStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { } return b[:n], nil } + func (m *StepStatus) XXX_Merge(src proto.Message) { xxx_messageInfo_StepStatus.Merge(m, src) } + func (m *StepStatus) XXX_Size() int { return m.Size() } + func (m *StepStatus) XXX_DiscardUnknown() { xxx_messageInfo_StepStatus.DiscardUnknown(m) } @@ -1535,9 +1802,11 @@ func (*Storage) ProtoMessage() {} func (*Storage) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{53} } + func (m *Storage) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } + func (m *Storage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { b = b[:cap(b)] n, err := m.MarshalToSizedBuffer(b) @@ -1546,12 +1815,15 @@ func (m *Storage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { } return b[:n], nil } + func (m *Storage) XXX_Merge(src proto.Message) { xxx_messageInfo_Storage.Merge(m, src) } + func (m *Storage) XXX_Size() int { return m.Size() } + func (m *Storage) XXX_DiscardUnknown() { xxx_messageInfo_Storage.DiscardUnknown(m) } @@ -1563,9 +1835,11 @@ func (*TLS) ProtoMessage() {} func (*TLS) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{54} } + func (m *TLS) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } + func (m *TLS) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { b = b[:cap(b)] n, err := m.MarshalToSizedBuffer(b) @@ -1574,12 +1848,15 @@ func (m *TLS) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { } return b[:n], nil } + func (m *TLS) XXX_Merge(src proto.Message) { xxx_messageInfo_TLS.Merge(m, src) } + func (m *TLS) XXX_Size() int { return m.Size() } + func (m *TLS) XXX_DiscardUnknown() { xxx_messageInfo_TLS.DiscardUnknown(m) } @@ -4921,6 +5198,7 @@ func encodeVarintGenerated(dAtA []byte, offset int, v uint64) int { dAtA[offset] = uint8(v) return base } + func (m *AWSCredentials) Size() (n int) { if m == nil { return 0 @@ -5989,35 +6267,42 @@ func (m *TLS) Size() (n int) { func sovGenerated(x uint64) (n int) { return (math_bits.Len64(x|1) + 6) / 7 } + func sozGenerated(x uint64) (n int) { return sovGenerated(uint64((x << 1) ^ uint64((int64(x) >> 63)))) } + func (this *AWSCredentials) String() string { if this == nil { return "nil" } - s := strings.Join([]string{`&AWSCredentials{`, + s := strings.Join([]string{ + `&AWSCredentials{`, `AccessKeyID:` + strings.Replace(strings.Replace(fmt.Sprintf("%v", this.AccessKeyID), "SecretKeySelector", "v1.SecretKeySelector", 1), `&`, ``, 1) + `,`, `SecretAccessKey:` + strings.Replace(strings.Replace(fmt.Sprintf("%v", this.SecretAccessKey), "SecretKeySelector", "v1.SecretKeySelector", 1), `&`, ``, 1) + `,`, `}`, }, "") return s } + func (this *AWSEndpoint) String() string { if this == nil { return "nil" } - s := strings.Join([]string{`&AWSEndpoint{`, + s := strings.Join([]string{ + `&AWSEndpoint{`, `URL:` + fmt.Sprintf("%v", this.URL) + `,`, `}`, }, "") return s } + func (this *Backoff) String() string { if this == nil { return "nil" } - s := strings.Join([]string{`&Backoff{`, + s := strings.Join([]string{ + `&Backoff{`, `Steps:` + fmt.Sprintf("%v", this.Steps) + `,`, `Cap:` + strings.Replace(strings.Replace(fmt.Sprintf("%v", this.Cap), "Duration", "v11.Duration", 1), `&`, ``, 1) + `,`, `JitterPercentage:` + fmt.Sprintf("%v", this.JitterPercentage) + `,`, @@ -6027,26 +6312,31 @@ func (this *Backoff) String() string { }, "") return s } + func (this *Cat) String() string { if this == nil { return "nil" } - s := strings.Join([]string{`&Cat{`, + s := strings.Join([]string{ + `&Cat{`, `}`, }, "") return s } + func (this *Code) String() string { if this == nil { return "nil" } - s := strings.Join([]string{`&Code{`, + s := strings.Join([]string{ + `&Code{`, `Source:` + fmt.Sprintf("%v", this.Source) + `,`, `Runtime:` + fmt.Sprintf("%v", this.Runtime) + `,`, `}`, }, "") return s } + func (this *Container) String() string { if this == nil { return "nil" @@ -6061,7 +6351,8 @@ func (this *Container) String() string { repeatedStringForEnv += fmt.Sprintf("%v", f) + "," } repeatedStringForEnv += "}" - s := strings.Join([]string{`&Container{`, + s := strings.Join([]string{ + `&Container{`, `Image:` + fmt.Sprintf("%v", this.Image) + `,`, `In:` + strings.Replace(this.In.String(), "Interface", "Interface", 1) + `,`, `VolumeMounts:` + repeatedStringForVolumeMounts + `,`, @@ -6073,38 +6364,45 @@ func (this *Container) String() string { }, "") return s } + func (this *Cron) String() string { if this == nil { return "nil" } - s := strings.Join([]string{`&Cron{`, + s := strings.Join([]string{ + `&Cron{`, `Schedule:` + fmt.Sprintf("%v", this.Schedule) + `,`, `Layout:` + fmt.Sprintf("%v", this.Layout) + `,`, `}`, }, "") return s } + func (this *DBDataSource) String() string { if this == nil { return "nil" } - s := strings.Join([]string{`&DBDataSource{`, + s := strings.Join([]string{ + `&DBDataSource{`, `Value:` + fmt.Sprintf("%v", this.Value) + `,`, `ValueFrom:` + strings.Replace(this.ValueFrom.String(), "DBDataSourceFrom", "DBDataSourceFrom", 1) + `,`, `}`, }, "") return s } + func (this *DBDataSourceFrom) String() string { if this == nil { return "nil" } - s := strings.Join([]string{`&DBDataSourceFrom{`, + s := strings.Join([]string{ + `&DBDataSourceFrom{`, `SecretKeyRef:` + strings.Replace(fmt.Sprintf("%v", this.SecretKeyRef), "SecretKeySelector", "v1.SecretKeySelector", 1) + `,`, `}`, }, "") return s } + func (this *DBSink) String() string { if this == nil { return "nil" @@ -6114,18 +6412,21 @@ func (this *DBSink) String() string { repeatedStringForActions += strings.Replace(strings.Replace(f.String(), "SQLAction", "SQLAction", 1), `&`, ``, 1) + "," } repeatedStringForActions += "}" - s := strings.Join([]string{`&DBSink{`, + s := strings.Join([]string{ + `&DBSink{`, `Database:` + strings.Replace(strings.Replace(this.Database.String(), "Database", "Database", 1), `&`, ``, 1) + `,`, `Actions:` + repeatedStringForActions + `,`, `}`, }, "") return s } + func (this *DBSource) String() string { if this == nil { return "nil" } - s := strings.Join([]string{`&DBSource{`, + s := strings.Join([]string{ + `&DBSource{`, `Database:` + strings.Replace(strings.Replace(this.Database.String(), "Database", "Database", 1), `&`, ``, 1) + `,`, `Query:` + fmt.Sprintf("%v", this.Query) + `,`, `OffsetColumn:` + fmt.Sprintf("%v", this.OffsetColumn) + `,`, @@ -6136,46 +6437,55 @@ func (this *DBSource) String() string { }, "") return s } + func (this *Database) String() string { if this == nil { return "nil" } - s := strings.Join([]string{`&Database{`, + s := strings.Join([]string{ + `&Database{`, `Driver:` + fmt.Sprintf("%v", this.Driver) + `,`, `DataSource:` + strings.Replace(this.DataSource.String(), "DBDataSource", "DBDataSource", 1) + `,`, `}`, }, "") return s } + func (this *Dedupe) String() string { if this == nil { return "nil" } - s := strings.Join([]string{`&Dedupe{`, + s := strings.Join([]string{ + `&Dedupe{`, `UID:` + fmt.Sprintf("%v", this.UID) + `,`, `MaxSize:` + strings.Replace(strings.Replace(fmt.Sprintf("%v", this.MaxSize), "Quantity", "resource.Quantity", 1), `&`, ``, 1) + `,`, `}`, }, "") return s } + func (this *Expand) String() string { if this == nil { return "nil" } - s := strings.Join([]string{`&Expand{`, + s := strings.Join([]string{ + `&Expand{`, `}`, }, "") return s } + func (this *Flatten) String() string { if this == nil { return "nil" } - s := strings.Join([]string{`&Flatten{`, + s := strings.Join([]string{ + `&Flatten{`, `}`, }, "") return s } + func (this *GetPodSpecReq) String() string { if this == nil { return "nil" @@ -6185,7 +6495,8 @@ func (this *GetPodSpecReq) String() string { repeatedStringForImagePullSecrets += fmt.Sprintf("%v", f) + "," } repeatedStringForImagePullSecrets += "}" - s := strings.Join([]string{`&GetPodSpecReq{`, + s := strings.Join([]string{ + `&GetPodSpecReq{`, `PipelineName:` + fmt.Sprintf("%v", this.PipelineName) + `,`, `Namespace:` + fmt.Sprintf("%v", this.Namespace) + `,`, `Replica:` + fmt.Sprintf("%v", this.Replica) + `,`, @@ -6202,6 +6513,7 @@ func (this *GetPodSpecReq) String() string { }, "") return s } + func (this *Git) String() string { if this == nil { return "nil" @@ -6211,7 +6523,8 @@ func (this *Git) String() string { repeatedStringForEnv += fmt.Sprintf("%v", f) + "," } repeatedStringForEnv += "}" - s := strings.Join([]string{`&Git{`, + s := strings.Join([]string{ + `&Git{`, `Image:` + fmt.Sprintf("%v", this.Image) + `,`, `URL:` + fmt.Sprintf("%v", this.URL) + `,`, `Path:` + fmt.Sprintf("%v", this.Path) + `,`, @@ -6225,11 +6538,13 @@ func (this *Git) String() string { }, "") return s } + func (this *Group) String() string { if this == nil { return "nil" } - s := strings.Join([]string{`&Group{`, + s := strings.Join([]string{ + `&Group{`, `Key:` + fmt.Sprintf("%v", this.Key) + `,`, `EndOfGroup:` + fmt.Sprintf("%v", this.EndOfGroup) + `,`, `Format:` + fmt.Sprintf("%v", this.Format) + `,`, @@ -6238,20 +6553,24 @@ func (this *Group) String() string { }, "") return s } + func (this *HTTP) String() string { if this == nil { return "nil" } - s := strings.Join([]string{`&HTTP{`, + s := strings.Join([]string{ + `&HTTP{`, `}`, }, "") return s } + func (this *HTTPHeader) String() string { if this == nil { return "nil" } - s := strings.Join([]string{`&HTTPHeader{`, + s := strings.Join([]string{ + `&HTTPHeader{`, `Name:` + fmt.Sprintf("%v", this.Name) + `,`, `Value:` + fmt.Sprintf("%v", this.Value) + `,`, `ValueFrom:` + strings.Replace(this.ValueFrom.String(), "HTTPHeaderSource", "HTTPHeaderSource", 1) + `,`, @@ -6259,16 +6578,19 @@ func (this *HTTPHeader) String() string { }, "") return s } + func (this *HTTPHeaderSource) String() string { if this == nil { return "nil" } - s := strings.Join([]string{`&HTTPHeaderSource{`, + s := strings.Join([]string{ + `&HTTPHeaderSource{`, `SecretKeyRef:` + strings.Replace(strings.Replace(fmt.Sprintf("%v", this.SecretKeyRef), "SecretKeySelector", "v1.SecretKeySelector", 1), `&`, ``, 1) + `,`, `}`, }, "") return s } + func (this *HTTPSink) String() string { if this == nil { return "nil" @@ -6278,39 +6600,46 @@ func (this *HTTPSink) String() string { repeatedStringForHeaders += strings.Replace(strings.Replace(f.String(), "HTTPHeader", "HTTPHeader", 1), `&`, ``, 1) + "," } repeatedStringForHeaders += "}" - s := strings.Join([]string{`&HTTPSink{`, + s := strings.Join([]string{ + `&HTTPSink{`, `URL:` + fmt.Sprintf("%v", this.URL) + `,`, `Headers:` + repeatedStringForHeaders + `,`, `}`, }, "") return s } + func (this *HTTPSource) String() string { if this == nil { return "nil" } - s := strings.Join([]string{`&HTTPSource{`, + s := strings.Join([]string{ + `&HTTPSource{`, `ServiceName:` + fmt.Sprintf("%v", this.ServiceName) + `,`, `}`, }, "") return s } + func (this *Interface) String() string { if this == nil { return "nil" } - s := strings.Join([]string{`&Interface{`, + s := strings.Join([]string{ + `&Interface{`, `FIFO:` + fmt.Sprintf("%v", this.FIFO) + `,`, `HTTP:` + strings.Replace(this.HTTP.String(), "HTTP", "HTTP", 1) + `,`, `}`, }, "") return s } + func (this *Kafka) String() string { if this == nil { return "nil" } - s := strings.Join([]string{`&Kafka{`, + s := strings.Join([]string{ + `&Kafka{`, `Name:` + fmt.Sprintf("%v", this.Name) + `,`, `Topic:` + fmt.Sprintf("%v", this.Topic) + `,`, `KafkaConfig:` + strings.Replace(strings.Replace(this.KafkaConfig.String(), "KafkaConfig", "KafkaConfig", 1), `&`, ``, 1) + `,`, @@ -6318,11 +6647,13 @@ func (this *Kafka) String() string { }, "") return s } + func (this *KafkaConfig) String() string { if this == nil { return "nil" } - s := strings.Join([]string{`&KafkaConfig{`, + s := strings.Join([]string{ + `&KafkaConfig{`, `Brokers:` + fmt.Sprintf("%v", this.Brokers) + `,`, `Version:` + fmt.Sprintf("%v", this.Version) + `,`, `NET:` + strings.Replace(this.NET.String(), "KafkaNET", "KafkaNET", 1) + `,`, @@ -6330,49 +6661,58 @@ func (this *KafkaConfig) String() string { }, "") return s } + func (this *KafkaNET) String() string { if this == nil { return "nil" } - s := strings.Join([]string{`&KafkaNET{`, + s := strings.Join([]string{ + `&KafkaNET{`, `TLS:` + strings.Replace(this.TLS.String(), "TLS", "TLS", 1) + `,`, `SASL:` + strings.Replace(this.SASL.String(), "SASL", "SASL", 1) + `,`, `}`, }, "") return s } + func (this *KafkaSink) String() string { if this == nil { return "nil" } - s := strings.Join([]string{`&KafkaSink{`, + s := strings.Join([]string{ + `&KafkaSink{`, `Kafka:` + strings.Replace(strings.Replace(this.Kafka.String(), "Kafka", "Kafka", 1), `&`, ``, 1) + `,`, `Async:` + fmt.Sprintf("%v", this.Async) + `,`, `}`, }, "") return s } + func (this *KafkaSource) String() string { if this == nil { return "nil" } - s := strings.Join([]string{`&KafkaSource{`, + s := strings.Join([]string{ + `&KafkaSource{`, `Kafka:` + strings.Replace(strings.Replace(this.Kafka.String(), "Kafka", "Kafka", 1), `&`, ``, 1) + `,`, `StartOffset:` + fmt.Sprintf("%v", this.StartOffset) + `,`, `}`, }, "") return s } + func (this *Log) String() string { if this == nil { return "nil" } - s := strings.Join([]string{`&Log{`, + s := strings.Join([]string{ + `&Log{`, `Truncate:` + valueToStringGenerated(this.Truncate) + `,`, `}`, }, "") return s } + func (this *Metadata) String() string { if this == nil { return "nil" @@ -6397,18 +6737,21 @@ func (this *Metadata) String() string { mapStringForLabels += fmt.Sprintf("%v: %v,", k, this.Labels[k]) } mapStringForLabels += "}" - s := strings.Join([]string{`&Metadata{`, + s := strings.Join([]string{ + `&Metadata{`, `Annotations:` + mapStringForAnnotations + `,`, `Labels:` + mapStringForLabels + `,`, `}`, }, "") return s } + func (this *Metrics) String() string { if this == nil { return "nil" } - s := strings.Join([]string{`&Metrics{`, + s := strings.Join([]string{ + `&Metrics{`, `Total:` + fmt.Sprintf("%v", this.Total) + `,`, `Errors:` + fmt.Sprintf("%v", this.Errors) + `,`, `Rate:` + strings.Replace(strings.Replace(fmt.Sprintf("%v", this.Rate), "Quantity", "resource.Quantity", 1), `&`, ``, 1) + `,`, @@ -6417,11 +6760,13 @@ func (this *Metrics) String() string { }, "") return s } + func (this *Pipeline) String() string { if this == nil { return "nil" } - s := strings.Join([]string{`&Pipeline{`, + s := strings.Join([]string{ + `&Pipeline{`, `ObjectMeta:` + strings.Replace(strings.Replace(fmt.Sprintf("%v", this.ObjectMeta), "ObjectMeta", "v11.ObjectMeta", 1), `&`, ``, 1) + `,`, `Spec:` + strings.Replace(strings.Replace(this.Spec.String(), "PipelineSpec", "PipelineSpec", 1), `&`, ``, 1) + `,`, `Status:` + strings.Replace(strings.Replace(this.Status.String(), "PipelineStatus", "PipelineStatus", 1), `&`, ``, 1) + `,`, @@ -6429,6 +6774,7 @@ func (this *Pipeline) String() string { }, "") return s } + func (this *PipelineList) String() string { if this == nil { return "nil" @@ -6438,13 +6784,15 @@ func (this *PipelineList) String() string { repeatedStringForItems += strings.Replace(strings.Replace(f.String(), "Pipeline", "Pipeline", 1), `&`, ``, 1) + "," } repeatedStringForItems += "}" - s := strings.Join([]string{`&PipelineList{`, + s := strings.Join([]string{ + `&PipelineList{`, `ListMeta:` + strings.Replace(strings.Replace(fmt.Sprintf("%v", this.ListMeta), "ListMeta", "v11.ListMeta", 1), `&`, ``, 1) + `,`, `Items:` + repeatedStringForItems + `,`, `}`, }, "") return s } + func (this *PipelineSpec) String() string { if this == nil { return "nil" @@ -6454,12 +6802,14 @@ func (this *PipelineSpec) String() string { repeatedStringForSteps += strings.Replace(strings.Replace(f.String(), "StepSpec", "StepSpec", 1), `&`, ``, 1) + "," } repeatedStringForSteps += "}" - s := strings.Join([]string{`&PipelineSpec{`, + s := strings.Join([]string{ + `&PipelineSpec{`, `Steps:` + repeatedStringForSteps + `,`, `}`, }, "") return s } + func (this *PipelineStatus) String() string { if this == nil { return "nil" @@ -6469,7 +6819,8 @@ func (this *PipelineStatus) String() string { repeatedStringForConditions += fmt.Sprintf("%v", f) + "," } repeatedStringForConditions += "}" - s := strings.Join([]string{`&PipelineStatus{`, + s := strings.Join([]string{ + `&PipelineStatus{`, `Phase:` + fmt.Sprintf("%v", this.Phase) + `,`, `Message:` + fmt.Sprintf("%v", this.Message) + `,`, `Conditions:` + repeatedStringForConditions + `,`, @@ -6478,11 +6829,13 @@ func (this *PipelineStatus) String() string { }, "") return s } + func (this *S3) String() string { if this == nil { return "nil" } - s := strings.Join([]string{`&S3{`, + s := strings.Join([]string{ + `&S3{`, `Name:` + fmt.Sprintf("%v", this.Name) + `,`, `Bucket:` + fmt.Sprintf("%v", this.Bucket) + `,`, `Region:` + fmt.Sprintf("%v", this.Region) + `,`, @@ -6492,32 +6845,38 @@ func (this *S3) String() string { }, "") return s } + func (this *S3Sink) String() string { if this == nil { return "nil" } - s := strings.Join([]string{`&S3Sink{`, + s := strings.Join([]string{ + `&S3Sink{`, `S3:` + strings.Replace(strings.Replace(this.S3.String(), "S3", "S3", 1), `&`, ``, 1) + `,`, `}`, }, "") return s } + func (this *S3Source) String() string { if this == nil { return "nil" } - s := strings.Join([]string{`&S3Source{`, + s := strings.Join([]string{ + `&S3Source{`, `PollPeriod:` + strings.Replace(strings.Replace(fmt.Sprintf("%v", this.PollPeriod), "Duration", "v11.Duration", 1), `&`, ``, 1) + `,`, `S3:` + strings.Replace(strings.Replace(this.S3.String(), "S3", "S3", 1), `&`, ``, 1) + `,`, `}`, }, "") return s } + func (this *SASL) String() string { if this == nil { return "nil" } - s := strings.Join([]string{`&SASL{`, + s := strings.Join([]string{ + `&SASL{`, `Mechanism:` + fmt.Sprintf("%v", this.Mechanism) + `,`, `UserSecret:` + strings.Replace(fmt.Sprintf("%v", this.UserSecret), "SecretKeySelector", "v1.SecretKeySelector", 1) + `,`, `PasswordSecret:` + strings.Replace(fmt.Sprintf("%v", this.PasswordSecret), "SecretKeySelector", "v1.SecretKeySelector", 1) + `,`, @@ -6525,11 +6884,13 @@ func (this *SASL) String() string { }, "") return s } + func (this *SQLAction) String() string { if this == nil { return "nil" } - s := strings.Join([]string{`&SQLAction{`, + s := strings.Join([]string{ + `&SQLAction{`, `SQLStatement:` + strings.Replace(strings.Replace(this.SQLStatement.String(), "SQLStatement", "SQLStatement", 1), `&`, ``, 1) + `,`, `OnRecordNotFound:` + strings.Replace(this.OnRecordNotFound.String(), "SQLStatement", "SQLStatement", 1) + `,`, `OnError:` + strings.Replace(this.OnError.String(), "SQLStatement", "SQLStatement", 1) + `,`, @@ -6537,22 +6898,26 @@ func (this *SQLAction) String() string { }, "") return s } + func (this *SQLStatement) String() string { if this == nil { return "nil" } - s := strings.Join([]string{`&SQLStatement{`, + s := strings.Join([]string{ + `&SQLStatement{`, `SQL:` + fmt.Sprintf("%v", this.SQL) + `,`, `Args:` + fmt.Sprintf("%v", this.Args) + `,`, `}`, }, "") return s } + func (this *STAN) String() string { if this == nil { return "nil" } - s := strings.Join([]string{`&STAN{`, + s := strings.Join([]string{ + `&STAN{`, `Name:` + fmt.Sprintf("%v", this.Name) + `,`, `Subject:` + fmt.Sprintf("%v", this.Subject) + `,`, `NATSURL:` + fmt.Sprintf("%v", this.NATSURL) + `,`, @@ -6565,21 +6930,25 @@ func (this *STAN) String() string { }, "") return s } + func (this *STANAuth) String() string { if this == nil { return "nil" } - s := strings.Join([]string{`&STANAuth{`, + s := strings.Join([]string{ + `&STANAuth{`, `Token:` + strings.Replace(fmt.Sprintf("%v", this.Token), "SecretKeySelector", "v1.SecretKeySelector", 1) + `,`, `}`, }, "") return s } + func (this *Scale) String() string { if this == nil { return "nil" } - s := strings.Join([]string{`&Scale{`, + s := strings.Join([]string{ + `&Scale{`, `MinReplicas:` + fmt.Sprintf("%v", this.MinReplicas) + `,`, `MaxReplicas:` + valueToStringGenerated(this.MaxReplicas) + `,`, `ReplicaRatio:` + fmt.Sprintf("%v", this.ReplicaRatio) + `,`, @@ -6587,21 +6956,25 @@ func (this *Scale) String() string { }, "") return s } + func (this *Sidecar) String() string { if this == nil { return "nil" } - s := strings.Join([]string{`&Sidecar{`, + s := strings.Join([]string{ + `&Sidecar{`, `Resources:` + strings.Replace(strings.Replace(fmt.Sprintf("%v", this.Resources), "ResourceRequirements", "v1.ResourceRequirements", 1), `&`, ``, 1) + `,`, `}`, }, "") return s } + func (this *Sink) String() string { if this == nil { return "nil" } - s := strings.Join([]string{`&Sink{`, + s := strings.Join([]string{ + `&Sink{`, `Name:` + fmt.Sprintf("%v", this.Name) + `,`, `STAN:` + strings.Replace(this.STAN.String(), "STAN", "STAN", 1) + `,`, `Kafka:` + strings.Replace(this.Kafka.String(), "KafkaSink", "KafkaSink", 1) + `,`, @@ -6613,11 +6986,13 @@ func (this *Sink) String() string { }, "") return s } + func (this *Source) String() string { if this == nil { return "nil" } - s := strings.Join([]string{`&Source{`, + s := strings.Join([]string{ + `&Source{`, `Name:` + fmt.Sprintf("%v", this.Name) + `,`, `Cron:` + strings.Replace(this.Cron.String(), "Cron", "Cron", 1) + `,`, `STAN:` + strings.Replace(this.STAN.String(), "STAN", "STAN", 1) + `,`, @@ -6630,6 +7005,7 @@ func (this *Source) String() string { }, "") return s } + func (this *SourceStatus) String() string { if this == nil { return "nil" @@ -6644,18 +7020,21 @@ func (this *SourceStatus) String() string { mapStringForMetrics += fmt.Sprintf("%v: %v,", k, this.Metrics[k]) } mapStringForMetrics += "}" - s := strings.Join([]string{`&SourceStatus{`, + s := strings.Join([]string{ + `&SourceStatus{`, `Pending:` + valueToStringGenerated(this.Pending) + `,`, `Metrics:` + mapStringForMetrics + `,`, `}`, }, "") return s } + func (this *Step) String() string { if this == nil { return "nil" } - s := strings.Join([]string{`&Step{`, + s := strings.Join([]string{ + `&Step{`, `ObjectMeta:` + strings.Replace(strings.Replace(fmt.Sprintf("%v", this.ObjectMeta), "ObjectMeta", "v11.ObjectMeta", 1), `&`, ``, 1) + `,`, `Spec:` + strings.Replace(strings.Replace(this.Spec.String(), "StepSpec", "StepSpec", 1), `&`, ``, 1) + `,`, `Status:` + strings.Replace(strings.Replace(this.Status.String(), "StepStatus", "StepStatus", 1), `&`, ``, 1) + `,`, @@ -6663,6 +7042,7 @@ func (this *Step) String() string { }, "") return s } + func (this *StepList) String() string { if this == nil { return "nil" @@ -6672,13 +7052,15 @@ func (this *StepList) String() string { repeatedStringForItems += strings.Replace(strings.Replace(f.String(), "Step", "Step", 1), `&`, ``, 1) + "," } repeatedStringForItems += "}" - s := strings.Join([]string{`&StepList{`, + s := strings.Join([]string{ + `&StepList{`, `ListMeta:` + strings.Replace(strings.Replace(fmt.Sprintf("%v", this.ListMeta), "ListMeta", "v11.ListMeta", 1), `&`, ``, 1) + `,`, `Items:` + repeatedStringForItems + `,`, `}`, }, "") return s } + func (this *StepSpec) String() string { if this == nil { return "nil" @@ -6718,7 +7100,8 @@ func (this *StepSpec) String() string { mapStringForNodeSelector += fmt.Sprintf("%v: %v,", k, this.NodeSelector[k]) } mapStringForNodeSelector += "}" - s := strings.Join([]string{`&StepSpec{`, + s := strings.Join([]string{ + `&StepSpec{`, `Container:` + strings.Replace(this.Container.String(), "Container", "Container", 1) + `,`, `Sources:` + repeatedStringForSources + `,`, `Sinks:` + repeatedStringForSinks + `,`, @@ -6748,6 +7131,7 @@ func (this *StepSpec) String() string { }, "") return s } + func (this *StepStatus) String() string { if this == nil { return "nil" @@ -6772,7 +7156,8 @@ func (this *StepStatus) String() string { mapStringForSinkStatues += fmt.Sprintf("%v: %v,", k, this.SinkStatues[k]) } mapStringForSinkStatues += "}" - s := strings.Join([]string{`&StepStatus{`, + s := strings.Join([]string{ + `&StepStatus{`, `Phase:` + fmt.Sprintf("%v", this.Phase) + `,`, `Message:` + fmt.Sprintf("%v", this.Message) + `,`, `SourceStatuses:` + mapStringForSourceStatuses + `,`, @@ -6785,22 +7170,26 @@ func (this *StepStatus) String() string { }, "") return s } + func (this *Storage) String() string { if this == nil { return "nil" } - s := strings.Join([]string{`&Storage{`, + s := strings.Join([]string{ + `&Storage{`, `Name:` + fmt.Sprintf("%v", this.Name) + `,`, `SubPath:` + fmt.Sprintf("%v", this.SubPath) + `,`, `}`, }, "") return s } + func (this *TLS) String() string { if this == nil { return "nil" } - s := strings.Join([]string{`&TLS{`, + s := strings.Join([]string{ + `&TLS{`, `CACertSecret:` + strings.Replace(fmt.Sprintf("%v", this.CACertSecret), "SecretKeySelector", "v1.SecretKeySelector", 1) + `,`, `CertSecret:` + strings.Replace(fmt.Sprintf("%v", this.CertSecret), "SecretKeySelector", "v1.SecretKeySelector", 1) + `,`, `KeySecret:` + strings.Replace(fmt.Sprintf("%v", this.KeySecret), "SecretKeySelector", "v1.SecretKeySelector", 1) + `,`, @@ -6808,6 +7197,7 @@ func (this *TLS) String() string { }, "") return s } + func valueToStringGenerated(v interface{}) string { rv := reflect.ValueOf(v) if rv.IsNil() { @@ -6816,6 +7206,7 @@ func valueToStringGenerated(v interface{}) string { pv := reflect.Indirect(rv).Interface() return fmt.Sprintf("*%v", pv) } + func (m *AWSCredentials) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -6932,6 +7323,7 @@ func (m *AWSCredentials) Unmarshal(dAtA []byte) error { } return nil } + func (m *AWSEndpoint) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -7014,6 +7406,7 @@ func (m *AWSEndpoint) Unmarshal(dAtA []byte) error { } return nil } + func (m *Backoff) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -7187,6 +7580,7 @@ func (m *Backoff) Unmarshal(dAtA []byte) error { } return nil } + func (m *Cat) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -7237,6 +7631,7 @@ func (m *Cat) Unmarshal(dAtA []byte) error { } return nil } + func (m *Code) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -7351,6 +7746,7 @@ func (m *Code) Unmarshal(dAtA []byte) error { } return nil } + func (m *Container) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -7634,6 +8030,7 @@ func (m *Container) Unmarshal(dAtA []byte) error { } return nil } + func (m *Cron) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -7748,6 +8145,7 @@ func (m *Cron) Unmarshal(dAtA []byte) error { } return nil } + func (m *DBDataSource) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -7866,6 +8264,7 @@ func (m *DBDataSource) Unmarshal(dAtA []byte) error { } return nil } + func (m *DBDataSourceFrom) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -7952,6 +8351,7 @@ func (m *DBDataSourceFrom) Unmarshal(dAtA []byte) error { } return nil } + func (m *DBSink) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -8069,6 +8469,7 @@ func (m *DBSink) Unmarshal(dAtA []byte) error { } return nil } + func (m *DBSource) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -8302,6 +8703,7 @@ func (m *DBSource) Unmarshal(dAtA []byte) error { } return nil } + func (m *Database) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -8420,6 +8822,7 @@ func (m *Database) Unmarshal(dAtA []byte) error { } return nil } + func (m *Dedupe) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -8535,6 +8938,7 @@ func (m *Dedupe) Unmarshal(dAtA []byte) error { } return nil } + func (m *Expand) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -8585,6 +8989,7 @@ func (m *Expand) Unmarshal(dAtA []byte) error { } return nil } + func (m *Flatten) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -8635,6 +9040,7 @@ func (m *Flatten) Unmarshal(dAtA []byte) error { } return nil } + func (m *GetPodSpecReq) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -9035,6 +9441,7 @@ func (m *GetPodSpecReq) Unmarshal(dAtA []byte) error { } return nil } + func (m *Git) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -9387,6 +9794,7 @@ func (m *Git) Unmarshal(dAtA []byte) error { } return nil } + func (m *Group) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -9569,6 +9977,7 @@ func (m *Group) Unmarshal(dAtA []byte) error { } return nil } + func (m *HTTP) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -9619,6 +10028,7 @@ func (m *HTTP) Unmarshal(dAtA []byte) error { } return nil } + func (m *HTTPHeader) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -9769,6 +10179,7 @@ func (m *HTTPHeader) Unmarshal(dAtA []byte) error { } return nil } + func (m *HTTPHeaderSource) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -9852,6 +10263,7 @@ func (m *HTTPHeaderSource) Unmarshal(dAtA []byte) error { } return nil } + func (m *HTTPSink) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -9968,6 +10380,7 @@ func (m *HTTPSink) Unmarshal(dAtA []byte) error { } return nil } + func (m *HTTPSource) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -10050,6 +10463,7 @@ func (m *HTTPSource) Unmarshal(dAtA []byte) error { } return nil } + func (m *Interface) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -10156,6 +10570,7 @@ func (m *Interface) Unmarshal(dAtA []byte) error { } return nil } + func (m *Kafka) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -10303,6 +10718,7 @@ func (m *Kafka) Unmarshal(dAtA []byte) error { } return nil } + func (m *KafkaConfig) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -10453,6 +10869,7 @@ func (m *KafkaConfig) Unmarshal(dAtA []byte) error { } return nil } + func (m *KafkaNET) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -10575,6 +10992,7 @@ func (m *KafkaNET) Unmarshal(dAtA []byte) error { } return nil } + func (m *KafkaSink) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -10678,6 +11096,7 @@ func (m *KafkaSink) Unmarshal(dAtA []byte) error { } return nil } + func (m *KafkaSource) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -10793,6 +11212,7 @@ func (m *KafkaSource) Unmarshal(dAtA []byte) error { } return nil } + func (m *Log) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -10863,6 +11283,7 @@ func (m *Log) Unmarshal(dAtA []byte) error { } return nil } + func (m *Metadata) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -11167,6 +11588,7 @@ func (m *Metadata) Unmarshal(dAtA []byte) error { } return nil } + func (m *Metrics) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -11307,6 +11729,7 @@ func (m *Metrics) Unmarshal(dAtA []byte) error { } return nil } + func (m *Pipeline) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -11456,6 +11879,7 @@ func (m *Pipeline) Unmarshal(dAtA []byte) error { } return nil } + func (m *PipelineList) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -11573,6 +11997,7 @@ func (m *PipelineList) Unmarshal(dAtA []byte) error { } return nil } + func (m *PipelineSpec) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -11657,6 +12082,7 @@ func (m *PipelineSpec) Unmarshal(dAtA []byte) error { } return nil } + func (m *PipelineStatus) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -11838,6 +12264,7 @@ func (m *PipelineStatus) Unmarshal(dAtA []byte) error { } return nil } + func (m *S3) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -12056,6 +12483,7 @@ func (m *S3) Unmarshal(dAtA []byte) error { } return nil } + func (m *S3Sink) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -12139,6 +12567,7 @@ func (m *S3Sink) Unmarshal(dAtA []byte) error { } return nil } + func (m *S3Source) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -12255,6 +12684,7 @@ func (m *S3Source) Unmarshal(dAtA []byte) error { } return nil } + func (m *SASL) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -12409,6 +12839,7 @@ func (m *SASL) Unmarshal(dAtA []byte) error { } return nil } + func (m *SQLAction) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -12564,6 +12995,7 @@ func (m *SQLAction) Unmarshal(dAtA []byte) error { } return nil } + func (m *SQLStatement) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -12678,6 +13110,7 @@ func (m *SQLStatement) Unmarshal(dAtA []byte) error { } return nil } + func (m *STAN) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -12975,6 +13408,7 @@ func (m *STAN) Unmarshal(dAtA []byte) error { } return nil } + func (m *STANAuth) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -13061,6 +13495,7 @@ func (m *STANAuth) Unmarshal(dAtA []byte) error { } return nil } + func (m *Scale) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -13169,6 +13604,7 @@ func (m *Scale) Unmarshal(dAtA []byte) error { } return nil } + func (m *Sidecar) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -13252,6 +13688,7 @@ func (m *Sidecar) Unmarshal(dAtA []byte) error { } return nil } + func (m *Sink) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -13550,6 +13987,7 @@ func (m *Sink) Unmarshal(dAtA []byte) error { } return nil } + func (m *Source) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -13881,6 +14319,7 @@ func (m *Source) Unmarshal(dAtA []byte) error { } return nil } + func (m *SourceStatus) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -14080,6 +14519,7 @@ func (m *SourceStatus) Unmarshal(dAtA []byte) error { } return nil } + func (m *Step) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -14229,6 +14669,7 @@ func (m *Step) Unmarshal(dAtA []byte) error { } return nil } + func (m *StepList) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -14346,6 +14787,7 @@ func (m *StepList) Unmarshal(dAtA []byte) error { } return nil } + func (m *StepSpec) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -15321,6 +15763,7 @@ func (m *StepSpec) Unmarshal(dAtA []byte) error { } return nil } + func (m *StepStatus) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -15809,6 +16252,7 @@ func (m *StepStatus) Unmarshal(dAtA []byte) error { } return nil } + func (m *Storage) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -15923,6 +16367,7 @@ func (m *Storage) Unmarshal(dAtA []byte) error { } return nil } + func (m *TLS) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -16081,6 +16526,7 @@ func (m *TLS) Unmarshal(dAtA []byte) error { } return nil } + func skipGenerated(dAtA []byte) (n int, err error) { l := len(dAtA) iNdEx := 0 diff --git a/runner/main.go b/runner/main.go index c2f9fe66..410c1100 100644 --- a/runner/main.go +++ b/runner/main.go @@ -4,6 +4,11 @@ import ( "context" "errors" "fmt" + "io/ioutil" + "net/http" + "net/http/pprof" + "os" + dfv1 "github.com/argoproj-labs/argo-dataflow/api/v1alpha1" "github.com/argoproj-labs/argo-dataflow/runner/cat" "github.com/argoproj-labs/argo-dataflow/runner/dedupe" @@ -17,11 +22,8 @@ import ( "github.com/argoproj-labs/argo-dataflow/runner/sleep" "github.com/argoproj-labs/argo-dataflow/sdks/golang" sharedutil "github.com/argoproj-labs/argo-dataflow/shared/util" - "io/ioutil" + "k8s.io/apimachinery/pkg/api/resource" - "net/http" - "net/http/pprof" - "os" ) var logger = sharedutil.NewLogger()