(dAtA []byte)
| 2908 | } |
| 2909 | |
| 2910 | func (m *StreamWriteRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) { |
| 2911 | i := len(dAtA) |
| 2912 | _ = i |
| 2913 | var l int |
| 2914 | _ = l |
| 2915 | { |
| 2916 | size := m.MessageWithBufRef.Size() |
| 2917 | i -= size |
| 2918 | if _, err := m.MessageWithBufRef.MarshalTo(dAtA[i:]); err != nil { |
| 2919 | return 0, err |
| 2920 | } |
| 2921 | i = encodeVarintCortex(dAtA, i, uint64(size)) |
| 2922 | } |
| 2923 | i-- |
| 2924 | dAtA[i] = 0x3e |
| 2925 | i-- |
| 2926 | dAtA[i] = 0xc2 |
| 2927 | if m.Request != nil { |
| 2928 | { |
| 2929 | size, err := m.Request.MarshalToSizedBuffer(dAtA[:i]) |
| 2930 | if err != nil { |
| 2931 | return 0, err |
| 2932 | } |
| 2933 | i -= size |
| 2934 | i = encodeVarintCortex(dAtA, i, uint64(size)) |
| 2935 | } |
| 2936 | i-- |
| 2937 | dAtA[i] = 0x12 |
| 2938 | } |
| 2939 | if len(m.TenantID) > 0 { |
| 2940 | i -= len(m.TenantID) |
| 2941 | copy(dAtA[i:], m.TenantID) |
| 2942 | i = encodeVarintCortex(dAtA, i, uint64(len(m.TenantID))) |
| 2943 | i-- |
| 2944 | dAtA[i] = 0xa |
| 2945 | } |
| 2946 | return len(dAtA) - i, nil |
| 2947 | } |
| 2948 | |
| 2949 | func (m *WriteResponse) Marshal() (dAtA []byte, err error) { |
| 2950 | size := m.Size() |
no test coverage detected