From 0fe072e335ffe3a5d805b3f9b33cbd301c5fda9e Mon Sep 17 00:00:00 2001 From: Alex Collins Date: Thu, 16 Sep 2021 09:47:15 -0700 Subject: [PATCH] fix: Remove Golang SDK dependencies --- api/v1alpha1/generated.pb.go | 624 +++++++++++++++++++++++++++++++---- sdks/golang/start.go | 17 +- 2 files changed, 574 insertions(+), 67 deletions(-) diff --git a/api/v1alpha1/generated.pb.go b/api/v1alpha1/generated.pb.go index 80ff7550..aa9175bd 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 (*AbstractStep) ProtoMessage() {} func (*AbstractStep) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{2} } + func (m *AbstractStep) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } + func (m *AbstractStep) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { b = b[:cap(b)] n, err := m.MarshalToSizedBuffer(b) @@ -118,12 +132,15 @@ func (m *AbstractStep) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) } return b[:n], nil } + func (m *AbstractStep) XXX_Merge(src proto.Message) { xxx_messageInfo_AbstractStep.Merge(m, src) } + func (m *AbstractStep) XXX_Size() int { return m.Size() } + func (m *AbstractStep) XXX_DiscardUnknown() { xxx_messageInfo_AbstractStep.DiscardUnknown(m) } @@ -135,9 +152,11 @@ func (*AbstractVolumeSource) ProtoMessage() {} func (*AbstractVolumeSource) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{3} } + func (m *AbstractVolumeSource) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } + func (m *AbstractVolumeSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { b = b[:cap(b)] n, err := m.MarshalToSizedBuffer(b) @@ -146,12 +165,15 @@ func (m *AbstractVolumeSource) XXX_Marshal(b []byte, deterministic bool) ([]byte } return b[:n], nil } + func (m *AbstractVolumeSource) XXX_Merge(src proto.Message) { xxx_messageInfo_AbstractVolumeSource.Merge(m, src) } + func (m *AbstractVolumeSource) XXX_Size() int { return m.Size() } + func (m *AbstractVolumeSource) XXX_DiscardUnknown() { xxx_messageInfo_AbstractVolumeSource.DiscardUnknown(m) } @@ -163,9 +185,11 @@ func (*Backoff) ProtoMessage() {} func (*Backoff) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{4} } + 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) @@ -174,12 +198,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) } @@ -191,9 +218,11 @@ func (*Cat) ProtoMessage() {} func (*Cat) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{5} } + 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) @@ -202,12 +231,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) } @@ -219,9 +251,11 @@ func (*Code) ProtoMessage() {} func (*Code) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{6} } + 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) @@ -230,12 +264,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) } @@ -247,9 +284,11 @@ func (*Container) ProtoMessage() {} func (*Container) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{7} } + 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) @@ -258,12 +297,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) } @@ -275,9 +317,11 @@ func (*Cron) ProtoMessage() {} func (*Cron) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{8} } + 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) @@ -286,12 +330,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) } @@ -303,9 +350,11 @@ func (*DBDataSource) ProtoMessage() {} func (*DBDataSource) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{9} } + 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) @@ -314,12 +363,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) } @@ -331,9 +383,11 @@ func (*DBDataSourceFrom) ProtoMessage() {} func (*DBDataSourceFrom) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{10} } + 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) @@ -342,12 +396,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) } @@ -359,9 +416,11 @@ func (*DBSink) ProtoMessage() {} func (*DBSink) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{11} } + 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) @@ -370,12 +429,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) } @@ -387,9 +449,11 @@ func (*DBSource) ProtoMessage() {} func (*DBSource) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{12} } + 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) @@ -398,12 +462,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) } @@ -415,9 +482,11 @@ func (*Database) ProtoMessage() {} func (*Database) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{13} } + 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) @@ -426,12 +495,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) } @@ -443,9 +515,11 @@ func (*Dedupe) ProtoMessage() {} func (*Dedupe) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{14} } + 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) @@ -454,12 +528,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) } @@ -471,9 +548,11 @@ func (*Expand) ProtoMessage() {} func (*Expand) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{15} } + 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) @@ -482,12 +561,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) } @@ -499,9 +581,11 @@ func (*Filter) ProtoMessage() {} func (*Filter) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{16} } + func (m *Filter) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } + func (m *Filter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { b = b[:cap(b)] n, err := m.MarshalToSizedBuffer(b) @@ -510,12 +594,15 @@ func (m *Filter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { } return b[:n], nil } + func (m *Filter) XXX_Merge(src proto.Message) { xxx_messageInfo_Filter.Merge(m, src) } + func (m *Filter) XXX_Size() int { return m.Size() } + func (m *Filter) XXX_DiscardUnknown() { xxx_messageInfo_Filter.DiscardUnknown(m) } @@ -527,9 +614,11 @@ func (*Flatten) ProtoMessage() {} func (*Flatten) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{17} } + 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) @@ -538,12 +627,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) } @@ -555,9 +647,11 @@ func (*GetPodSpecReq) ProtoMessage() {} func (*GetPodSpecReq) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{18} } + 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) @@ -566,12 +660,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) } @@ -583,9 +680,11 @@ func (*Git) ProtoMessage() {} func (*Git) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{19} } + 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) @@ -594,12 +693,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) } @@ -611,9 +713,11 @@ func (*Group) ProtoMessage() {} func (*Group) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{20} } + 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) @@ -622,12 +726,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) } @@ -639,9 +746,11 @@ func (*HTTP) ProtoMessage() {} func (*HTTP) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{21} } + 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) @@ -650,12 +759,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) } @@ -667,9 +779,11 @@ func (*HTTPHeader) ProtoMessage() {} func (*HTTPHeader) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{22} } + 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) @@ -678,12 +792,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) } @@ -695,9 +812,11 @@ func (*HTTPHeaderSource) ProtoMessage() {} func (*HTTPHeaderSource) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{23} } + 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) @@ -706,12 +825,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) } @@ -723,9 +845,11 @@ func (*HTTPSink) ProtoMessage() {} func (*HTTPSink) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{24} } + 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) @@ -734,12 +858,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) } @@ -751,9 +878,11 @@ func (*HTTPSource) ProtoMessage() {} func (*HTTPSource) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{25} } + 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) @@ -762,12 +891,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) } @@ -779,9 +911,11 @@ func (*Interface) ProtoMessage() {} func (*Interface) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{26} } + 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) @@ -790,12 +924,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) } @@ -807,9 +944,11 @@ func (*Kafka) ProtoMessage() {} func (*Kafka) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{27} } + 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) @@ -818,12 +957,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) } @@ -835,9 +977,11 @@ func (*KafkaConfig) ProtoMessage() {} func (*KafkaConfig) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{28} } + 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) @@ -846,12 +990,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) } @@ -863,9 +1010,11 @@ func (*KafkaNET) ProtoMessage() {} func (*KafkaNET) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{29} } + 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) @@ -874,12 +1023,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) } @@ -891,9 +1043,11 @@ func (*KafkaSink) ProtoMessage() {} func (*KafkaSink) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{30} } + 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) @@ -902,12 +1056,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) } @@ -919,9 +1076,11 @@ func (*KafkaSource) ProtoMessage() {} func (*KafkaSource) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{31} } + 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) @@ -930,12 +1089,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) } @@ -947,9 +1109,11 @@ func (*Log) ProtoMessage() {} func (*Log) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{32} } + 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) @@ -958,12 +1122,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) } @@ -975,9 +1142,11 @@ func (*Map) ProtoMessage() {} func (*Map) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{33} } + func (m *Map) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } + func (m *Map) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { b = b[:cap(b)] n, err := m.MarshalToSizedBuffer(b) @@ -986,12 +1155,15 @@ func (m *Map) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { } return b[:n], nil } + func (m *Map) XXX_Merge(src proto.Message) { xxx_messageInfo_Map.Merge(m, src) } + func (m *Map) XXX_Size() int { return m.Size() } + func (m *Map) XXX_DiscardUnknown() { xxx_messageInfo_Map.DiscardUnknown(m) } @@ -1003,9 +1175,11 @@ func (*Metadata) ProtoMessage() {} func (*Metadata) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{34} } + 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) @@ -1014,12 +1188,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) } @@ -1031,9 +1208,11 @@ func (*Metrics) ProtoMessage() {} func (*Metrics) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{35} } + 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) @@ -1042,12 +1221,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) } @@ -1059,9 +1241,11 @@ func (*Pipeline) ProtoMessage() {} func (*Pipeline) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{36} } + 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) @@ -1070,12 +1254,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) } @@ -1087,9 +1274,11 @@ func (*PipelineList) ProtoMessage() {} func (*PipelineList) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{37} } + 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) @@ -1098,12 +1287,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) } @@ -1115,9 +1307,11 @@ func (*PipelineSpec) ProtoMessage() {} func (*PipelineSpec) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{38} } + 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) @@ -1126,12 +1320,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) } @@ -1143,9 +1340,11 @@ func (*PipelineStatus) ProtoMessage() {} func (*PipelineStatus) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{39} } + 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) @@ -1154,12 +1353,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) } @@ -1171,9 +1373,11 @@ func (*S3) ProtoMessage() {} func (*S3) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{40} } + 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) @@ -1182,12 +1386,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) } @@ -1199,9 +1406,11 @@ func (*S3Sink) ProtoMessage() {} func (*S3Sink) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{41} } + 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) @@ -1210,12 +1419,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) } @@ -1227,9 +1439,11 @@ func (*S3Source) ProtoMessage() {} func (*S3Source) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{42} } + 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) @@ -1238,12 +1452,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) } @@ -1255,9 +1472,11 @@ func (*SASL) ProtoMessage() {} func (*SASL) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{43} } + 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) @@ -1266,12 +1485,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) } @@ -1283,9 +1505,11 @@ func (*SQLAction) ProtoMessage() {} func (*SQLAction) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{44} } + 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) @@ -1294,12 +1518,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) } @@ -1311,9 +1538,11 @@ func (*SQLStatement) ProtoMessage() {} func (*SQLStatement) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{45} } + 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) @@ -1322,12 +1551,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) } @@ -1339,9 +1571,11 @@ func (*STAN) ProtoMessage() {} func (*STAN) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{46} } + 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) @@ -1350,12 +1584,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) } @@ -1367,9 +1604,11 @@ func (*STANAuth) ProtoMessage() {} func (*STANAuth) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{47} } + 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) @@ -1378,12 +1617,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) } @@ -1395,9 +1637,11 @@ func (*Scale) ProtoMessage() {} func (*Scale) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{48} } + 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) @@ -1406,12 +1650,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) } @@ -1423,9 +1670,11 @@ func (*Sidecar) ProtoMessage() {} func (*Sidecar) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{49} } + 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) @@ -1434,12 +1683,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) } @@ -1451,9 +1703,11 @@ func (*Sink) ProtoMessage() {} func (*Sink) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{50} } + 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) @@ -1462,12 +1716,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) } @@ -1479,9 +1736,11 @@ func (*Source) ProtoMessage() {} func (*Source) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{51} } + 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) @@ -1490,12 +1749,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) } @@ -1507,9 +1769,11 @@ func (*SourceStatus) ProtoMessage() {} func (*SourceStatus) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{52} } + 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) @@ -1518,12 +1782,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) } @@ -1535,9 +1802,11 @@ func (*Step) ProtoMessage() {} func (*Step) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{53} } + 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) @@ -1546,12 +1815,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) } @@ -1563,9 +1835,11 @@ func (*StepList) ProtoMessage() {} func (*StepList) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{54} } + 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) @@ -1574,12 +1848,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) } @@ -1591,9 +1868,11 @@ func (*StepSpec) ProtoMessage() {} func (*StepSpec) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{55} } + 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) @@ -1602,12 +1881,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) } @@ -1619,9 +1901,11 @@ func (*StepStatus) ProtoMessage() {} func (*StepStatus) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{56} } + 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) @@ -1630,12 +1914,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) } @@ -1647,9 +1934,11 @@ func (*Storage) ProtoMessage() {} func (*Storage) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{57} } + 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) @@ -1658,12 +1947,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) } @@ -1675,9 +1967,11 @@ func (*TLS) ProtoMessage() {} func (*TLS) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{58} } + 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) @@ -1686,12 +1980,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) } @@ -1703,9 +2000,11 @@ func (*VolumeSink) ProtoMessage() {} func (*VolumeSink) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{59} } + func (m *VolumeSink) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } + func (m *VolumeSink) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { b = b[:cap(b)] n, err := m.MarshalToSizedBuffer(b) @@ -1714,12 +2013,15 @@ func (m *VolumeSink) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { } return b[:n], nil } + func (m *VolumeSink) XXX_Merge(src proto.Message) { xxx_messageInfo_VolumeSink.Merge(m, src) } + func (m *VolumeSink) XXX_Size() int { return m.Size() } + func (m *VolumeSink) XXX_DiscardUnknown() { xxx_messageInfo_VolumeSink.DiscardUnknown(m) } @@ -1731,9 +2033,11 @@ func (*VolumeSource) ProtoMessage() {} func (*VolumeSource) Descriptor() ([]byte, []int) { return fileDescriptor_7a4218a80d7ff35f, []int{60} } + func (m *VolumeSource) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } + func (m *VolumeSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { b = b[:cap(b)] n, err := m.MarshalToSizedBuffer(b) @@ -1742,12 +2046,15 @@ func (m *VolumeSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) } return b[:n], nil } + func (m *VolumeSource) XXX_Merge(src proto.Message) { xxx_messageInfo_VolumeSource.Merge(m, src) } + func (m *VolumeSource) XXX_Size() int { return m.Size() } + func (m *VolumeSource) XXX_DiscardUnknown() { xxx_messageInfo_VolumeSource.DiscardUnknown(m) } @@ -5885,6 +6192,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 @@ -7181,14 +7489,17 @@ func (m *VolumeSource) 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) + `,`, `SessionToken:` + strings.Replace(strings.Replace(fmt.Sprintf("%v", this.SessionToken), "SecretKeySelector", "v1.SecretKeySelector", 1), `&`, ``, 1) + `,`, @@ -7196,31 +7507,37 @@ func (this *AWSCredentials) String() string { }, "") 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 *AbstractStep) String() string { if this == nil { return "nil" } - s := strings.Join([]string{`&AbstractStep{`, + s := strings.Join([]string{ + `&AbstractStep{`, `Resources:` + strings.Replace(strings.Replace(fmt.Sprintf("%v", this.Resources), "ResourceRequirements", "v1.ResourceRequirements", 1), `&`, ``, 1) + `,`, `}`, }, "") return s } + func (this *AbstractVolumeSource) String() string { if this == nil { return "nil" } - s := strings.Join([]string{`&AbstractVolumeSource{`, + s := strings.Join([]string{ + `&AbstractVolumeSource{`, `HostPath:` + strings.Replace(fmt.Sprintf("%v", this.HostPath), "HostPathVolumeSource", "v1.HostPathVolumeSource", 1) + `,`, `EmptyDir:` + strings.Replace(fmt.Sprintf("%v", this.EmptyDir), "EmptyDirVolumeSource", "v1.EmptyDirVolumeSource", 1) + `,`, `GCEPersistentDisk:` + strings.Replace(fmt.Sprintf("%v", this.GCEPersistentDisk), "GCEPersistentDiskVolumeSource", "v1.GCEPersistentDiskVolumeSource", 1) + `,`, @@ -7254,11 +7571,13 @@ func (this *AbstractVolumeSource) String() string { }, "") 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(fmt.Sprintf("%v", this.Cap), "Duration", "v11.Duration", 1) + `,`, `JitterPercentage:` + fmt.Sprintf("%v", this.JitterPercentage) + `,`, @@ -7268,27 +7587,32 @@ 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{`, `AbstractStep:` + strings.Replace(strings.Replace(this.AbstractStep.String(), "AbstractStep", "AbstractStep", 1), `&`, ``, 1) + `,`, `}`, }, "") 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" @@ -7303,7 +7627,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 + `,`, @@ -7315,38 +7640,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" @@ -7356,18 +7688,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) + `,`, @@ -7378,22 +7713,26 @@ 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{`, `AbstractStep:` + strings.Replace(strings.Replace(this.AbstractStep.String(), "AbstractStep", "AbstractStep", 1), `&`, ``, 1) + `,`, `UID:` + fmt.Sprintf("%v", this.UID) + `,`, `MaxSize:` + strings.Replace(strings.Replace(fmt.Sprintf("%v", this.MaxSize), "Quantity", "resource.Quantity", 1), `&`, ``, 1) + `,`, @@ -7401,37 +7740,44 @@ func (this *Dedupe) String() string { }, "") return s } + func (this *Expand) String() string { if this == nil { return "nil" } - s := strings.Join([]string{`&Expand{`, + s := strings.Join([]string{ + `&Expand{`, `AbstractStep:` + strings.Replace(strings.Replace(this.AbstractStep.String(), "AbstractStep", "AbstractStep", 1), `&`, ``, 1) + `,`, `}`, }, "") return s } + func (this *Filter) String() string { if this == nil { return "nil" } - s := strings.Join([]string{`&Filter{`, + s := strings.Join([]string{ + `&Filter{`, `AbstractStep:` + strings.Replace(strings.Replace(this.AbstractStep.String(), "AbstractStep", "AbstractStep", 1), `&`, ``, 1) + `,`, `Expression:` + fmt.Sprintf("%v", this.Expression) + `,`, `}`, }, "") return s } + func (this *Flatten) String() string { if this == nil { return "nil" } - s := strings.Join([]string{`&Flatten{`, + s := strings.Join([]string{ + `&Flatten{`, `AbstractStep:` + strings.Replace(strings.Replace(this.AbstractStep.String(), "AbstractStep", "AbstractStep", 1), `&`, ``, 1) + `,`, `}`, }, "") return s } + func (this *GetPodSpecReq) String() string { if this == nil { return "nil" @@ -7441,7 +7787,8 @@ func (this *GetPodSpecReq) String() string { repeatedStringForImagePullSecrets += fmt.Sprintf("%v", f) + "," } repeatedStringForImagePullSecrets += "}" - s := strings.Join([]string{`&GetPodSpecReq{`, + s := strings.Join([]string{ + `&GetPodSpecReq{`, `Cluster:` + fmt.Sprintf("%v", this.Cluster) + `,`, `Debug:` + fmt.Sprintf("%v", this.Debug) + `,`, `PipelineName:` + fmt.Sprintf("%v", this.PipelineName) + `,`, @@ -7459,6 +7806,7 @@ func (this *GetPodSpecReq) String() string { }, "") return s } + func (this *Git) String() string { if this == nil { return "nil" @@ -7468,7 +7816,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) + `,`, @@ -7482,11 +7831,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) + `,`, @@ -7495,20 +7846,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) + `,`, @@ -7516,16 +7871,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" @@ -7535,7 +7893,8 @@ 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 + `,`, `InsecureSkipVerify:` + fmt.Sprintf("%v", this.InsecureSkipVerify) + `,`, @@ -7543,32 +7902,38 @@ func (this *HTTPSink) String() string { }, "") 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) + `,`, @@ -7576,11 +7941,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) + `,`, @@ -7589,60 +7956,71 @@ 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 *Map) String() string { if this == nil { return "nil" } - s := strings.Join([]string{`&Map{`, + s := strings.Join([]string{ + `&Map{`, `AbstractStep:` + strings.Replace(strings.Replace(this.AbstractStep.String(), "AbstractStep", "AbstractStep", 1), `&`, ``, 1) + `,`, `Expression:` + fmt.Sprintf("%v", this.Expression) + `,`, `}`, }, "") return s } + func (this *Metadata) String() string { if this == nil { return "nil" @@ -7667,18 +8045,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) + `,`, `Retries:` + fmt.Sprintf("%v", this.Retries) + `,`, @@ -7687,11 +8068,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) + `,`, @@ -7699,6 +8082,7 @@ func (this *Pipeline) String() string { }, "") return s } + func (this *PipelineList) String() string { if this == nil { return "nil" @@ -7708,13 +8092,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" @@ -7724,13 +8110,15 @@ 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 + `,`, `DeletionDelay:` + strings.Replace(fmt.Sprintf("%v", this.DeletionDelay), "Duration", "v11.Duration", 1) + `,`, `}`, }, "") return s } + func (this *PipelineStatus) String() string { if this == nil { return "nil" @@ -7740,7 +8128,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 + `,`, @@ -7749,11 +8138,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) + `,`, @@ -7763,21 +8154,25 @@ 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(fmt.Sprintf("%v", this.PollPeriod), "Duration", "v11.Duration", 1) + `,`, `S3:` + strings.Replace(strings.Replace(this.S3.String(), "S3", "S3", 1), `&`, ``, 1) + `,`, `Concurrency:` + fmt.Sprintf("%v", this.Concurrency) + `,`, @@ -7785,11 +8180,13 @@ func (this *S3Source) String() string { }, "") 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) + `,`, @@ -7797,11 +8194,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) + `,`, @@ -7809,22 +8208,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) + `,`, @@ -7837,21 +8240,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{`, `DesiredReplicas:` + fmt.Sprintf("%v", this.DesiredReplicas) + `,`, `PeekDelay:` + fmt.Sprintf("%v", this.PeekDelay) + `,`, `ScalingDelay:` + fmt.Sprintf("%v", this.ScalingDelay) + `,`, @@ -7859,21 +8266,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) + `,`, @@ -7886,11 +8297,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) + `,`, @@ -7904,6 +8317,7 @@ func (this *Source) String() string { }, "") return s } + func (this *SourceStatus) String() string { if this == nil { return "nil" @@ -7918,7 +8332,8 @@ 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 + `,`, `LastPending:` + valueToStringGenerated(this.LastPending) + `,`, @@ -7926,11 +8341,13 @@ func (this *SourceStatus) String() string { }, "") 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) + `,`, @@ -7938,6 +8355,7 @@ func (this *Step) String() string { }, "") return s } + func (this *StepList) String() string { if this == nil { return "nil" @@ -7947,13 +8365,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" @@ -7993,7 +8413,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 + `,`, @@ -8023,6 +8444,7 @@ func (this *StepSpec) String() string { }, "") return s } + func (this *StepStatus) String() string { if this == nil { return "nil" @@ -8047,7 +8469,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 + `,`, @@ -8060,22 +8483,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) + `,`, @@ -8083,21 +8510,25 @@ func (this *TLS) String() string { }, "") return s } + func (this *VolumeSink) String() string { if this == nil { return "nil" } - s := strings.Join([]string{`&VolumeSink{`, + s := strings.Join([]string{ + `&VolumeSink{`, `AbstractVolumeSource:` + strings.Replace(strings.Replace(this.AbstractVolumeSource.String(), "AbstractVolumeSource", "AbstractVolumeSource", 1), `&`, ``, 1) + `,`, `}`, }, "") return s } + func (this *VolumeSource) String() string { if this == nil { return "nil" } - s := strings.Join([]string{`&VolumeSource{`, + s := strings.Join([]string{ + `&VolumeSource{`, `PollPeriod:` + strings.Replace(fmt.Sprintf("%v", this.PollPeriod), "Duration", "v11.Duration", 1) + `,`, `Concurrency:` + fmt.Sprintf("%v", this.Concurrency) + `,`, `AbstractVolumeSource:` + strings.Replace(strings.Replace(this.AbstractVolumeSource.String(), "AbstractVolumeSource", "AbstractVolumeSource", 1), `&`, ``, 1) + `,`, @@ -8106,6 +8537,7 @@ func (this *VolumeSource) String() string { }, "") return s } + func valueToStringGenerated(v interface{}) string { rv := reflect.ValueOf(v) if rv.IsNil() { @@ -8114,6 +8546,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 @@ -8263,6 +8696,7 @@ func (m *AWSCredentials) Unmarshal(dAtA []byte) error { } return nil } + func (m *AWSEndpoint) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -8345,6 +8779,7 @@ func (m *AWSEndpoint) Unmarshal(dAtA []byte) error { } return nil } + func (m *AbstractStep) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -8428,6 +8863,7 @@ func (m *AbstractStep) Unmarshal(dAtA []byte) error { } return nil } + func (m *AbstractVolumeSource) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -9522,6 +9958,7 @@ func (m *AbstractVolumeSource) Unmarshal(dAtA []byte) error { } return nil } + func (m *Backoff) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -9701,6 +10138,7 @@ func (m *Backoff) Unmarshal(dAtA []byte) error { } return nil } + func (m *Cat) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -9784,6 +10222,7 @@ func (m *Cat) Unmarshal(dAtA []byte) error { } return nil } + func (m *Code) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -9898,6 +10337,7 @@ func (m *Code) Unmarshal(dAtA []byte) error { } return nil } + func (m *Container) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -10181,6 +10621,7 @@ func (m *Container) Unmarshal(dAtA []byte) error { } return nil } + func (m *Cron) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -10295,6 +10736,7 @@ func (m *Cron) Unmarshal(dAtA []byte) error { } return nil } + func (m *DBDataSource) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -10413,6 +10855,7 @@ func (m *DBDataSource) Unmarshal(dAtA []byte) error { } return nil } + func (m *DBDataSourceFrom) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -10499,6 +10942,7 @@ func (m *DBDataSourceFrom) Unmarshal(dAtA []byte) error { } return nil } + func (m *DBSink) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -10616,6 +11060,7 @@ func (m *DBSink) Unmarshal(dAtA []byte) error { } return nil } + func (m *DBSource) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -10849,6 +11294,7 @@ func (m *DBSource) Unmarshal(dAtA []byte) error { } return nil } + func (m *Database) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -10967,6 +11413,7 @@ func (m *Database) Unmarshal(dAtA []byte) error { } return nil } + func (m *Dedupe) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -11115,6 +11562,7 @@ func (m *Dedupe) Unmarshal(dAtA []byte) error { } return nil } + func (m *Expand) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -11198,6 +11646,7 @@ func (m *Expand) Unmarshal(dAtA []byte) error { } return nil } + func (m *Filter) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -11313,6 +11762,7 @@ func (m *Filter) Unmarshal(dAtA []byte) error { } return nil } + func (m *Flatten) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -11396,6 +11846,7 @@ func (m *Flatten) Unmarshal(dAtA []byte) error { } return nil } + func (m *GetPodSpecReq) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -11828,6 +12279,7 @@ func (m *GetPodSpecReq) Unmarshal(dAtA []byte) error { } return nil } + func (m *Git) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -12180,6 +12632,7 @@ func (m *Git) Unmarshal(dAtA []byte) error { } return nil } + func (m *Group) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -12362,6 +12815,7 @@ func (m *Group) Unmarshal(dAtA []byte) error { } return nil } + func (m *HTTP) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -12412,6 +12866,7 @@ func (m *HTTP) Unmarshal(dAtA []byte) error { } return nil } + func (m *HTTPHeader) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -12562,6 +13017,7 @@ func (m *HTTPHeader) Unmarshal(dAtA []byte) error { } return nil } + func (m *HTTPHeaderSource) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -12645,6 +13101,7 @@ func (m *HTTPHeaderSource) Unmarshal(dAtA []byte) error { } return nil } + func (m *HTTPSink) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -12781,6 +13238,7 @@ func (m *HTTPSink) Unmarshal(dAtA []byte) error { } return nil } + func (m *HTTPSource) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -12863,6 +13321,7 @@ func (m *HTTPSource) Unmarshal(dAtA []byte) error { } return nil } + func (m *Interface) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -12969,6 +13428,7 @@ func (m *Interface) Unmarshal(dAtA []byte) error { } return nil } + func (m *Kafka) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -13116,6 +13576,7 @@ func (m *Kafka) Unmarshal(dAtA []byte) error { } return nil } + func (m *KafkaConfig) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -13285,6 +13746,7 @@ func (m *KafkaConfig) Unmarshal(dAtA []byte) error { } return nil } + func (m *KafkaNET) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -13407,6 +13869,7 @@ func (m *KafkaNET) Unmarshal(dAtA []byte) error { } return nil } + func (m *KafkaSink) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -13510,6 +13973,7 @@ func (m *KafkaSink) Unmarshal(dAtA []byte) error { } return nil } + func (m *KafkaSource) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -13625,6 +14089,7 @@ func (m *KafkaSource) Unmarshal(dAtA []byte) error { } return nil } + func (m *Log) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -13695,6 +14160,7 @@ func (m *Log) Unmarshal(dAtA []byte) error { } return nil } + func (m *Map) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -13810,6 +14276,7 @@ func (m *Map) Unmarshal(dAtA []byte) error { } return nil } + func (m *Metadata) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -14114,6 +14581,7 @@ func (m *Metadata) Unmarshal(dAtA []byte) error { } return nil } + func (m *Metrics) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -14240,6 +14708,7 @@ func (m *Metrics) Unmarshal(dAtA []byte) error { } return nil } + func (m *Pipeline) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -14389,6 +14858,7 @@ func (m *Pipeline) Unmarshal(dAtA []byte) error { } return nil } + func (m *PipelineList) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -14506,6 +14976,7 @@ func (m *PipelineList) Unmarshal(dAtA []byte) error { } return nil } + func (m *PipelineSpec) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -14626,6 +15097,7 @@ func (m *PipelineSpec) Unmarshal(dAtA []byte) error { } return nil } + func (m *PipelineStatus) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -14807,6 +15279,7 @@ func (m *PipelineStatus) Unmarshal(dAtA []byte) error { } return nil } + func (m *S3) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -15025,6 +15498,7 @@ func (m *S3) Unmarshal(dAtA []byte) error { } return nil } + func (m *S3Sink) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -15108,6 +15582,7 @@ func (m *S3Sink) Unmarshal(dAtA []byte) error { } return nil } + func (m *S3Source) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -15246,6 +15721,7 @@ func (m *S3Source) Unmarshal(dAtA []byte) error { } return nil } + func (m *SASL) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -15400,6 +15876,7 @@ func (m *SASL) Unmarshal(dAtA []byte) error { } return nil } + func (m *SQLAction) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -15555,6 +16032,7 @@ func (m *SQLAction) Unmarshal(dAtA []byte) error { } return nil } + func (m *SQLStatement) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -15669,6 +16147,7 @@ func (m *SQLStatement) Unmarshal(dAtA []byte) error { } return nil } + func (m *STAN) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -15966,6 +16445,7 @@ func (m *STAN) Unmarshal(dAtA []byte) error { } return nil } + func (m *STANAuth) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -16052,6 +16532,7 @@ func (m *STANAuth) Unmarshal(dAtA []byte) error { } return nil } + func (m *Scale) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -16198,6 +16679,7 @@ func (m *Scale) Unmarshal(dAtA []byte) error { } return nil } + func (m *Sidecar) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -16281,6 +16763,7 @@ func (m *Sidecar) Unmarshal(dAtA []byte) error { } return nil } + func (m *Sink) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -16615,6 +17098,7 @@ func (m *Sink) Unmarshal(dAtA []byte) error { } return nil } + func (m *Source) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -16982,6 +17466,7 @@ func (m *Source) Unmarshal(dAtA []byte) error { } return nil } + func (m *SourceStatus) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -17201,6 +17686,7 @@ func (m *SourceStatus) Unmarshal(dAtA []byte) error { } return nil } + func (m *Step) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -17350,6 +17836,7 @@ func (m *Step) Unmarshal(dAtA []byte) error { } return nil } + func (m *StepList) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -17467,6 +17954,7 @@ func (m *StepList) Unmarshal(dAtA []byte) error { } return nil } + func (m *StepSpec) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -18447,6 +18935,7 @@ func (m *StepSpec) Unmarshal(dAtA []byte) error { } return nil } + func (m *StepStatus) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -18935,6 +19424,7 @@ func (m *StepStatus) Unmarshal(dAtA []byte) error { } return nil } + func (m *Storage) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -19049,6 +19539,7 @@ func (m *Storage) Unmarshal(dAtA []byte) error { } return nil } + func (m *TLS) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -19207,6 +19698,7 @@ func (m *TLS) Unmarshal(dAtA []byte) error { } return nil } + func (m *VolumeSink) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -19290,6 +19782,7 @@ func (m *VolumeSink) Unmarshal(dAtA []byte) error { } return nil } + func (m *VolumeSource) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -19448,6 +19941,7 @@ func (m *VolumeSource) Unmarshal(dAtA []byte) error { } return nil } + func skipGenerated(dAtA []byte) (n int, err error) { l := len(dAtA) iNdEx := 0 diff --git a/sdks/golang/start.go b/sdks/golang/start.go index 4035c105..e987336e 100644 --- a/sdks/golang/start.go +++ b/sdks/golang/start.go @@ -6,8 +6,13 @@ import ( "log" "net" "net/http" +) + +type meta struct{ string } - dfv1 "github.com/argoproj-labs/argo-dataflow/api/v1alpha1" +var ( + MetaSource = meta{"source"} + MetaID = meta{"id"} ) func Start(handler func(ctx context.Context, msg []byte) ([]byte, error)) { @@ -22,7 +27,15 @@ func StartWithContext(ctx context.Context, handler func(ctx context.Context, msg w.WriteHeader(204) }) http.HandleFunc("/messages", func(w http.ResponseWriter, r *http.Request) { - ctx := dfv1.MetaExtract(r.Context(), r.Header) + ctx := context.WithValue( + context.WithValue( + r.Context(), + MetaSource, + r.Header.Get("source"), + ), + MetaID, + r.Header.Get("id"), + ) out, err := func() ([]byte, error) { in, err := ioutil.ReadAll(r.Body) _ = r.Body.Close()