github/ttrpc
4
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Re-generate example.pb.go

Browse Source 
It is different from what this repository would generate, probably
since 7c78be300b.

Signed-off-by: Kazuyoshi Kato <katokazu@amazon.com>
This commit is contained in:
Kazuyoshi Kato 2021-10-25 18:35:35 -07:00
parent 77fc8a41aa
commit 35cd24038a
1 changed files with 288 additions and 159 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

447
example/example.pb.go
View File

@ -1,32 +1,21 @@
// Code generated by protoc-gen-gogo. DO NOT EDIT. // Code generated by protoc-gen-gogo. DO NOT EDIT.
// source: github.com/containerd/ttrpc/example/example.proto // source: github.com/containerd/ttrpc/example/example.proto
/*
Package example is a generated protocol buffer package.
It is generated from these files:
github.com/containerd/ttrpc/example/example.proto
It has these top-level messages:
Method1Request
Method1Response
Method2Request
*/
package example package example
import proto "github.com/gogo/protobuf/proto" import (
import fmt "fmt" context "context"
import math "math" fmt "fmt"
import google_protobuf "github.com/gogo/protobuf/types" github_com_containerd_ttrpc "github.com/containerd/ttrpc"
import _ "github.com/gogo/protobuf/gogoproto" _ "github.com/gogo/protobuf/gogoproto"
proto "github.com/gogo/protobuf/proto"
import strings "strings" types "github.com/gogo/protobuf/types"
import reflect "reflect" io "io"
math "math"
import context "context" math_bits "math/bits"
import ttrpc "github.com/containerd/ttrpc" reflect "reflect"
strings "strings"
import io "io" )
// Reference imports to suppress errors if they are not otherwise used. // Reference imports to suppress errors if they are not otherwise used.
var _ = proto.Marshal var _ = proto.Marshal
@ -37,43 +26,163 @@ var _ = math.Inf
// is compatible with the proto package it is being compiled against. // is compatible with the proto package it is being compiled against.
// A compilation error at this line likely means your copy of the // A compilation error at this line likely means your copy of the
// proto package needs to be updated. // proto package needs to be updated.
const _ = proto.GoGoProtoPackageIsVersion2 // please upgrade the proto package const _ = proto.GoGoProtoPackageIsVersion3 // please upgrade the proto package
type Method1Request struct { type Method1Request struct {
Foo string `protobuf:"bytes,1,opt,name=foo,proto3" json:"foo,omitempty"` Foo string `protobuf:"bytes,1,opt,name=foo,proto3" json:"foo,omitempty"`
Bar string `protobuf:"bytes,2,opt,name=bar,proto3" json:"bar,omitempty"` Bar string `protobuf:"bytes,2,opt,name=bar,proto3" json:"bar,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
} }
func (m *Method1Request) Reset() { *m = Method1Request{} } func (m *Method1Request) Reset() { *m = Method1Request{} }
func (*Method1Request) ProtoMessage() {} func (*Method1Request) ProtoMessage() {}
func (*Method1Request) Descriptor() ([]byte, []int) { return fileDescriptorExample, []int{0} } func (*Method1Request) Descriptor() ([]byte, []int) {
return fileDescriptor_d5b23bbed948ff84, []int{0}
}
func (m *Method1Request) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
}
func (m *Method1Request) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
if deterministic {
return xxx_messageInfo_Method1Request.Marshal(b, m, deterministic)
} else {
b = b[:cap(b)]
n, err := m.MarshalToSizedBuffer(b)
if err != nil {
return nil, err
}
return b[:n], nil
}
}
func (m *Method1Request) XXX_Merge(src proto.Message) {
xxx_messageInfo_Method1Request.Merge(m, src)
}
func (m *Method1Request) XXX_Size() int {
return m.Size()
}
func (m *Method1Request) XXX_DiscardUnknown() {
xxx_messageInfo_Method1Request.DiscardUnknown(m)
}
var xxx_messageInfo_Method1Request proto.InternalMessageInfo
type Method1Response struct { type Method1Response struct {
Foo string `protobuf:"bytes,1,opt,name=foo,proto3" json:"foo,omitempty"` Foo string `protobuf:"bytes,1,opt,name=foo,proto3" json:"foo,omitempty"`
Bar string `protobuf:"bytes,2,opt,name=bar,proto3" json:"bar,omitempty"` Bar string `protobuf:"bytes,2,opt,name=bar,proto3" json:"bar,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
} }
func (m *Method1Response) Reset() { *m = Method1Response{} } func (m *Method1Response) Reset() { *m = Method1Response{} }
func (*Method1Response) ProtoMessage() {} func (*Method1Response) ProtoMessage() {}
func (*Method1Response) Descriptor() ([]byte, []int) { return fileDescriptorExample, []int{1} } func (*Method1Response) Descriptor() ([]byte, []int) {
return fileDescriptor_d5b23bbed948ff84, []int{1}
}
func (m *Method1Response) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
}
func (m *Method1Response) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
if deterministic {
return xxx_messageInfo_Method1Response.Marshal(b, m, deterministic)
} else {
b = b[:cap(b)]
n, err := m.MarshalToSizedBuffer(b)
if err != nil {
return nil, err
}
return b[:n], nil
}
}
func (m *Method1Response) XXX_Merge(src proto.Message) {
xxx_messageInfo_Method1Response.Merge(m, src)
}
func (m *Method1Response) XXX_Size() int {
return m.Size()
}
func (m *Method1Response) XXX_DiscardUnknown() {
xxx_messageInfo_Method1Response.DiscardUnknown(m)
}
var xxx_messageInfo_Method1Response proto.InternalMessageInfo
type Method2Request struct { type Method2Request struct {
Action string `protobuf:"bytes,1,opt,name=action,proto3" json:"action,omitempty"` Action string `protobuf:"bytes,1,opt,name=action,proto3" json:"action,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
} }
func (m *Method2Request) Reset() { *m = Method2Request{} } func (m *Method2Request) Reset() { *m = Method2Request{} }
func (*Method2Request) ProtoMessage() {} func (*Method2Request) ProtoMessage() {}
func (*Method2Request) Descriptor() ([]byte, []int) { return fileDescriptorExample, []int{2} } func (*Method2Request) Descriptor() ([]byte, []int) {
return fileDescriptor_d5b23bbed948ff84, []int{2}
}
func (m *Method2Request) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
}
func (m *Method2Request) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
if deterministic {
return xxx_messageInfo_Method2Request.Marshal(b, m, deterministic)
} else {
b = b[:cap(b)]
n, err := m.MarshalToSizedBuffer(b)
if err != nil {
return nil, err
}
return b[:n], nil
}
}
func (m *Method2Request) XXX_Merge(src proto.Message) {
xxx_messageInfo_Method2Request.Merge(m, src)
}
func (m *Method2Request) XXX_Size() int {
return m.Size()
}
func (m *Method2Request) XXX_DiscardUnknown() {
xxx_messageInfo_Method2Request.DiscardUnknown(m)
}
var xxx_messageInfo_Method2Request proto.InternalMessageInfo
func init() { func init() {
proto.RegisterType((*Method1Request)(nil), "ttrpc.example.v1.Method1Request") proto.RegisterType((*Method1Request)(nil), "ttrpc.example.v1.Method1Request")
proto.RegisterType((*Method1Response)(nil), "ttrpc.example.v1.Method1Response") proto.RegisterType((*Method1Response)(nil), "ttrpc.example.v1.Method1Response")
proto.RegisterType((*Method2Request)(nil), "ttrpc.example.v1.Method2Request") proto.RegisterType((*Method2Request)(nil), "ttrpc.example.v1.Method2Request")
} }
func init() {
proto.RegisterFile("github.com/containerd/ttrpc/example/example.proto", fileDescriptor_d5b23bbed948ff84)
}
var fileDescriptor_d5b23bbed948ff84 = []byte{
// 279 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xe2, 0x32, 0x4c, 0xcf, 0x2c, 0xc9,
0x28, 0x4d, 0xd2, 0x4b, 0xce, 0xcf, 0xd5, 0x4f, 0xce, 0xcf, 0x2b, 0x49, 0xcc, 0xcc, 0x4b, 0x2d,
0x4a, 0xd1, 0x2f, 0x29, 0x29, 0x2a, 0x48, 0xd6, 0x4f, 0xad, 0x48, 0xcc, 0x2d, 0xc8, 0x49, 0x85,
0xd1, 0x7a, 0x05, 0x45, 0xf9, 0x25, 0xf9, 0x42, 0x02, 0x60, 0x49, 0x3d, 0x98, 0x60, 0x99, 0xa1,
0x94, 0x74, 0x7a, 0x7e, 0x7e, 0x7a, 0x4e, 0xaa, 0x3e, 0x58, 0x3e, 0xa9, 0x34, 0x4d, 0x3f, 0x35,
0xb7, 0xa0, 0xa4, 0x12, 0xa2, 0x5c, 0x4a, 0x24, 0x3d, 0x3f, 0x3d, 0x1f, 0xcc, 0xd4, 0x07, 0xb1,
0x20, 0xa2, 0x4a, 0x26, 0x5c, 0x7c, 0xbe, 0xa9, 0x25, 0x19, 0xf9, 0x29, 0x86, 0x41, 0xa9, 0x85,
0xa5, 0xa9, 0xc5, 0x25, 0x42, 0x02, 0x5c, 0xcc, 0x69, 0xf9, 0xf9, 0x12, 0x8c, 0x0a, 0x8c, 0x1a,
0x9c, 0x41, 0x20, 0x26, 0x48, 0x24, 0x29, 0xb1, 0x48, 0x82, 0x09, 0x22, 0x92, 0x94, 0x58, 0xa4,
0x64, 0xca, 0xc5, 0x0f, 0xd7, 0x55, 0x5c, 0x90, 0x9f, 0x57, 0x9c, 0x4a, 0x94, 0x36, 0x0d, 0x98,
0x65, 0x46, 0x30, 0xcb, 0xc4, 0xb8, 0xd8, 0x12, 0x93, 0x4b, 0x32, 0xf3, 0xf3, 0xa0, 0x1a, 0xa1,
0x3c, 0xa3, 0x79, 0x8c, 0x5c, 0xec, 0xae, 0x10, 0x8f, 0x09, 0xf9, 0x71, 0xb1, 0x43, 0x2d, 0x13,
0x52, 0xd0, 0x43, 0xf7, 0xb3, 0x1e, 0xaa, 0xeb, 0xa5, 0x14, 0xf1, 0xa8, 0x80, 0xba, 0xd4, 0x19,
0x66, 0x9e, 0x11, 0x11, 0xe6, 0x89, 0xe9, 0x41, 0xc2, 0x54, 0x0f, 0x16, 0xa6, 0x7a, 0xae, 0xa0,
0x30, 0x75, 0x72, 0x3d, 0xf1, 0x50, 0x8e, 0xe1, 0xc6, 0x43, 0x39, 0x86, 0x86, 0x47, 0x72, 0x8c,
0x27, 0x1e, 0xc9, 0x31, 0x5e, 0x78, 0x24, 0xc7, 0xf8, 0xe0, 0x91, 0x1c, 0x63, 0x94, 0x36, 0x11,
0x31, 0x69, 0x0d, 0xa5, 0x93, 0xd8, 0xc0, 0xc6, 0x1a, 0x03, 0x02, 0x00, 0x00, 0xff, 0xff, 0x4a,
0xc9, 0x2c, 0xdc, 0xff, 0x01, 0x00, 0x00,
}
func (m *Method1Request) Marshal() (dAtA []byte, err error) { func (m *Method1Request) Marshal() (dAtA []byte, err error) {
size := m.Size() size := m.Size()
dAtA = make([]byte, size) dAtA = make([]byte, size)
n, err := m.MarshalTo(dAtA) n, err := m.MarshalToSizedBuffer(dAtA[:size])
if err != nil { if err != nil {
return nil, err return nil, err
} }
@ -81,29 +190,40 @@ func (m *Method1Request) Marshal() (dAtA []byte, err error) {
} }
func (m *Method1Request) MarshalTo(dAtA []byte) (int, error) { func (m *Method1Request) MarshalTo(dAtA []byte) (int, error) {
var i int size := m.Size()
return m.MarshalToSizedBuffer(dAtA[:size])
}
func (m *Method1Request) MarshalToSizedBuffer(dAtA []byte) (int, error) {
i := len(dAtA)
_ = i _ = i
var l int var l int
_ = l _ = l
if len(m.Foo) > 0 { if m.XXX_unrecognized != nil {
dAtA[i] = 0xa i -= len(m.XXX_unrecognized)
i++ copy(dAtA[i:], m.XXX_unrecognized)
i = encodeVarintExample(dAtA, i, uint64(len(m.Foo)))
i += copy(dAtA[i:], m.Foo)
} }
if len(m.Bar) > 0 { if len(m.Bar) > 0 {
dAtA[i] = 0x12 i -= len(m.Bar)
i++ copy(dAtA[i:], m.Bar)
i = encodeVarintExample(dAtA, i, uint64(len(m.Bar))) i = encodeVarintExample(dAtA, i, uint64(len(m.Bar)))
i += copy(dAtA[i:], m.Bar) i--
dAtA[i] = 0x12
} }
return i, nil if len(m.Foo) > 0 {
i -= len(m.Foo)
copy(dAtA[i:], m.Foo)
i = encodeVarintExample(dAtA, i, uint64(len(m.Foo)))
i--
dAtA[i] = 0xa
}
return len(dAtA) - i, nil
} }
func (m *Method1Response) Marshal() (dAtA []byte, err error) { func (m *Method1Response) Marshal() (dAtA []byte, err error) {
size := m.Size() size := m.Size()
dAtA = make([]byte, size) dAtA = make([]byte, size)
n, err := m.MarshalTo(dAtA) n, err := m.MarshalToSizedBuffer(dAtA[:size])
if err != nil { if err != nil {
return nil, err return nil, err
} }
@ -111,29 +231,40 @@ func (m *Method1Response) Marshal() (dAtA []byte, err error) {
} }
func (m *Method1Response) MarshalTo(dAtA []byte) (int, error) { func (m *Method1Response) MarshalTo(dAtA []byte) (int, error) {
var i int size := m.Size()
return m.MarshalToSizedBuffer(dAtA[:size])
}
func (m *Method1Response) MarshalToSizedBuffer(dAtA []byte) (int, error) {
i := len(dAtA)
_ = i _ = i
var l int var l int
_ = l _ = l
if len(m.Foo) > 0 { if m.XXX_unrecognized != nil {
dAtA[i] = 0xa i -= len(m.XXX_unrecognized)
i++ copy(dAtA[i:], m.XXX_unrecognized)
i = encodeVarintExample(dAtA, i, uint64(len(m.Foo)))
i += copy(dAtA[i:], m.Foo)
} }
if len(m.Bar) > 0 { if len(m.Bar) > 0 {
dAtA[i] = 0x12 i -= len(m.Bar)
i++ copy(dAtA[i:], m.Bar)
i = encodeVarintExample(dAtA, i, uint64(len(m.Bar))) i = encodeVarintExample(dAtA, i, uint64(len(m.Bar)))
i += copy(dAtA[i:], m.Bar) i--
dAtA[i] = 0x12
} }
return i, nil if len(m.Foo) > 0 {
i -= len(m.Foo)
copy(dAtA[i:], m.Foo)
i = encodeVarintExample(dAtA, i, uint64(len(m.Foo)))
i--
dAtA[i] = 0xa
}
return len(dAtA) - i, nil
} }
func (m *Method2Request) Marshal() (dAtA []byte, err error) { func (m *Method2Request) Marshal() (dAtA []byte, err error) {
size := m.Size() size := m.Size()
dAtA = make([]byte, size) dAtA = make([]byte, size)
n, err := m.MarshalTo(dAtA) n, err := m.MarshalToSizedBuffer(dAtA[:size])
if err != nil { if err != nil {
return nil, err return nil, err
} }
@ -141,29 +272,44 @@ func (m *Method2Request) Marshal() (dAtA []byte, err error) {
} }
func (m *Method2Request) MarshalTo(dAtA []byte) (int, error) { func (m *Method2Request) MarshalTo(dAtA []byte) (int, error) {
var i int size := m.Size()
return m.MarshalToSizedBuffer(dAtA[:size])
}
func (m *Method2Request) MarshalToSizedBuffer(dAtA []byte) (int, error) {
i := len(dAtA)
_ = i _ = i
var l int var l int
_ = l _ = l
if len(m.Action) > 0 { if m.XXX_unrecognized != nil {
dAtA[i] = 0xa i -= len(m.XXX_unrecognized)
i++ copy(dAtA[i:], m.XXX_unrecognized)
i = encodeVarintExample(dAtA, i, uint64(len(m.Action)))
i += copy(dAtA[i:], m.Action)
} }
return i, nil if len(m.Action) > 0 {
i -= len(m.Action)
copy(dAtA[i:], m.Action)
i = encodeVarintExample(dAtA, i, uint64(len(m.Action)))
i--
dAtA[i] = 0xa
}
return len(dAtA) - i, nil
} }
func encodeVarintExample(dAtA []byte, offset int, v uint64) int { func encodeVarintExample(dAtA []byte, offset int, v uint64) int {
offset -= sovExample(v)
base := offset
for v >= 1<<7 { for v >= 1<<7 {
dAtA[offset] = uint8(v&0x7f | 0x80) dAtA[offset] = uint8(v&0x7f | 0x80)
v >>= 7 v >>= 7
offset++ offset++
} }
dAtA[offset] = uint8(v) dAtA[offset] = uint8(v)
return offset + 1 return base
} }
func (m *Method1Request) Size() (n int) { func (m *Method1Request) Size() (n int) {
if m == nil {
return 0
}
var l int var l int
_ = l _ = l
l = len(m.Foo) l = len(m.Foo)
@ -174,10 +320,16 @@ func (m *Method1Request) Size() (n int) {
if l > 0 { if l > 0 {
n += 1 + l + sovExample(uint64(l)) n += 1 + l + sovExample(uint64(l))
} }
if m.XXX_unrecognized != nil {
n += len(m.XXX_unrecognized)
}
return n return n
} }
func (m *Method1Response) Size() (n int) { func (m *Method1Response) Size() (n int) {
if m == nil {
return 0
}
var l int var l int
_ = l _ = l
l = len(m.Foo) l = len(m.Foo)
@ -188,28 +340,30 @@ func (m *Method1Response) Size() (n int) {
if l > 0 { if l > 0 {
n += 1 + l + sovExample(uint64(l)) n += 1 + l + sovExample(uint64(l))
} }
if m.XXX_unrecognized != nil {
n += len(m.XXX_unrecognized)
}
return n return n
} }
func (m *Method2Request) Size() (n int) { func (m *Method2Request) Size() (n int) {
if m == nil {
return 0
}
var l int var l int
_ = l _ = l
l = len(m.Action) l = len(m.Action)
if l > 0 { if l > 0 {
n += 1 + l + sovExample(uint64(l)) n += 1 + l + sovExample(uint64(l))
} }
if m.XXX_unrecognized != nil {
n += len(m.XXX_unrecognized)
}
return n return n
} }
func sovExample(x uint64) (n int) { func sovExample(x uint64) (n int) {
for { return (math_bits.Len64(x|1) + 6) / 7
n++
x >>= 7
if x == 0 {
break
}
}
return n
} }
func sozExample(x uint64) (n int) { func sozExample(x uint64) (n int) {
return sovExample(uint64((x << 1) ^ uint64((int64(x) >> 63)))) return sovExample(uint64((x << 1) ^ uint64((int64(x) >> 63))))
@ -221,6 +375,7 @@ func (this *Method1Request) String() string {
s := strings.Join([]string{`&Method1Request{`, s := strings.Join([]string{`&Method1Request{`,
`Foo:` + fmt.Sprintf("%v", this.Foo) + `,`, `Foo:` + fmt.Sprintf("%v", this.Foo) + `,`,
`Bar:` + fmt.Sprintf("%v", this.Bar) + `,`, `Bar:` + fmt.Sprintf("%v", this.Bar) + `,`,
`XXX_unrecognized:` + fmt.Sprintf("%v", this.XXX_unrecognized) + `,`,
`}`, `}`,
}, "") }, "")
return s return s
@ -232,6 +387,7 @@ func (this *Method1Response) String() string {
s := strings.Join([]string{`&Method1Response{`, s := strings.Join([]string{`&Method1Response{`,
`Foo:` + fmt.Sprintf("%v", this.Foo) + `,`, `Foo:` + fmt.Sprintf("%v", this.Foo) + `,`,
`Bar:` + fmt.Sprintf("%v", this.Bar) + `,`, `Bar:` + fmt.Sprintf("%v", this.Bar) + `,`,
`XXX_unrecognized:` + fmt.Sprintf("%v", this.XXX_unrecognized) + `,`,
`}`, `}`,
}, "") }, "")
return s return s
@ -242,6 +398,7 @@ func (this *Method2Request) String() string {
} }
s := strings.Join([]string{`&Method2Request{`, s := strings.Join([]string{`&Method2Request{`,
`Action:` + fmt.Sprintf("%v", this.Action) + `,`, `Action:` + fmt.Sprintf("%v", this.Action) + `,`,
`XXX_unrecognized:` + fmt.Sprintf("%v", this.XXX_unrecognized) + `,`,
`}`, `}`,
}, "") }, "")
return s return s
@ -257,11 +414,11 @@ func valueToStringExample(v interface{}) string {
type ExampleService interface { type ExampleService interface {
Method1(ctx context.Context, req *Method1Request) (*Method1Response, error) Method1(ctx context.Context, req *Method1Request) (*Method1Response, error)
Method2(ctx context.Context, req *Method1Request) (*google_protobuf.Empty, error) Method2(ctx context.Context, req *Method1Request) (*types.Empty, error)
} }
func RegisterExampleService(srv *ttrpc.Server, svc ExampleService) { func RegisterExampleService(srv *github_com_containerd_ttrpc.Server, svc ExampleService) {
srv.Register("ttrpc.example.v1.Example", map[string]ttrpc.Method{ srv.Register("ttrpc.example.v1.Example", map[string]github_com_containerd_ttrpc.Method{
"Method1": func(ctx context.Context, unmarshal func(interface{}) error) (interface{}, error) { "Method1": func(ctx context.Context, unmarshal func(interface{}) error) (interface{}, error) {
var req Method1Request var req Method1Request
if err := unmarshal(&req); err != nil { if err := unmarshal(&req); err != nil {
@ -280,10 +437,10 @@ func RegisterExampleService(srv *ttrpc.Server, svc ExampleService) {
} }
type exampleClient struct { type exampleClient struct {
client *ttrpc.Client client *github_com_containerd_ttrpc.Client
} }
func NewExampleClient(client *ttrpc.Client) ExampleService { func NewExampleClient(client *github_com_containerd_ttrpc.Client) ExampleService {
return &exampleClient{ return &exampleClient{
client: client, client: client,
} }
@ -297,8 +454,8 @@ func (c *exampleClient) Method1(ctx context.Context, req *Method1Request) (*Meth
return &resp, nil return &resp, nil
} }
func (c *exampleClient) Method2(ctx context.Context, req *Method1Request) (*google_protobuf.Empty, error) { func (c *exampleClient) Method2(ctx context.Context, req *Method1Request) (*types.Empty, error) {
var resp google_protobuf.Empty var resp types.Empty
if err := c.client.Call(ctx, "ttrpc.example.v1.Example", "Method2", req, &resp); err != nil { if err := c.client.Call(ctx, "ttrpc.example.v1.Example", "Method2", req, &resp); err != nil {
return nil, err return nil, err
} }
@ -319,7 +476,7 @@ func (m *Method1Request) Unmarshal(dAtA []byte) error {
} }
b := dAtA[iNdEx] b := dAtA[iNdEx]
iNdEx++ iNdEx++
wire |= (uint64(b) & 0x7F) << shift wire |= uint64(b&0x7F) << shift
if b < 0x80 { if b < 0x80 {
break break
} }
@ -347,7 +504,7 @@ func (m *Method1Request) Unmarshal(dAtA []byte) error {
} }
b := dAtA[iNdEx] b := dAtA[iNdEx]
iNdEx++ iNdEx++
stringLen |= (uint64(b) & 0x7F) << shift stringLen |= uint64(b&0x7F) << shift
if b < 0x80 { if b < 0x80 {
break break
} }
@ -357,6 +514,9 @@ func (m *Method1Request) Unmarshal(dAtA []byte) error {
return ErrInvalidLengthExample return ErrInvalidLengthExample
} }
postIndex := iNdEx + intStringLen postIndex := iNdEx + intStringLen
if postIndex < 0 {
return ErrInvalidLengthExample
}
if postIndex > l { if postIndex > l {
return io.ErrUnexpectedEOF return io.ErrUnexpectedEOF
} }
@ -376,7 +536,7 @@ func (m *Method1Request) Unmarshal(dAtA []byte) error {
} }
b := dAtA[iNdEx] b := dAtA[iNdEx]
iNdEx++ iNdEx++
stringLen |= (uint64(b) & 0x7F) << shift stringLen |= uint64(b&0x7F) << shift
if b < 0x80 { if b < 0x80 {
break break
} }
@ -386,6 +546,9 @@ func (m *Method1Request) Unmarshal(dAtA []byte) error {
return ErrInvalidLengthExample return ErrInvalidLengthExample
} }
postIndex := iNdEx + intStringLen postIndex := iNdEx + intStringLen
if postIndex < 0 {
return ErrInvalidLengthExample
}
if postIndex > l { if postIndex > l {
return io.ErrUnexpectedEOF return io.ErrUnexpectedEOF
} }
@ -397,12 +560,13 @@ func (m *Method1Request) Unmarshal(dAtA []byte) error {
if err != nil { if err != nil {
return err return err
} }
if skippy < 0 { if (skippy < 0) || (iNdEx+skippy) < 0 {
return ErrInvalidLengthExample return ErrInvalidLengthExample
} }
if (iNdEx + skippy) > l { if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF return io.ErrUnexpectedEOF
} }
m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
iNdEx += skippy iNdEx += skippy
} }
} }
@ -427,7 +591,7 @@ func (m *Method1Response) Unmarshal(dAtA []byte) error {
} }
b := dAtA[iNdEx] b := dAtA[iNdEx]
iNdEx++ iNdEx++
wire |= (uint64(b) & 0x7F) << shift wire |= uint64(b&0x7F) << shift
if b < 0x80 { if b < 0x80 {
break break
} }
@ -455,7 +619,7 @@ func (m *Method1Response) Unmarshal(dAtA []byte) error {
} }
b := dAtA[iNdEx] b := dAtA[iNdEx]
iNdEx++ iNdEx++
stringLen |= (uint64(b) & 0x7F) << shift stringLen |= uint64(b&0x7F) << shift
if b < 0x80 { if b < 0x80 {
break break
} }
@ -465,6 +629,9 @@ func (m *Method1Response) Unmarshal(dAtA []byte) error {
return ErrInvalidLengthExample return ErrInvalidLengthExample
} }
postIndex := iNdEx + intStringLen postIndex := iNdEx + intStringLen
if postIndex < 0 {
return ErrInvalidLengthExample
}
if postIndex > l { if postIndex > l {
return io.ErrUnexpectedEOF return io.ErrUnexpectedEOF
} }
@ -484,7 +651,7 @@ func (m *Method1Response) Unmarshal(dAtA []byte) error {
} }
b := dAtA[iNdEx] b := dAtA[iNdEx]
iNdEx++ iNdEx++
stringLen |= (uint64(b) & 0x7F) << shift stringLen |= uint64(b&0x7F) << shift
if b < 0x80 { if b < 0x80 {
break break
} }
@ -494,6 +661,9 @@ func (m *Method1Response) Unmarshal(dAtA []byte) error {
return ErrInvalidLengthExample return ErrInvalidLengthExample
} }
postIndex := iNdEx + intStringLen postIndex := iNdEx + intStringLen
if postIndex < 0 {
return ErrInvalidLengthExample
}
if postIndex > l { if postIndex > l {
return io.ErrUnexpectedEOF return io.ErrUnexpectedEOF
} }
@ -505,12 +675,13 @@ func (m *Method1Response) Unmarshal(dAtA []byte) error {
if err != nil { if err != nil {
return err return err
} }
if skippy < 0 { if (skippy < 0) || (iNdEx+skippy) < 0 {
return ErrInvalidLengthExample return ErrInvalidLengthExample
} }
if (iNdEx + skippy) > l { if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF return io.ErrUnexpectedEOF
} }
m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
iNdEx += skippy iNdEx += skippy
} }
} }
@ -535,7 +706,7 @@ func (m *Method2Request) Unmarshal(dAtA []byte) error {
} }
b := dAtA[iNdEx] b := dAtA[iNdEx]
iNdEx++ iNdEx++
wire |= (uint64(b) & 0x7F) << shift wire |= uint64(b&0x7F) << shift
if b < 0x80 { if b < 0x80 {
break break
} }
@ -563,7 +734,7 @@ func (m *Method2Request) Unmarshal(dAtA []byte) error {
} }
b := dAtA[iNdEx] b := dAtA[iNdEx]
iNdEx++ iNdEx++
stringLen |= (uint64(b) & 0x7F) << shift stringLen |= uint64(b&0x7F) << shift
if b < 0x80 { if b < 0x80 {
break break
} }
@ -573,6 +744,9 @@ func (m *Method2Request) Unmarshal(dAtA []byte) error {
return ErrInvalidLengthExample return ErrInvalidLengthExample
} }
postIndex := iNdEx + intStringLen postIndex := iNdEx + intStringLen
if postIndex < 0 {
return ErrInvalidLengthExample
}
if postIndex > l { if postIndex > l {
return io.ErrUnexpectedEOF return io.ErrUnexpectedEOF
} }
@ -584,12 +758,13 @@ func (m *Method2Request) Unmarshal(dAtA []byte) error {
if err != nil { if err != nil {
return err return err
} }
if skippy < 0 { if (skippy < 0) || (iNdEx+skippy) < 0 {
return ErrInvalidLengthExample return ErrInvalidLengthExample
} }
if (iNdEx + skippy) > l { if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF return io.ErrUnexpectedEOF
} }
m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
iNdEx += skippy iNdEx += skippy
} }
} }
@ -602,6 +777,7 @@ func (m *Method2Request) Unmarshal(dAtA []byte) error {
func skipExample(dAtA []byte) (n int, err error) { func skipExample(dAtA []byte) (n int, err error) {
l := len(dAtA) l := len(dAtA)
iNdEx := 0 iNdEx := 0
depth := 0
for iNdEx < l { for iNdEx < l {
var wire uint64 var wire uint64
for shift := uint(0); ; shift += 7 { for shift := uint(0); ; shift += 7 {
@ -633,10 +809,8 @@ func skipExample(dAtA []byte) (n int, err error) {
break break
} }
} }
return iNdEx, nil
case 1: case 1:
iNdEx += 8 iNdEx += 8
return iNdEx, nil
case 2: case 2:
var length int var length int
for shift := uint(0); ; shift += 7 { for shift := uint(0); ; shift += 7 {
@ -653,79 +827,34 @@ func skipExample(dAtA []byte) (n int, err error) {
break break
} }
} }
iNdEx += length
if length < 0 { if length < 0 {
return 0, ErrInvalidLengthExample return 0, ErrInvalidLengthExample
} }
return iNdEx, nil iNdEx += length
case 3: case 3:
for { depth++
var innerWire uint64
var start int = iNdEx
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return 0, ErrIntOverflowExample
}
if iNdEx >= l {
return 0, io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
innerWire |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
innerWireType := int(innerWire & 0x7)
if innerWireType == 4 {
break
}
next, err := skipExample(dAtA[start:])
if err != nil {
return 0, err
}
iNdEx = start + next
}
return iNdEx, nil
case 4: case 4:
return iNdEx, nil if depth == 0 {
return 0, ErrUnexpectedEndOfGroupExample
}
depth--
case 5: case 5:
iNdEx += 4 iNdEx += 4
return iNdEx, nil
default: default:
return 0, fmt.Errorf("proto: illegal wireType %d", wireType) return 0, fmt.Errorf("proto: illegal wireType %d", wireType)
} }
if iNdEx < 0 {
return 0, ErrInvalidLengthExample
}
if depth == 0 {
return iNdEx, nil
}
} }
panic("unreachable") return 0, io.ErrUnexpectedEOF
} }
var ( var (
ErrInvalidLengthExample = fmt.Errorf("proto: negative length found during unmarshaling") ErrInvalidLengthExample = fmt.Errorf("proto: negative length found during unmarshaling")
ErrIntOverflowExample = fmt.Errorf("proto: integer overflow") ErrIntOverflowExample = fmt.Errorf("proto: integer overflow")
ErrUnexpectedEndOfGroupExample = fmt.Errorf("proto: unexpected end of group")
) )
func init() {
proto.RegisterFile("github.com/containerd/ttrpc/example/example.proto", fileDescriptorExample)
}
var fileDescriptorExample = []byte{
// 279 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xe2, 0x32, 0x4c, 0xcf, 0x2c, 0xc9,
0x28, 0x4d, 0xd2, 0x4b, 0xce, 0xcf, 0xd5, 0x4f, 0xce, 0xcf, 0x2b, 0x49, 0xcc, 0xcc, 0x4b, 0x2d,
0x4a, 0xd1, 0x2f, 0x29, 0x29, 0x2a, 0x48, 0xd6, 0x4f, 0xad, 0x48, 0xcc, 0x2d, 0xc8, 0x49, 0x85,
0xd1, 0x7a, 0x05, 0x45, 0xf9, 0x25, 0xf9, 0x42, 0x02, 0x60, 0x49, 0x3d, 0x98, 0x60, 0x99, 0xa1,
0x94, 0x74, 0x7a, 0x7e, 0x7e, 0x7a, 0x4e, 0xaa, 0x3e, 0x58, 0x3e, 0xa9, 0x34, 0x4d, 0x3f, 0x35,
0xb7, 0xa0, 0xa4, 0x12, 0xa2, 0x5c, 0x4a, 0x24, 0x3d, 0x3f, 0x3d, 0x1f, 0xcc, 0xd4, 0x07, 0xb1,
0x20, 0xa2, 0x4a, 0x26, 0x5c, 0x7c, 0xbe, 0xa9, 0x25, 0x19, 0xf9, 0x29, 0x86, 0x41, 0xa9, 0x85,
0xa5, 0xa9, 0xc5, 0x25, 0x42, 0x02, 0x5c, 0xcc, 0x69, 0xf9, 0xf9, 0x12, 0x8c, 0x0a, 0x8c, 0x1a,
0x9c, 0x41, 0x20, 0x26, 0x48, 0x24, 0x29, 0xb1, 0x48, 0x82, 0x09, 0x22, 0x92, 0x94, 0x58, 0xa4,
0x64, 0xca, 0xc5, 0x0f, 0xd7, 0x55, 0x5c, 0x90, 0x9f, 0x57, 0x9c, 0x4a, 0x94, 0x36, 0x0d, 0x98,
0x65, 0x46, 0x30, 0xcb, 0xc4, 0xb8, 0xd8, 0x12, 0x93, 0x4b, 0x32, 0xf3, 0xf3, 0xa0, 0x1a, 0xa1,
0x3c, 0xa3, 0x79, 0x8c, 0x5c, 0xec, 0xae, 0x10, 0x8f, 0x09, 0xf9, 0x71, 0xb1, 0x43, 0x2d, 0x13,
0x52, 0xd0, 0x43, 0xf7, 0xb3, 0x1e, 0xaa, 0xeb, 0xa5, 0x14, 0xf1, 0xa8, 0x80, 0xba, 0xd4, 0x19,
0x66, 0x9e, 0x11, 0x11, 0xe6, 0x89, 0xe9, 0x41, 0xc2, 0x54, 0x0f, 0x16, 0xa6, 0x7a, 0xae, 0xa0,
0x30, 0x75, 0x72, 0x3d, 0xf1, 0x50, 0x8e, 0xe1, 0xc6, 0x43, 0x39, 0x86, 0x86, 0x47, 0x72, 0x8c,
0x27, 0x1e, 0xc9, 0x31, 0x5e, 0x78, 0x24, 0xc7, 0xf8, 0xe0, 0x91, 0x1c, 0x63, 0x94, 0x36, 0x11,
0x31, 0x69, 0x0d, 0xa5, 0x93, 0xd8, 0xc0, 0xc6, 0x1a, 0x03, 0x02, 0x00, 0x00, 0xff, 0xff, 0x4a,
0xc9, 0x2c, 0xdc, 0xff, 0x01, 0x00, 0x00,
}