//go:build vtprotobuf // +build vtprotobuf // Code generated by protoc-gen-go-vtproto. DO NOT EDIT. // source: envoy/config/tap/v3/common.proto package tapv3 import ( protohelpers "github.com/planetscale/vtprotobuf/protohelpers" durationpb "github.com/planetscale/vtprotobuf/types/known/durationpb" wrapperspb "github.com/planetscale/vtprotobuf/types/known/wrapperspb" proto "google.golang.org/protobuf/proto" protoimpl "google.golang.org/protobuf/runtime/protoimpl" ) const ( // Verify that this generated code is sufficiently up-to-date. _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion) // Verify that runtime/protoimpl is sufficiently up-to-date. _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20) ) func (m *TapConfig) MarshalVTStrict() (dAtA []byte, err error) { if m == nil { return nil, nil } size := m.SizeVT() dAtA = make([]byte, size) n, err := m.MarshalToSizedBufferVTStrict(dAtA[:size]) if err != nil { return nil, err } return dAtA[:n], nil } func (m *TapConfig) MarshalToVTStrict(dAtA []byte) (int, error) { size := m.SizeVT() return m.MarshalToSizedBufferVTStrict(dAtA[:size]) } func (m *TapConfig) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error) { if m == nil { return 0, nil } i := len(dAtA) _ = i var l int _ = l if m.unknownFields != nil { i -= len(m.unknownFields) copy(dAtA[i:], m.unknownFields) } if m.Match != nil { if vtmsg, ok := interface{}(m.Match).(interface { MarshalToSizedBufferVTStrict([]byte) (int, error) }); ok { size, err := vtmsg.MarshalToSizedBufferVTStrict(dAtA[:i]) if err != nil { return 0, err } i -= size i = protohelpers.EncodeVarint(dAtA, i, uint64(size)) } else { encoded, err := proto.Marshal(m.Match) if err != nil { return 0, err } i -= len(encoded) copy(dAtA[i:], encoded) i = protohelpers.EncodeVarint(dAtA, i, uint64(len(encoded))) } i-- dAtA[i] = 0x22 } if m.TapEnabled != nil { if vtmsg, ok := interface{}(m.TapEnabled).(interface { MarshalToSizedBufferVTStrict([]byte) (int, error) }); ok { size, err := vtmsg.MarshalToSizedBufferVTStrict(dAtA[:i]) if err != nil { return 0, err } i -= size i = protohelpers.EncodeVarint(dAtA, i, uint64(size)) } else { encoded, err := proto.Marshal(m.TapEnabled) if err != nil { return 0, err } i -= len(encoded) copy(dAtA[i:], encoded) i = protohelpers.EncodeVarint(dAtA, i, uint64(len(encoded))) } i-- dAtA[i] = 0x1a } if m.OutputConfig != nil { size, err := m.OutputConfig.MarshalToSizedBufferVTStrict(dAtA[:i]) if err != nil { return 0, err } i -= size i = protohelpers.EncodeVarint(dAtA, i, uint64(size)) i-- dAtA[i] = 0x12 } if m.MatchConfig != nil { size, err := m.MatchConfig.MarshalToSizedBufferVTStrict(dAtA[:i]) if err != nil { return 0, err } i -= size i = protohelpers.EncodeVarint(dAtA, i, uint64(size)) i-- dAtA[i] = 0xa } return len(dAtA) - i, nil } func (m *MatchPredicate_MatchSet) MarshalVTStrict() (dAtA []byte, err error) { if m == nil { return nil, nil } size := m.SizeVT() dAtA = make([]byte, size) n, err := m.MarshalToSizedBufferVTStrict(dAtA[:size]) if err != nil { return nil, err } return dAtA[:n], nil } func (m *MatchPredicate_MatchSet) MarshalToVTStrict(dAtA []byte) (int, error) { size := m.SizeVT() return m.MarshalToSizedBufferVTStrict(dAtA[:size]) } func (m *MatchPredicate_MatchSet) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error) { if m == nil { return 0, nil } i := len(dAtA) _ = i var l int _ = l if m.unknownFields != nil { i -= len(m.unknownFields) copy(dAtA[i:], m.unknownFields) } if len(m.Rules) > 0 { for iNdEx := len(m.Rules) - 1; iNdEx >= 0; iNdEx-- { size, err := m.Rules[iNdEx].MarshalToSizedBufferVTStrict(dAtA[:i]) if err != nil { return 0, err } i -= size i = protohelpers.EncodeVarint(dAtA, i, uint64(size)) i-- dAtA[i] = 0xa } } return len(dAtA) - i, nil } func (m *MatchPredicate) MarshalVTStrict() (dAtA []byte, err error) { if m == nil { return nil, nil } size := m.SizeVT() dAtA = make([]byte, size) n, err := m.MarshalToSizedBufferVTStrict(dAtA[:size]) if err != nil { return nil, err } return dAtA[:n], nil } func (m *MatchPredicate) MarshalToVTStrict(dAtA []byte) (int, error) { size := m.SizeVT() return m.MarshalToSizedBufferVTStrict(dAtA[:size]) } func (m *MatchPredicate) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error) { if m == nil { return 0, nil } i := len(dAtA) _ = i var l int _ = l if m.unknownFields != nil { i -= len(m.unknownFields) copy(dAtA[i:], m.unknownFields) } if msg, ok := m.Rule.(*MatchPredicate_HttpResponseGenericBodyMatch); ok { size, err := msg.MarshalToSizedBufferVTStrict(dAtA[:i]) if err != nil { return 0, err } i -= size } if msg, ok := m.Rule.(*MatchPredicate_HttpRequestGenericBodyMatch); ok { size, err := msg.MarshalToSizedBufferVTStrict(dAtA[:i]) if err != nil { return 0, err } i -= size } if msg, ok := m.Rule.(*MatchPredicate_HttpResponseTrailersMatch); ok { size, err := msg.MarshalToSizedBufferVTStrict(dAtA[:i]) if err != nil { return 0, err } i -= size } if msg, ok := m.Rule.(*MatchPredicate_HttpResponseHeadersMatch); ok { size, err := msg.MarshalToSizedBufferVTStrict(dAtA[:i]) if err != nil { return 0, err } i -= size } if msg, ok := m.Rule.(*MatchPredicate_HttpRequestTrailersMatch); ok { size, err := msg.MarshalToSizedBufferVTStrict(dAtA[:i]) if err != nil { return 0, err } i -= size } if msg, ok := m.Rule.(*MatchPredicate_HttpRequestHeadersMatch); ok { size, err := msg.MarshalToSizedBufferVTStrict(dAtA[:i]) if err != nil { return 0, err } i -= size } if msg, ok := m.Rule.(*MatchPredicate_AnyMatch); ok { size, err := msg.MarshalToSizedBufferVTStrict(dAtA[:i]) if err != nil { return 0, err } i -= size } if msg, ok := m.Rule.(*MatchPredicate_NotMatch); ok { size, err := msg.MarshalToSizedBufferVTStrict(dAtA[:i]) if err != nil { return 0, err } i -= size } if msg, ok := m.Rule.(*MatchPredicate_AndMatch); ok { size, err := msg.MarshalToSizedBufferVTStrict(dAtA[:i]) if err != nil { return 0, err } i -= size } if msg, ok := m.Rule.(*MatchPredicate_OrMatch); ok { size, err := msg.MarshalToSizedBufferVTStrict(dAtA[:i]) if err != nil { return 0, err } i -= size } return len(dAtA) - i, nil } func (m *MatchPredicate_OrMatch) MarshalToVTStrict(dAtA []byte) (int, error) { size := m.SizeVT() return m.MarshalToSizedBufferVTStrict(dAtA[:size]) } func (m *MatchPredicate_OrMatch) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error) { i := len(dAtA) if m.OrMatch != nil { size, err := m.OrMatch.MarshalToSizedBufferVTStrict(dAtA[:i]) if err != nil { return 0, err } i -= size i = protohelpers.EncodeVarint(dAtA, i, uint64(size)) i-- dAtA[i] = 0xa } else { i = protohelpers.EncodeVarint(dAtA, i, 0) i-- dAtA[i] = 0xa } return len(dAtA) - i, nil } func (m *MatchPredicate_AndMatch) MarshalToVTStrict(dAtA []byte) (int, error) { size := m.SizeVT() return m.MarshalToSizedBufferVTStrict(dAtA[:size]) } func (m *MatchPredicate_AndMatch) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error) { i := len(dAtA) if m.AndMatch != nil { size, err := m.AndMatch.MarshalToSizedBufferVTStrict(dAtA[:i]) if err != nil { return 0, err } i -= size i = protohelpers.EncodeVarint(dAtA, i, uint64(size)) i-- dAtA[i] = 0x12 } else { i = protohelpers.EncodeVarint(dAtA, i, 0) i-- dAtA[i] = 0x12 } return len(dAtA) - i, nil } func (m *MatchPredicate_NotMatch) MarshalToVTStrict(dAtA []byte) (int, error) { size := m.SizeVT() return m.MarshalToSizedBufferVTStrict(dAtA[:size]) } func (m *MatchPredicate_NotMatch) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error) { i := len(dAtA) if m.NotMatch != nil { size, err := m.NotMatch.MarshalToSizedBufferVTStrict(dAtA[:i]) if err != nil { return 0, err } i -= size i = protohelpers.EncodeVarint(dAtA, i, uint64(size)) i-- dAtA[i] = 0x1a } else { i = protohelpers.EncodeVarint(dAtA, i, 0) i-- dAtA[i] = 0x1a } return len(dAtA) - i, nil } func (m *MatchPredicate_AnyMatch) MarshalToVTStrict(dAtA []byte) (int, error) { size := m.SizeVT() return m.MarshalToSizedBufferVTStrict(dAtA[:size]) } func (m *MatchPredicate_AnyMatch) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error) { i := len(dAtA) i-- if m.AnyMatch { dAtA[i] = 1 } else { dAtA[i] = 0 } i-- dAtA[i] = 0x20 return len(dAtA) - i, nil } func (m *MatchPredicate_HttpRequestHeadersMatch) MarshalToVTStrict(dAtA []byte) (int, error) { size := m.SizeVT() return m.MarshalToSizedBufferVTStrict(dAtA[:size]) } func (m *MatchPredicate_HttpRequestHeadersMatch) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error) { i := len(dAtA) if m.HttpRequestHeadersMatch != nil { size, err := m.HttpRequestHeadersMatch.MarshalToSizedBufferVTStrict(dAtA[:i]) if err != nil { return 0, err } i -= size i = protohelpers.EncodeVarint(dAtA, i, uint64(size)) i-- dAtA[i] = 0x2a } else { i = protohelpers.EncodeVarint(dAtA, i, 0) i-- dAtA[i] = 0x2a } return len(dAtA) - i, nil } func (m *MatchPredicate_HttpRequestTrailersMatch) MarshalToVTStrict(dAtA []byte) (int, error) { size := m.SizeVT() return m.MarshalToSizedBufferVTStrict(dAtA[:size]) } func (m *MatchPredicate_HttpRequestTrailersMatch) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error) { i := len(dAtA) if m.HttpRequestTrailersMatch != nil { size, err := m.HttpRequestTrailersMatch.MarshalToSizedBufferVTStrict(dAtA[:i]) if err != nil { return 0, err } i -= size i = protohelpers.EncodeVarint(dAtA, i, uint64(size)) i-- dAtA[i] = 0x32 } else { i = protohelpers.EncodeVarint(dAtA, i, 0) i-- dAtA[i] = 0x32 } return len(dAtA) - i, nil } func (m *MatchPredicate_HttpResponseHeadersMatch) MarshalToVTStrict(dAtA []byte) (int, error) { size := m.SizeVT() return m.MarshalToSizedBufferVTStrict(dAtA[:size]) } func (m *MatchPredicate_HttpResponseHeadersMatch) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error) { i := len(dAtA) if m.HttpResponseHeadersMatch != nil { size, err := m.HttpResponseHeadersMatch.MarshalToSizedBufferVTStrict(dAtA[:i]) if err != nil { return 0, err } i -= size i = protohelpers.EncodeVarint(dAtA, i, uint64(size)) i-- dAtA[i] = 0x3a } else { i = protohelpers.EncodeVarint(dAtA, i, 0) i-- dAtA[i] = 0x3a } return len(dAtA) - i, nil } func (m *MatchPredicate_HttpResponseTrailersMatch) MarshalToVTStrict(dAtA []byte) (int, error) { size := m.SizeVT() return m.MarshalToSizedBufferVTStrict(dAtA[:size]) } func (m *MatchPredicate_HttpResponseTrailersMatch) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error) { i := len(dAtA) if m.HttpResponseTrailersMatch != nil { size, err := m.HttpResponseTrailersMatch.MarshalToSizedBufferVTStrict(dAtA[:i]) if err != nil { return 0, err } i -= size i = protohelpers.EncodeVarint(dAtA, i, uint64(size)) i-- dAtA[i] = 0x42 } else { i = protohelpers.EncodeVarint(dAtA, i, 0) i-- dAtA[i] = 0x42 } return len(dAtA) - i, nil } func (m *MatchPredicate_HttpRequestGenericBodyMatch) MarshalToVTStrict(dAtA []byte) (int, error) { size := m.SizeVT() return m.MarshalToSizedBufferVTStrict(dAtA[:size]) } func (m *MatchPredicate_HttpRequestGenericBodyMatch) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error) { i := len(dAtA) if m.HttpRequestGenericBodyMatch != nil { size, err := m.HttpRequestGenericBodyMatch.MarshalToSizedBufferVTStrict(dAtA[:i]) if err != nil { return 0, err } i -= size i = protohelpers.EncodeVarint(dAtA, i, uint64(size)) i-- dAtA[i] = 0x4a } else { i = protohelpers.EncodeVarint(dAtA, i, 0) i-- dAtA[i] = 0x4a } return len(dAtA) - i, nil } func (m *MatchPredicate_HttpResponseGenericBodyMatch) MarshalToVTStrict(dAtA []byte) (int, error) { size := m.SizeVT() return m.MarshalToSizedBufferVTStrict(dAtA[:size]) } func (m *MatchPredicate_HttpResponseGenericBodyMatch) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error) { i := len(dAtA) if m.HttpResponseGenericBodyMatch != nil { size, err := m.HttpResponseGenericBodyMatch.MarshalToSizedBufferVTStrict(dAtA[:i]) if err != nil { return 0, err } i -= size i = protohelpers.EncodeVarint(dAtA, i, uint64(size)) i-- dAtA[i] = 0x52 } else { i = protohelpers.EncodeVarint(dAtA, i, 0) i-- dAtA[i] = 0x52 } return len(dAtA) - i, nil } func (m *HttpHeadersMatch) MarshalVTStrict() (dAtA []byte, err error) { if m == nil { return nil, nil } size := m.SizeVT() dAtA = make([]byte, size) n, err := m.MarshalToSizedBufferVTStrict(dAtA[:size]) if err != nil { return nil, err } return dAtA[:n], nil } func (m *HttpHeadersMatch) MarshalToVTStrict(dAtA []byte) (int, error) { size := m.SizeVT() return m.MarshalToSizedBufferVTStrict(dAtA[:size]) } func (m *HttpHeadersMatch) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error) { if m == nil { return 0, nil } i := len(dAtA) _ = i var l int _ = l if m.unknownFields != nil { i -= len(m.unknownFields) copy(dAtA[i:], m.unknownFields) } if len(m.Headers) > 0 { for iNdEx := len(m.Headers) - 1; iNdEx >= 0; iNdEx-- { if vtmsg, ok := interface{}(m.Headers[iNdEx]).(interface { MarshalToSizedBufferVTStrict([]byte) (int, error) }); ok { size, err := vtmsg.MarshalToSizedBufferVTStrict(dAtA[:i]) if err != nil { return 0, err } i -= size i = protohelpers.EncodeVarint(dAtA, i, uint64(size)) } else { encoded, err := proto.Marshal(m.Headers[iNdEx]) if err != nil { return 0, err } i -= len(encoded) copy(dAtA[i:], encoded) i = protohelpers.EncodeVarint(dAtA, i, uint64(len(encoded))) } i-- dAtA[i] = 0xa } } return len(dAtA) - i, nil } func (m *HttpGenericBodyMatch_GenericTextMatch) MarshalVTStrict() (dAtA []byte, err error) { if m == nil { return nil, nil } size := m.SizeVT() dAtA = make([]byte, size) n, err := m.MarshalToSizedBufferVTStrict(dAtA[:size]) if err != nil { return nil, err } return dAtA[:n], nil } func (m *HttpGenericBodyMatch_GenericTextMatch) MarshalToVTStrict(dAtA []byte) (int, error) { size := m.SizeVT() return m.MarshalToSizedBufferVTStrict(dAtA[:size]) } func (m *HttpGenericBodyMatch_GenericTextMatch) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error) { if m == nil { return 0, nil } i := len(dAtA) _ = i var l int _ = l if m.unknownFields != nil { i -= len(m.unknownFields) copy(dAtA[i:], m.unknownFields) } if msg, ok := m.Rule.(*HttpGenericBodyMatch_GenericTextMatch_BinaryMatch); ok { size, err := msg.MarshalToSizedBufferVTStrict(dAtA[:i]) if err != nil { return 0, err } i -= size } if msg, ok := m.Rule.(*HttpGenericBodyMatch_GenericTextMatch_StringMatch); ok { size, err := msg.MarshalToSizedBufferVTStrict(dAtA[:i]) if err != nil { return 0, err } i -= size } return len(dAtA) - i, nil } func (m *HttpGenericBodyMatch_GenericTextMatch_StringMatch) MarshalToVTStrict(dAtA []byte) (int, error) { size := m.SizeVT() return m.MarshalToSizedBufferVTStrict(dAtA[:size]) } func (m *HttpGenericBodyMatch_GenericTextMatch_StringMatch) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error) { i := len(dAtA) i -= len(m.StringMatch) copy(dAtA[i:], m.StringMatch) i = protohelpers.EncodeVarint(dAtA, i, uint64(len(m.StringMatch))) i-- dAtA[i] = 0xa return len(dAtA) - i, nil } func (m *HttpGenericBodyMatch_GenericTextMatch_BinaryMatch) MarshalToVTStrict(dAtA []byte) (int, error) { size := m.SizeVT() return m.MarshalToSizedBufferVTStrict(dAtA[:size]) } func (m *HttpGenericBodyMatch_GenericTextMatch_BinaryMatch) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error) { i := len(dAtA) i -= len(m.BinaryMatch) copy(dAtA[i:], m.BinaryMatch) i = protohelpers.EncodeVarint(dAtA, i, uint64(len(m.BinaryMatch))) i-- dAtA[i] = 0x12 return len(dAtA) - i, nil } func (m *HttpGenericBodyMatch) MarshalVTStrict() (dAtA []byte, err error) { if m == nil { return nil, nil } size := m.SizeVT() dAtA = make([]byte, size) n, err := m.MarshalToSizedBufferVTStrict(dAtA[:size]) if err != nil { return nil, err } return dAtA[:n], nil } func (m *HttpGenericBodyMatch) MarshalToVTStrict(dAtA []byte) (int, error) { size := m.SizeVT() return m.MarshalToSizedBufferVTStrict(dAtA[:size]) } func (m *HttpGenericBodyMatch) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error) { if m == nil { return 0, nil } i := len(dAtA) _ = i var l int _ = l if m.unknownFields != nil { i -= len(m.unknownFields) copy(dAtA[i:], m.unknownFields) } if len(m.Patterns) > 0 { for iNdEx := len(m.Patterns) - 1; iNdEx >= 0; iNdEx-- { size, err := m.Patterns[iNdEx].MarshalToSizedBufferVTStrict(dAtA[:i]) if err != nil { return 0, err } i -= size i = protohelpers.EncodeVarint(dAtA, i, uint64(size)) i-- dAtA[i] = 0x12 } } if m.BytesLimit != 0 { i = protohelpers.EncodeVarint(dAtA, i, uint64(m.BytesLimit)) i-- dAtA[i] = 0x8 } return len(dAtA) - i, nil } func (m *OutputConfig) MarshalVTStrict() (dAtA []byte, err error) { if m == nil { return nil, nil } size := m.SizeVT() dAtA = make([]byte, size) n, err := m.MarshalToSizedBufferVTStrict(dAtA[:size]) if err != nil { return nil, err } return dAtA[:n], nil } func (m *OutputConfig) MarshalToVTStrict(dAtA []byte) (int, error) { size := m.SizeVT() return m.MarshalToSizedBufferVTStrict(dAtA[:size]) } func (m *OutputConfig) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error) { if m == nil { return 0, nil } i := len(dAtA) _ = i var l int _ = l if m.unknownFields != nil { i -= len(m.unknownFields) copy(dAtA[i:], m.unknownFields) } if m.Streaming { i-- if m.Streaming { dAtA[i] = 1 } else { dAtA[i] = 0 } i-- dAtA[i] = 0x20 } if m.MaxBufferedTxBytes != nil { size, err := (*wrapperspb.UInt32Value)(m.MaxBufferedTxBytes).MarshalToSizedBufferVTStrict(dAtA[:i]) if err != nil { return 0, err } i -= size i = protohelpers.EncodeVarint(dAtA, i, uint64(size)) i-- dAtA[i] = 0x1a } if m.MaxBufferedRxBytes != nil { size, err := (*wrapperspb.UInt32Value)(m.MaxBufferedRxBytes).MarshalToSizedBufferVTStrict(dAtA[:i]) if err != nil { return 0, err } i -= size i = protohelpers.EncodeVarint(dAtA, i, uint64(size)) i-- dAtA[i] = 0x12 } if len(m.Sinks) > 0 { for iNdEx := len(m.Sinks) - 1; iNdEx >= 0; iNdEx-- { size, err := m.Sinks[iNdEx].MarshalToSizedBufferVTStrict(dAtA[:i]) if err != nil { return 0, err } i -= size i = protohelpers.EncodeVarint(dAtA, i, uint64(size)) i-- dAtA[i] = 0xa } } return len(dAtA) - i, nil } func (m *OutputSink) MarshalVTStrict() (dAtA []byte, err error) { if m == nil { return nil, nil } size := m.SizeVT() dAtA = make([]byte, size) n, err := m.MarshalToSizedBufferVTStrict(dAtA[:size]) if err != nil { return nil, err } return dAtA[:n], nil } func (m *OutputSink) MarshalToVTStrict(dAtA []byte) (int, error) { size := m.SizeVT() return m.MarshalToSizedBufferVTStrict(dAtA[:size]) } func (m *OutputSink) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error) { if m == nil { return 0, nil } i := len(dAtA) _ = i var l int _ = l if m.unknownFields != nil { i -= len(m.unknownFields) copy(dAtA[i:], m.unknownFields) } if msg, ok := m.OutputSinkType.(*OutputSink_CustomSink); ok { size, err := msg.MarshalToSizedBufferVTStrict(dAtA[:i]) if err != nil { return 0, err } i -= size } if msg, ok := m.OutputSinkType.(*OutputSink_BufferedAdmin); ok { size, err := msg.MarshalToSizedBufferVTStrict(dAtA[:i]) if err != nil { return 0, err } i -= size } if msg, ok := m.OutputSinkType.(*OutputSink_StreamingGrpc); ok { size, err := msg.MarshalToSizedBufferVTStrict(dAtA[:i]) if err != nil { return 0, err } i -= size } if msg, ok := m.OutputSinkType.(*OutputSink_FilePerTap); ok { size, err := msg.MarshalToSizedBufferVTStrict(dAtA[:i]) if err != nil { return 0, err } i -= size } if msg, ok := m.OutputSinkType.(*OutputSink_StreamingAdmin); ok { size, err := msg.MarshalToSizedBufferVTStrict(dAtA[:i]) if err != nil { return 0, err } i -= size } if m.Format != 0 { i = protohelpers.EncodeVarint(dAtA, i, uint64(m.Format)) i-- dAtA[i] = 0x8 } return len(dAtA) - i, nil } func (m *OutputSink_StreamingAdmin) MarshalToVTStrict(dAtA []byte) (int, error) { size := m.SizeVT() return m.MarshalToSizedBufferVTStrict(dAtA[:size]) } func (m *OutputSink_StreamingAdmin) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error) { i := len(dAtA) if m.StreamingAdmin != nil { size, err := m.StreamingAdmin.MarshalToSizedBufferVTStrict(dAtA[:i]) if err != nil { return 0, err } i -= size i = protohelpers.EncodeVarint(dAtA, i, uint64(size)) i-- dAtA[i] = 0x12 } else { i = protohelpers.EncodeVarint(dAtA, i, 0) i-- dAtA[i] = 0x12 } return len(dAtA) - i, nil } func (m *OutputSink_FilePerTap) MarshalToVTStrict(dAtA []byte) (int, error) { size := m.SizeVT() return m.MarshalToSizedBufferVTStrict(dAtA[:size]) } func (m *OutputSink_FilePerTap) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error) { i := len(dAtA) if m.FilePerTap != nil { size, err := m.FilePerTap.MarshalToSizedBufferVTStrict(dAtA[:i]) if err != nil { return 0, err } i -= size i = protohelpers.EncodeVarint(dAtA, i, uint64(size)) i-- dAtA[i] = 0x1a } else { i = protohelpers.EncodeVarint(dAtA, i, 0) i-- dAtA[i] = 0x1a } return len(dAtA) - i, nil } func (m *OutputSink_StreamingGrpc) MarshalToVTStrict(dAtA []byte) (int, error) { size := m.SizeVT() return m.MarshalToSizedBufferVTStrict(dAtA[:size]) } func (m *OutputSink_StreamingGrpc) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error) { i := len(dAtA) if m.StreamingGrpc != nil { size, err := m.StreamingGrpc.MarshalToSizedBufferVTStrict(dAtA[:i]) if err != nil { return 0, err } i -= size i = protohelpers.EncodeVarint(dAtA, i, uint64(size)) i-- dAtA[i] = 0x22 } else { i = protohelpers.EncodeVarint(dAtA, i, 0) i-- dAtA[i] = 0x22 } return len(dAtA) - i, nil } func (m *OutputSink_BufferedAdmin) MarshalToVTStrict(dAtA []byte) (int, error) { size := m.SizeVT() return m.MarshalToSizedBufferVTStrict(dAtA[:size]) } func (m *OutputSink_BufferedAdmin) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error) { i := len(dAtA) if m.BufferedAdmin != nil { size, err := m.BufferedAdmin.MarshalToSizedBufferVTStrict(dAtA[:i]) if err != nil { return 0, err } i -= size i = protohelpers.EncodeVarint(dAtA, i, uint64(size)) i-- dAtA[i] = 0x2a } else { i = protohelpers.EncodeVarint(dAtA, i, 0) i-- dAtA[i] = 0x2a } return len(dAtA) - i, nil } func (m *OutputSink_CustomSink) MarshalToVTStrict(dAtA []byte) (int, error) { size := m.SizeVT() return m.MarshalToSizedBufferVTStrict(dAtA[:size]) } func (m *OutputSink_CustomSink) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error) { i := len(dAtA) if m.CustomSink != nil { if vtmsg, ok := interface{}(m.CustomSink).(interface { MarshalToSizedBufferVTStrict([]byte) (int, error) }); ok { size, err := vtmsg.MarshalToSizedBufferVTStrict(dAtA[:i]) if err != nil { return 0, err } i -= size i = protohelpers.EncodeVarint(dAtA, i, uint64(size)) } else { encoded, err := proto.Marshal(m.CustomSink) if err != nil { return 0, err } i -= len(encoded) copy(dAtA[i:], encoded) i = protohelpers.EncodeVarint(dAtA, i, uint64(len(encoded))) } i-- dAtA[i] = 0x32 } else { i = protohelpers.EncodeVarint(dAtA, i, 0) i-- dAtA[i] = 0x32 } return len(dAtA) - i, nil } func (m *StreamingAdminSink) MarshalVTStrict() (dAtA []byte, err error) { if m == nil { return nil, nil } size := m.SizeVT() dAtA = make([]byte, size) n, err := m.MarshalToSizedBufferVTStrict(dAtA[:size]) if err != nil { return nil, err } return dAtA[:n], nil } func (m *StreamingAdminSink) MarshalToVTStrict(dAtA []byte) (int, error) { size := m.SizeVT() return m.MarshalToSizedBufferVTStrict(dAtA[:size]) } func (m *StreamingAdminSink) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error) { if m == nil { return 0, nil } i := len(dAtA) _ = i var l int _ = l if m.unknownFields != nil { i -= len(m.unknownFields) copy(dAtA[i:], m.unknownFields) } return len(dAtA) - i, nil } func (m *BufferedAdminSink) MarshalVTStrict() (dAtA []byte, err error) { if m == nil { return nil, nil } size := m.SizeVT() dAtA = make([]byte, size) n, err := m.MarshalToSizedBufferVTStrict(dAtA[:size]) if err != nil { return nil, err } return dAtA[:n], nil } func (m *BufferedAdminSink) MarshalToVTStrict(dAtA []byte) (int, error) { size := m.SizeVT() return m.MarshalToSizedBufferVTStrict(dAtA[:size]) } func (m *BufferedAdminSink) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error) { if m == nil { return 0, nil } i := len(dAtA) _ = i var l int _ = l if m.unknownFields != nil { i -= len(m.unknownFields) copy(dAtA[i:], m.unknownFields) } if m.Timeout != nil { size, err := (*durationpb.Duration)(m.Timeout).MarshalToSizedBufferVTStrict(dAtA[:i]) if err != nil { return 0, err } i -= size i = protohelpers.EncodeVarint(dAtA, i, uint64(size)) i-- dAtA[i] = 0x12 } if m.MaxTraces != 0 { i = protohelpers.EncodeVarint(dAtA, i, uint64(m.MaxTraces)) i-- dAtA[i] = 0x8 } return len(dAtA) - i, nil } func (m *FilePerTapSink) MarshalVTStrict() (dAtA []byte, err error) { if m == nil { return nil, nil } size := m.SizeVT() dAtA = make([]byte, size) n, err := m.MarshalToSizedBufferVTStrict(dAtA[:size]) if err != nil { return nil, err } return dAtA[:n], nil } func (m *FilePerTapSink) MarshalToVTStrict(dAtA []byte) (int, error) { size := m.SizeVT() return m.MarshalToSizedBufferVTStrict(dAtA[:size]) } func (m *FilePerTapSink) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error) { if m == nil { return 0, nil } i := len(dAtA) _ = i var l int _ = l if m.unknownFields != nil { i -= len(m.unknownFields) copy(dAtA[i:], m.unknownFields) } if len(m.PathPrefix) > 0 { i -= len(m.PathPrefix) copy(dAtA[i:], m.PathPrefix) i = protohelpers.EncodeVarint(dAtA, i, uint64(len(m.PathPrefix))) i-- dAtA[i] = 0xa } return len(dAtA) - i, nil } func (m *StreamingGrpcSink) MarshalVTStrict() (dAtA []byte, err error) { if m == nil { return nil, nil } size := m.SizeVT() dAtA = make([]byte, size) n, err := m.MarshalToSizedBufferVTStrict(dAtA[:size]) if err != nil { return nil, err } return dAtA[:n], nil } func (m *StreamingGrpcSink) MarshalToVTStrict(dAtA []byte) (int, error) { size := m.SizeVT() return m.MarshalToSizedBufferVTStrict(dAtA[:size]) } func (m *StreamingGrpcSink) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error) { if m == nil { return 0, nil } i := len(dAtA) _ = i var l int _ = l if m.unknownFields != nil { i -= len(m.unknownFields) copy(dAtA[i:], m.unknownFields) } if m.GrpcService != nil { if vtmsg, ok := interface{}(m.GrpcService).(interface { MarshalToSizedBufferVTStrict([]byte) (int, error) }); ok { size, err := vtmsg.MarshalToSizedBufferVTStrict(dAtA[:i]) if err != nil { return 0, err } i -= size i = protohelpers.EncodeVarint(dAtA, i, uint64(size)) } else { encoded, err := proto.Marshal(m.GrpcService) if err != nil { return 0, err } i -= len(encoded) copy(dAtA[i:], encoded) i = protohelpers.EncodeVarint(dAtA, i, uint64(len(encoded))) } i-- dAtA[i] = 0x12 } if len(m.TapId) > 0 { i -= len(m.TapId) copy(dAtA[i:], m.TapId) i = protohelpers.EncodeVarint(dAtA, i, uint64(len(m.TapId))) i-- dAtA[i] = 0xa } return len(dAtA) - i, nil } func (m *TapConfig) SizeVT() (n int) { if m == nil { return 0 } var l int _ = l if m.MatchConfig != nil { l = m.MatchConfig.SizeVT() n += 1 + l + protohelpers.SizeOfVarint(uint64(l)) } if m.OutputConfig != nil { l = m.OutputConfig.SizeVT() n += 1 + l + protohelpers.SizeOfVarint(uint64(l)) } if m.TapEnabled != nil { if size, ok := interface{}(m.TapEnabled).(interface { SizeVT() int }); ok { l = size.SizeVT() } else { l = proto.Size(m.TapEnabled) } n += 1 + l + protohelpers.SizeOfVarint(uint64(l)) } if m.Match != nil { if size, ok := interface{}(m.Match).(interface { SizeVT() int }); ok { l = size.SizeVT() } else { l = proto.Size(m.Match) } n += 1 + l + protohelpers.SizeOfVarint(uint64(l)) } n += len(m.unknownFields) return n } func (m *MatchPredicate_MatchSet) SizeVT() (n int) { if m == nil { return 0 } var l int _ = l if len(m.Rules) > 0 { for _, e := range m.Rules { l = e.SizeVT() n += 1 + l + protohelpers.SizeOfVarint(uint64(l)) } } n += len(m.unknownFields) return n } func (m *MatchPredicate) SizeVT() (n int) { if m == nil { return 0 } var l int _ = l if vtmsg, ok := m.Rule.(interface{ SizeVT() int }); ok { n += vtmsg.SizeVT() } n += len(m.unknownFields) return n } func (m *MatchPredicate_OrMatch) SizeVT() (n int) { if m == nil { return 0 } var l int _ = l if m.OrMatch != nil { l = m.OrMatch.SizeVT() n += 1 + l + protohelpers.SizeOfVarint(uint64(l)) } else { n += 2 } return n } func (m *MatchPredicate_AndMatch) SizeVT() (n int) { if m == nil { return 0 } var l int _ = l if m.AndMatch != nil { l = m.AndMatch.SizeVT() n += 1 + l + protohelpers.SizeOfVarint(uint64(l)) } else { n += 2 } return n } func (m *MatchPredicate_NotMatch) SizeVT() (n int) { if m == nil { return 0 } var l int _ = l if m.NotMatch != nil { l = m.NotMatch.SizeVT() n += 1 + l + protohelpers.SizeOfVarint(uint64(l)) } else { n += 2 } return n } func (m *MatchPredicate_AnyMatch) SizeVT() (n int) { if m == nil { return 0 } var l int _ = l n += 2 return n } func (m *MatchPredicate_HttpRequestHeadersMatch) SizeVT() (n int) { if m == nil { return 0 } var l int _ = l if m.HttpRequestHeadersMatch != nil { l = m.HttpRequestHeadersMatch.SizeVT() n += 1 + l + protohelpers.SizeOfVarint(uint64(l)) } else { n += 2 } return n } func (m *MatchPredicate_HttpRequestTrailersMatch) SizeVT() (n int) { if m == nil { return 0 } var l int _ = l if m.HttpRequestTrailersMatch != nil { l = m.HttpRequestTrailersMatch.SizeVT() n += 1 + l + protohelpers.SizeOfVarint(uint64(l)) } else { n += 2 } return n } func (m *MatchPredicate_HttpResponseHeadersMatch) SizeVT() (n int) { if m == nil { return 0 } var l int _ = l if m.HttpResponseHeadersMatch != nil { l = m.HttpResponseHeadersMatch.SizeVT() n += 1 + l + protohelpers.SizeOfVarint(uint64(l)) } else { n += 2 } return n } func (m *MatchPredicate_HttpResponseTrailersMatch) SizeVT() (n int) { if m == nil { return 0 } var l int _ = l if m.HttpResponseTrailersMatch != nil { l = m.HttpResponseTrailersMatch.SizeVT() n += 1 + l + protohelpers.SizeOfVarint(uint64(l)) } else { n += 2 } return n } func (m *MatchPredicate_HttpRequestGenericBodyMatch) SizeVT() (n int) { if m == nil { return 0 } var l int _ = l if m.HttpRequestGenericBodyMatch != nil { l = m.HttpRequestGenericBodyMatch.SizeVT() n += 1 + l + protohelpers.SizeOfVarint(uint64(l)) } else { n += 2 } return n } func (m *MatchPredicate_HttpResponseGenericBodyMatch) SizeVT() (n int) { if m == nil { return 0 } var l int _ = l if m.HttpResponseGenericBodyMatch != nil { l = m.HttpResponseGenericBodyMatch.SizeVT() n += 1 + l + protohelpers.SizeOfVarint(uint64(l)) } else { n += 2 } return n } func (m *HttpHeadersMatch) SizeVT() (n int) { if m == nil { return 0 } var l int _ = l if len(m.Headers) > 0 { for _, e := range m.Headers { if size, ok := interface{}(e).(interface { SizeVT() int }); ok { l = size.SizeVT() } else { l = proto.Size(e) } n += 1 + l + protohelpers.SizeOfVarint(uint64(l)) } } n += len(m.unknownFields) return n } func (m *HttpGenericBodyMatch_GenericTextMatch) SizeVT() (n int) { if m == nil { return 0 } var l int _ = l if vtmsg, ok := m.Rule.(interface{ SizeVT() int }); ok { n += vtmsg.SizeVT() } n += len(m.unknownFields) return n } func (m *HttpGenericBodyMatch_GenericTextMatch_StringMatch) SizeVT() (n int) { if m == nil { return 0 } var l int _ = l l = len(m.StringMatch) n += 1 + l + protohelpers.SizeOfVarint(uint64(l)) return n } func (m *HttpGenericBodyMatch_GenericTextMatch_BinaryMatch) SizeVT() (n int) { if m == nil { return 0 } var l int _ = l l = len(m.BinaryMatch) n += 1 + l + protohelpers.SizeOfVarint(uint64(l)) return n } func (m *HttpGenericBodyMatch) SizeVT() (n int) { if m == nil { return 0 } var l int _ = l if m.BytesLimit != 0 { n += 1 + protohelpers.SizeOfVarint(uint64(m.BytesLimit)) } if len(m.Patterns) > 0 { for _, e := range m.Patterns { l = e.SizeVT() n += 1 + l + protohelpers.SizeOfVarint(uint64(l)) } } n += len(m.unknownFields) return n } func (m *OutputConfig) SizeVT() (n int) { if m == nil { return 0 } var l int _ = l if len(m.Sinks) > 0 { for _, e := range m.Sinks { l = e.SizeVT() n += 1 + l + protohelpers.SizeOfVarint(uint64(l)) } } if m.MaxBufferedRxBytes != nil { l = (*wrapperspb.UInt32Value)(m.MaxBufferedRxBytes).SizeVT() n += 1 + l + protohelpers.SizeOfVarint(uint64(l)) } if m.MaxBufferedTxBytes != nil { l = (*wrapperspb.UInt32Value)(m.MaxBufferedTxBytes).SizeVT() n += 1 + l + protohelpers.SizeOfVarint(uint64(l)) } if m.Streaming { n += 2 } n += len(m.unknownFields) return n } func (m *OutputSink) SizeVT() (n int) { if m == nil { return 0 } var l int _ = l if m.Format != 0 { n += 1 + protohelpers.SizeOfVarint(uint64(m.Format)) } if vtmsg, ok := m.OutputSinkType.(interface{ SizeVT() int }); ok { n += vtmsg.SizeVT() } n += len(m.unknownFields) return n } func (m *OutputSink_StreamingAdmin) SizeVT() (n int) { if m == nil { return 0 } var l int _ = l if m.StreamingAdmin != nil { l = m.StreamingAdmin.SizeVT() n += 1 + l + protohelpers.SizeOfVarint(uint64(l)) } else { n += 2 } return n } func (m *OutputSink_FilePerTap) SizeVT() (n int) { if m == nil { return 0 } var l int _ = l if m.FilePerTap != nil { l = m.FilePerTap.SizeVT() n += 1 + l + protohelpers.SizeOfVarint(uint64(l)) } else { n += 2 } return n } func (m *OutputSink_StreamingGrpc) SizeVT() (n int) { if m == nil { return 0 } var l int _ = l if m.StreamingGrpc != nil { l = m.StreamingGrpc.SizeVT() n += 1 + l + protohelpers.SizeOfVarint(uint64(l)) } else { n += 2 } return n } func (m *OutputSink_BufferedAdmin) SizeVT() (n int) { if m == nil { return 0 } var l int _ = l if m.BufferedAdmin != nil { l = m.BufferedAdmin.SizeVT() n += 1 + l + protohelpers.SizeOfVarint(uint64(l)) } else { n += 2 } return n } func (m *OutputSink_CustomSink) SizeVT() (n int) { if m == nil { return 0 } var l int _ = l if m.CustomSink != nil { if size, ok := interface{}(m.CustomSink).(interface { SizeVT() int }); ok { l = size.SizeVT() } else { l = proto.Size(m.CustomSink) } n += 1 + l + protohelpers.SizeOfVarint(uint64(l)) } else { n += 2 } return n } func (m *StreamingAdminSink) SizeVT() (n int) { if m == nil { return 0 } var l int _ = l n += len(m.unknownFields) return n } func (m *BufferedAdminSink) SizeVT() (n int) { if m == nil { return 0 } var l int _ = l if m.MaxTraces != 0 { n += 1 + protohelpers.SizeOfVarint(uint64(m.MaxTraces)) } if m.Timeout != nil { l = (*durationpb.Duration)(m.Timeout).SizeVT() n += 1 + l + protohelpers.SizeOfVarint(uint64(l)) } n += len(m.unknownFields) return n } func (m *FilePerTapSink) SizeVT() (n int) { if m == nil { return 0 } var l int _ = l l = len(m.PathPrefix) if l > 0 { n += 1 + l + protohelpers.SizeOfVarint(uint64(l)) } n += len(m.unknownFields) return n } func (m *StreamingGrpcSink) SizeVT() (n int) { if m == nil { return 0 } var l int _ = l l = len(m.TapId) if l > 0 { n += 1 + l + protohelpers.SizeOfVarint(uint64(l)) } if m.GrpcService != nil { if size, ok := interface{}(m.GrpcService).(interface { SizeVT() int }); ok { l = size.SizeVT() } else { l = proto.Size(m.GrpcService) } n += 1 + l + protohelpers.SizeOfVarint(uint64(l)) } n += len(m.unknownFields) return n }