Skip to content

S
sidecar
Commit 71978d8d authored by suyanlong's avatar suyanlong
Browse files
Options

Merge branch 'master' of https://gitlab.33.cn/link33/sidecar

parents 3c662c5f 04eb4a2e
Pipeline #8626 canceled with stages
      Show whitespace changes
      Inline Side-by-side
      Showing with 286 additions and 199 deletions
      model/pb/basic.pb.go
      View file @ 71978d8d
      ......@@ -5,18 +5,15 @@ package pb
      import (
      fmt "fmt"
      proto "github.com/gogo/protobuf/proto"
      io "io"
      math "math"
      math_bits "math/bits"
      proto "github.com/gogo/protobuf/proto"
      )
      // Reference imports to suppress errors if they are not otherwise used.
      var _ = proto.Marshal
      var _ = fmt.Errorf
      var _ = math.Inf
      // This is a compile-time assertion to ensure that this generated file
      ......@@ -30,19 +27,14 @@ type Uint64Slice struct {
      }
      func (m *Uint64Slice) Reset() { *m = Uint64Slice{} }
      func (m *Uint64Slice) String() string { return proto.CompactTextString(m) }
      func (*Uint64Slice) ProtoMessage() {}
      func (*Uint64Slice) Descriptor() ([]byte, []int) {
      return fileDescriptor_0cc45f6ac745dd88, []int{0}
      }
      func (m *Uint64Slice) XXX_Unmarshal(b []byte) error {
      return m.Unmarshal(b)
      }
      func (m *Uint64Slice) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
      if deterministic {
      return xxx_messageInfo_Uint64Slice.Marshal(b, m, deterministic)
      ......@@ -55,15 +47,12 @@ func (m *Uint64Slice) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
      return b[:n], nil
      }
      }
      func (m *Uint64Slice) XXX_Merge(src proto.Message) {
      xxx_messageInfo_Uint64Slice.Merge(m, src)
      }
      func (m *Uint64Slice) XXX_Size() int {
      return m.Size()
      }
      func (m *Uint64Slice) XXX_DiscardUnknown() {
      xxx_messageInfo_Uint64Slice.DiscardUnknown(m)
      }
      ......@@ -83,19 +72,14 @@ type StringUint64Map struct {
      }
      func (m *StringUint64Map) Reset() { *m = StringUint64Map{} }
      func (m *StringUint64Map) String() string { return proto.CompactTextString(m) }
      func (*StringUint64Map) ProtoMessage() {}
      func (*StringUint64Map) Descriptor() ([]byte, []int) {
      return fileDescriptor_0cc45f6ac745dd88, []int{1}
      }
      func (m *StringUint64Map) XXX_Unmarshal(b []byte) error {
      return m.Unmarshal(b)
      }
      func (m *StringUint64Map) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
      if deterministic {
      return xxx_messageInfo_StringUint64Map.Marshal(b, m, deterministic)
      ......@@ -108,15 +92,12 @@ func (m *StringUint64Map) XXX_Marshal(b []byte, deterministic bool) ([]byte, err
      return b[:n], nil
      }
      }
      func (m *StringUint64Map) XXX_Merge(src proto.Message) {
      xxx_messageInfo_StringUint64Map.Merge(m, src)
      }
      func (m *StringUint64Map) XXX_Size() int {
      return m.Size()
      }
      func (m *StringUint64Map) XXX_DiscardUnknown() {
      xxx_messageInfo_StringUint64Map.DiscardUnknown(m)
      }
      ......@@ -143,19 +124,14 @@ type StringUint64SliceMap struct {
      }
      func (m *StringUint64SliceMap) Reset() { *m = StringUint64SliceMap{} }
      func (m *StringUint64SliceMap) String() string { return proto.CompactTextString(m) }
      func (*StringUint64SliceMap) ProtoMessage() {}
      func (*StringUint64SliceMap) Descriptor() ([]byte, []int) {
      return fileDescriptor_0cc45f6ac745dd88, []int{2}
      }
      func (m *StringUint64SliceMap) XXX_Unmarshal(b []byte) error {
      return m.Unmarshal(b)
      }
      func (m *StringUint64SliceMap) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
      if deterministic {
      return xxx_messageInfo_StringUint64SliceMap.Marshal(b, m, deterministic)
      ......@@ -168,15 +144,12 @@ func (m *StringUint64SliceMap) XXX_Marshal(b []byte, deterministic bool) ([]byte
      return b[:n], nil
      }
      }
      func (m *StringUint64SliceMap) XXX_Merge(src proto.Message) {
      xxx_messageInfo_StringUint64SliceMap.Merge(m, src)
      }
      func (m *StringUint64SliceMap) XXX_Size() int {
      return m.Size()
      }
      func (m *StringUint64SliceMap) XXX_DiscardUnknown() {
      xxx_messageInfo_StringUint64SliceMap.DiscardUnknown(m)
      }
      ......@@ -203,19 +176,14 @@ type VerifiedIndex struct {
      }
      func (m *VerifiedIndex) Reset() { *m = VerifiedIndex{} }
      func (m *VerifiedIndex) String() string { return proto.CompactTextString(m) }
      func (*VerifiedIndex) ProtoMessage() {}
      func (*VerifiedIndex) Descriptor() ([]byte, []int) {
      return fileDescriptor_0cc45f6ac745dd88, []int{3}
      }
      func (m *VerifiedIndex) XXX_Unmarshal(b []byte) error {
      return m.Unmarshal(b)
      }
      func (m *VerifiedIndex) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
      if deterministic {
      return xxx_messageInfo_VerifiedIndex.Marshal(b, m, deterministic)
      ......@@ -228,15 +196,12 @@ func (m *VerifiedIndex) XXX_Marshal(b []byte, deterministic bool) ([]byte, error
      return b[:n], nil
      }
      }
      func (m *VerifiedIndex) XXX_Merge(src proto.Message) {
      xxx_messageInfo_VerifiedIndex.Merge(m, src)
      }
      func (m *VerifiedIndex) XXX_Size() int {
      return m.Size()
      }
      func (m *VerifiedIndex) XXX_DiscardUnknown() {
      xxx_messageInfo_VerifiedIndex.DiscardUnknown(m)
      }
      ......@@ -262,19 +227,14 @@ type VerifiedIndexSlice struct {
      }
      func (m *VerifiedIndexSlice) Reset() { *m = VerifiedIndexSlice{} }
      func (m *VerifiedIndexSlice) String() string { return proto.CompactTextString(m) }
      func (*VerifiedIndexSlice) ProtoMessage() {}
      func (*VerifiedIndexSlice) Descriptor() ([]byte, []int) {
      return fileDescriptor_0cc45f6ac745dd88, []int{4}
      }
      func (m *VerifiedIndexSlice) XXX_Unmarshal(b []byte) error {
      return m.Unmarshal(b)
      }
      func (m *VerifiedIndexSlice) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
      if deterministic {
      return xxx_messageInfo_VerifiedIndexSlice.Marshal(b, m, deterministic)
      ......@@ -287,15 +247,12 @@ func (m *VerifiedIndexSlice) XXX_Marshal(b []byte, deterministic bool) ([]byte,
      return b[:n], nil
      }
      }
      func (m *VerifiedIndexSlice) XXX_Merge(src proto.Message) {
      xxx_messageInfo_VerifiedIndexSlice.Merge(m, src)
      }
      func (m *VerifiedIndexSlice) XXX_Size() int {
      return m.Size()
      }
      func (m *VerifiedIndexSlice) XXX_DiscardUnknown() {
      xxx_messageInfo_VerifiedIndexSlice.DiscardUnknown(m)
      }
      ......@@ -315,19 +272,14 @@ type StringVerifiedIndexMap struct {
      }
      func (m *StringVerifiedIndexMap) Reset() { *m = StringVerifiedIndexMap{} }
      func (m *StringVerifiedIndexMap) String() string { return proto.CompactTextString(m) }
      func (*StringVerifiedIndexMap) ProtoMessage() {}
      func (*StringVerifiedIndexMap) Descriptor() ([]byte, []int) {
      return fileDescriptor_0cc45f6ac745dd88, []int{5}
      }
      func (m *StringVerifiedIndexMap) XXX_Unmarshal(b []byte) error {
      return m.Unmarshal(b)
      }
      func (m *StringVerifiedIndexMap) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
      if deterministic {
      return xxx_messageInfo_StringVerifiedIndexMap.Marshal(b, m, deterministic)
      ......@@ -340,15 +292,12 @@ func (m *StringVerifiedIndexMap) XXX_Marshal(b []byte, deterministic bool) ([]by
      return b[:n], nil
      }
      }
      func (m *StringVerifiedIndexMap) XXX_Merge(src proto.Message) {
      xxx_messageInfo_StringVerifiedIndexMap.Merge(m, src)
      }
      func (m *StringVerifiedIndexMap) XXX_Size() int {
      return m.Size()
      }
      func (m *StringVerifiedIndexMap) XXX_DiscardUnknown() {
      xxx_messageInfo_StringVerifiedIndexMap.DiscardUnknown(m)
      }
      ......@@ -375,19 +324,14 @@ type StringVerifiedIndexSliceMap struct {
      }
      func (m *StringVerifiedIndexSliceMap) Reset() { *m = StringVerifiedIndexSliceMap{} }
      func (m *StringVerifiedIndexSliceMap) String() string { return proto.CompactTextString(m) }
      func (*StringVerifiedIndexSliceMap) ProtoMessage() {}
      func (*StringVerifiedIndexSliceMap) Descriptor() ([]byte, []int) {
      return fileDescriptor_0cc45f6ac745dd88, []int{6}
      }
      func (m *StringVerifiedIndexSliceMap) XXX_Unmarshal(b []byte) error {
      return m.Unmarshal(b)
      }
      func (m *StringVerifiedIndexSliceMap) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
      if deterministic {
      return xxx_messageInfo_StringVerifiedIndexSliceMap.Marshal(b, m, deterministic)
      ......@@ -400,15 +344,12 @@ func (m *StringVerifiedIndexSliceMap) XXX_Marshal(b []byte, deterministic bool)
      return b[:n], nil
      }
      }
      func (m *StringVerifiedIndexSliceMap) XXX_Merge(src proto.Message) {
      xxx_messageInfo_StringVerifiedIndexSliceMap.Merge(m, src)
      }
      func (m *StringVerifiedIndexSliceMap) XXX_Size() int {
      return m.Size()
      }
      func (m *StringVerifiedIndexSliceMap) XXX_DiscardUnknown() {
      xxx_messageInfo_StringVerifiedIndexSliceMap.DiscardUnknown(m)
      }
      ......@@ -777,7 +718,6 @@ func encodeVarintBasic(dAtA []byte, offset int, v uint64) int {
      dAtA[offset] = uint8(v)
      return base
      }
      func (m *Uint64Slice) Size() (n int) {
      if m == nil {
      return 0
      ......@@ -912,11 +852,9 @@ func (m *StringVerifiedIndexSliceMap) Size() (n int) {
      func sovBasic(x uint64) (n int) {
      return (math_bits.Len64(x|1) + 6) / 7
      }
      func sozBasic(x uint64) (n int) {
      return sovBasic(uint64((x << 1) ^ uint64((int64(x) >> 63))))
      }
      func (m *Uint64Slice) Unmarshal(dAtA []byte) error {
      l := len(dAtA)
      iNdEx := 0
      ......@@ -1043,7 +981,6 @@ func (m *Uint64Slice) Unmarshal(dAtA []byte) error {
      }
      return nil
      }
      func (m *StringUint64Map) Unmarshal(dAtA []byte) error {
      l := len(dAtA)
      iNdEx := 0
      ......@@ -1202,7 +1139,6 @@ func (m *StringUint64Map) Unmarshal(dAtA []byte) error {
      }
      return nil
      }
      func (m *StringUint64SliceMap) Unmarshal(dAtA []byte) error {
      l := len(dAtA)
      iNdEx := 0
      ......@@ -1319,7 +1255,6 @@ func (m *StringUint64SliceMap) Unmarshal(dAtA []byte) error {
      }
      return nil
      }
      func (m *VerifiedIndex) Unmarshal(dAtA []byte) error {
      l := len(dAtA)
      iNdEx := 0
      ......@@ -1409,7 +1344,6 @@ func (m *VerifiedIndex) Unmarshal(dAtA []byte) error {
      }
      return nil
      }
      func (m *VerifiedIndexSlice) Unmarshal(dAtA []byte) error {
      l := len(dAtA)
      iNdEx := 0
      ......@@ -1494,7 +1428,6 @@ func (m *VerifiedIndexSlice) Unmarshal(dAtA []byte) error {
      }
      return nil
      }
      func (m *StringVerifiedIndexMap) Unmarshal(dAtA []byte) error {
      l := len(dAtA)
      iNdEx := 0
      ......@@ -1611,7 +1544,6 @@ func (m *StringVerifiedIndexMap) Unmarshal(dAtA []byte) error {
      }
      return nil
      }
      func (m *StringVerifiedIndexSliceMap) Unmarshal(dAtA []byte) error {
      l := len(dAtA)
      iNdEx := 0
      ......@@ -1728,7 +1660,6 @@ func (m *StringVerifiedIndexSliceMap) Unmarshal(dAtA []byte) error {
      }
      return nil
      }
      func skipBasic(dAtA []byte) (n int, err error) {
      l := len(dAtA)
      iNdEx := 0
      ......
      model/pb/ibtp.go
      View file @ 71978d8d
      ......@@ -3,6 +3,8 @@ package pb
      import (
      "crypto/sha256"
      "fmt"
      "strconv"
      "strings"
      "github.com/meshplus/bitxhub-kit/types"
      )
      ......@@ -40,3 +42,68 @@ func (m *IBTP) Category() IBTP_Category {
      }
      return IBTP_UNKNOWN
      }
      func (m *IBTP) ServicePair() string {
      return fmt.Sprintf("%s-%s", m.From, m.To)
      }
      // ParseFrom should be called after CheckServiceID is called
      func (m *IBTP) ParseFrom() (string, string, string) {
      bxhID, chainID, serviceID, _ := ParseFullServiceID(m.From)
      return bxhID, chainID, serviceID
      }
      // ParseTo should be called after CheckServiceID is called
      func (m *IBTP) ParseTo() (string, string, string) {
      bxhID, chainID, serviceID, _ := ParseFullServiceID(m.To)
      return bxhID, chainID, serviceID
      }
      func (m *IBTP) CheckServiceID() error {
      _, _, _, err := ParseFullServiceID(m.From)
      if err != nil {
      return err
      }
      _, _, _, err = ParseFullServiceID(m.To)
      return err
      }
      func ParseFullServiceID(id string) (string, string, string, error) {
      splits := strings.Split(id, ":")
      if len(splits) != 3 {
      return "", "", "", fmt.Errorf("invalid full service ID: %s", id)
      }
      return splits[0], splits[1], splits[2], nil
      }
      func ParseServicePair(servicePair string) (string, string, error) {
      splits := strings.Split(servicePair, "-")
      if len(splits) != 2 {
      return "", "", fmt.Errorf("invalid service pair: %s", servicePair)
      }
      return splits[0], splits[1], nil
      }
      func ParseIBTPID(id string) (string, string, uint64, error) {
      splits := strings.Split(id, "-")
      if len(splits) != 3 {
      return "", "", 0, fmt.Errorf("invalid IBTP ID: %s", id)
      }
      index, err := strconv.Atoi(splits[2])
      if err != nil {
      return "", "", 0, fmt.Errorf("invalid IBTP ID: %s", id)
      }
      return splits[0], splits[1], uint64(index), nil
      }
      func GenServicePair(from, to string) string {
      return fmt.Sprintf("%s-%s", from, to)
      }
      model/pb/ibtp.pb.go
      View file @ 71978d8d
      ......@@ -5,18 +5,15 @@ package pb
      import (
      fmt "fmt"
      proto "github.com/gogo/protobuf/proto"
      io "io"
      math "math"
      math_bits "math/bits"
      proto "github.com/gogo/protobuf/proto"
      )
      // Reference imports to suppress errors if they are not otherwise used.
      var _ = proto.Marshal
      var _ = fmt.Errorf
      var _ = math.Inf
      // This is a compile-time assertion to ensure that this generated file
      ......@@ -112,19 +109,14 @@ type IBTP struct {
      }
      func (m *IBTP) Reset() { *m = IBTP{} }
      func (m *IBTP) String() string { return proto.CompactTextString(m) }
      func (*IBTP) ProtoMessage() {}
      func (*IBTP) Descriptor() ([]byte, []int) {
      return fileDescriptor_7576a0a5bf0190a3, []int{0}
      }
      func (m *IBTP) XXX_Unmarshal(b []byte) error {
      return m.Unmarshal(b)
      }
      func (m *IBTP) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
      if deterministic {
      return xxx_messageInfo_IBTP.Marshal(b, m, deterministic)
      ......@@ -137,15 +129,12 @@ func (m *IBTP) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
      return b[:n], nil
      }
      }
      func (m *IBTP) XXX_Merge(src proto.Message) {
      xxx_messageInfo_IBTP.Merge(m, src)
      }
      func (m *IBTP) XXX_Size() int {
      return m.Size()
      }
      func (m *IBTP) XXX_DiscardUnknown() {
      xxx_messageInfo_IBTP.DiscardUnknown(m)
      }
      ......@@ -228,19 +217,14 @@ type Payload struct {
      }
      func (m *Payload) Reset() { *m = Payload{} }
      func (m *Payload) String() string { return proto.CompactTextString(m) }
      func (*Payload) ProtoMessage() {}
      func (*Payload) Descriptor() ([]byte, []int) {
      return fileDescriptor_7576a0a5bf0190a3, []int{1}
      }
      func (m *Payload) XXX_Unmarshal(b []byte) error {
      return m.Unmarshal(b)
      }
      func (m *Payload) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
      if deterministic {
      return xxx_messageInfo_Payload.Marshal(b, m, deterministic)
      ......@@ -253,15 +237,12 @@ func (m *Payload) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
      return b[:n], nil
      }
      }
      func (m *Payload) XXX_Merge(src proto.Message) {
      xxx_messageInfo_Payload.Merge(m, src)
      }
      func (m *Payload) XXX_Size() int {
      return m.Size()
      }
      func (m *Payload) XXX_DiscardUnknown() {
      xxx_messageInfo_Payload.DiscardUnknown(m)
      }
      ......@@ -294,19 +275,14 @@ type Content struct {
      }
      func (m *Content) Reset() { *m = Content{} }
      func (m *Content) String() string { return proto.CompactTextString(m) }
      func (*Content) ProtoMessage() {}
      func (*Content) Descriptor() ([]byte, []int) {
      return fileDescriptor_7576a0a5bf0190a3, []int{2}
      }
      func (m *Content) XXX_Unmarshal(b []byte) error {
      return m.Unmarshal(b)
      }
      func (m *Content) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
      if deterministic {
      return xxx_messageInfo_Content.Marshal(b, m, deterministic)
      ......@@ -319,15 +295,12 @@ func (m *Content) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
      return b[:n], nil
      }
      }
      func (m *Content) XXX_Merge(src proto.Message) {
      xxx_messageInfo_Content.Merge(m, src)
      }
      func (m *Content) XXX_Size() int {
      return m.Size()
      }
      func (m *Content) XXX_DiscardUnknown() {
      xxx_messageInfo_Content.DiscardUnknown(m)
      }
      ......@@ -395,19 +368,14 @@ type IBTPs struct {
      }
      func (m *IBTPs) Reset() { *m = IBTPs{} }
      func (m *IBTPs) String() string { return proto.CompactTextString(m) }
      func (*IBTPs) ProtoMessage() {}
      func (*IBTPs) Descriptor() ([]byte, []int) {
      return fileDescriptor_7576a0a5bf0190a3, []int{3}
      }
      func (m *IBTPs) XXX_Unmarshal(b []byte) error {
      return m.Unmarshal(b)
      }
      func (m *IBTPs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
      if deterministic {
      return xxx_messageInfo_IBTPs.Marshal(b, m, deterministic)
      ......@@ -420,15 +388,12 @@ func (m *IBTPs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
      return b[:n], nil
      }
      }
      func (m *IBTPs) XXX_Merge(src proto.Message) {
      xxx_messageInfo_IBTPs.Merge(m, src)
      }
      func (m *IBTPs) XXX_Size() int {
      return m.Size()
      }
      func (m *IBTPs) XXX_DiscardUnknown() {
      xxx_messageInfo_IBTPs.DiscardUnknown(m)
      }
      ......@@ -442,6 +407,50 @@ func (m *IBTPs) GetIbtps() []*IBTP {
      return nil
      }
      type Result struct {
      Data [][]byte `protobuf:"bytes,1,rep,name=data,proto3" json:"data,omitempty"`
      }
      func (m *Result) Reset() { *m = Result{} }
      func (m *Result) String() string { return proto.CompactTextString(m) }
      func (*Result) ProtoMessage() {}
      func (*Result) Descriptor() ([]byte, []int) {
      return fileDescriptor_7576a0a5bf0190a3, []int{4}
      }
      func (m *Result) XXX_Unmarshal(b []byte) error {
      return m.Unmarshal(b)
      }
      func (m *Result) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
      if deterministic {
      return xxx_messageInfo_Result.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 *Result) XXX_Merge(src proto.Message) {
      xxx_messageInfo_Result.Merge(m, src)
      }
      func (m *Result) XXX_Size() int {
      return m.Size()
      }
      func (m *Result) XXX_DiscardUnknown() {
      xxx_messageInfo_Result.DiscardUnknown(m)
      }
      var xxx_messageInfo_Result proto.InternalMessageInfo
      func (m *Result) GetData() [][]byte {
      if m != nil {
      return m.Data
      }
      return nil
      }
      func init() {
      proto.RegisterEnum("pb.IBTP_Type", IBTP_Type_name, IBTP_Type_value)
      proto.RegisterEnum("pb.IBTP_Category", IBTP_Category_name, IBTP_Category_value)
      ......@@ -449,47 +458,49 @@ func init() {
      proto.RegisterType((*Payload)(nil), "pb.payload")
      proto.RegisterType((*Content)(nil), "pb.content")
      proto.RegisterType((*IBTPs)(nil), "pb.IBTPs")
      proto.RegisterType((*Result)(nil), "pb.result")
      }
      func init() { proto.RegisterFile("ibtp.proto", fileDescriptor_7576a0a5bf0190a3) }
      var fileDescriptor_7576a0a5bf0190a3 = []byte{
      // 551 bytes of a gzipped FileDescriptorProto
      0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x54, 0x53, 0xcd, 0x6e, 0xd3, 0x4c,
      0x14, 0xcd, 0xc4, 0x4e, 0xe2, 0xdc, 0xa4, 0xad, 0x35, 0xad, 0x3e, 0x8d, 0xaa, 0x4f, 0x96, 0xf1,
      0x02, 0xcc, 0x26, 0x8b, 0x80, 0xd8, 0xa7, 0x96, 0x11, 0x56, 0x8b, 0x5b, 0xc6, 0x89, 0x58, 0x56,
      0xfe, 0x6b, 0x64, 0xd1, 0x7a, 0x46, 0xe3, 0x29, 0x22, 0x6f, 0xc1, 0x53, 0xf0, 0x2c, 0x2c, 0xbb,
      0x64, 0x89, 0xda, 0x15, 0x6f, 0x81, 0x66, 0x1c, 0x27, 0x65, 0x37, 0xe7, 0xdc, 0x73, 0xee, 0xf5,
      0xcc, 0x3d, 0x06, 0xa8, 0x32, 0xc9, 0x67, 0x5c, 0x30, 0xc9, 0x70, 0x9f, 0x67, 0xa7, 0x93, 0x2c,
      0x6d, 0xaa, 0xbc, 0x25, 0xbc, 0x1f, 0x06, 0x98, 0xd1, 0xd9, 0xf2, 0x0a, 0x63, 0x30, 0x6f, 0x04,
      0xbb, 0x23, 0xc8, 0x45, 0xfe, 0x98, 0xea, 0x33, 0x3e, 0x84, 0xbe, 0x64, 0xa4, 0xaf, 0x99, 0xbe,
      0x64, 0xf8, 0x04, 0x06, 0x35, 0xab, 0xf3, 0x92, 0x18, 0x2e, 0xf2, 0x4d, 0xda, 0x02, 0xfc, 0x02,
      0x4c, 0xb9, 0xe1, 0x25, 0x31, 0x5d, 0xe4, 0x1f, 0xce, 0x0f, 0x66, 0x3c, 0x9b, 0xa9, 0x8e, 0xb3,
      0xe5, 0x86, 0x97, 0x54, 0x97, 0xf0, 0xff, 0x30, 0x96, 0xd5, 0x5d, 0xd9, 0xc8, 0xf4, 0x8e, 0x93,
      0x81, 0x8b, 0x7c, 0x83, 0xee, 0x09, 0xd5, 0x96, 0x0b, 0xc6, 0x6e, 0xc8, 0xd0, 0x45, 0xfe, 0x94,
      0xb6, 0x00, 0x13, 0x18, 0xf1, 0x74, 0x73, 0xcb, 0xd2, 0x82, 0x8c, 0x34, 0xdf, 0x41, 0xfc, 0x1a,
      0x06, 0x6b, 0xc1, 0xee, 0x39, 0xb1, 0x5c, 0xe4, 0x4f, 0xe6, 0xc7, 0x6a, 0x62, 0x22, 0x45, 0x55,
      0xaf, 0x57, 0x55, 0x2d, 0xdf, 0xbd, 0xfd, 0x98, 0x72, 0xda, 0x2a, 0x54, 0x93, 0xaf, 0xa5, 0x68,
      0x2a, 0x56, 0x93, 0xb1, 0xbe, 0x46, 0x07, 0xd5, 0xd0, 0xf2, 0x9b, 0x14, 0x29, 0x81, 0x76, 0xa8,
      0x06, 0x5e, 0x01, 0xa6, 0xfa, 0x6c, 0x7c, 0x08, 0x10, 0xc5, 0xcb, 0x90, 0x06, 0x1f, 0x16, 0x51,
      0x6c, 0xf7, 0xf0, 0x31, 0x1c, 0xd1, 0x30, 0x08, 0xa3, 0xab, 0xe5, 0x75, 0xb2, 0x0a, 0x82, 0x30,
      0x49, 0x6c, 0xf4, 0x9c, 0x7c, 0xbf, 0x88, 0x2e, 0x56, 0x34, 0xb4, 0xfb, 0x78, 0x0a, 0x16, 0xbd,
      0xbc, 0xb8, 0x38, 0x5b, 0x04, 0xe7, 0xb6, 0x81, 0x4f, 0xc0, 0xee, 0x24, 0x3b, 0xd6, 0xf4, 0xe6,
      0x60, 0x05, 0xa9, 0x2c, 0xd7, 0x4c, 0x6c, 0xf0, 0x04, 0x46, 0x34, 0xfc, 0xb4, 0x0a, 0x93, 0xa5,
      0xdd, 0xd3, 0xe6, 0x30, 0xb9, 0xba, 0x8c, 0x93, 0xd0, 0x46, 0xaa, 0xb4, 0x8a, 0xcf, 0xe3, 0xcb,
      0xcf, 0xb1, 0xdd, 0xf7, 0x16, 0xbb, 0xe7, 0x50, 0xaf, 0x59, 0xd6, 0xb9, 0xd8, 0x70, 0x59, 0x16,
      0x7a, 0x5f, 0x16, 0xdd, 0x13, 0xea, 0xca, 0x39, 0xab, 0x65, 0x59, 0x4b, 0xbd, 0xb9, 0x29, 0xed,
      0xa0, 0xf7, 0x07, 0xed, 0x4a, 0xf8, 0x25, 0x1c, 0x35, 0x22, 0xbf, 0x56, 0x50, 0xa4, 0xb9, 0xbc,
      0xae, 0x8a, 0xed, 0xe6, 0x0f, 0x1a, 0x91, 0x07, 0x5b, 0x36, 0x2a, 0x94, 0xae, 0x68, 0xe4, 0x3f,
      0xba, 0x36, 0x0f, 0x07, 0x45, 0x23, 0x9f, 0xe9, 0x54, 0x7c, 0xee, 0xeb, 0x5c, 0x27, 0x43, 0xc5,
      0xe7, 0xbe, 0xce, 0x15, 0x97, 0x8a, 0x75, 0x43, 0x4c, 0xd7, 0xf0, 0xa7, 0x54, 0x9f, 0xf1, 0x29,
      0x58, 0x79, 0x7a, 0x7b, 0x9b, 0xa5, 0xf9, 0x17, 0x1d, 0x84, 0x31, 0xdd, 0x61, 0xfc, 0x1f, 0x0c,
      0x95, 0x26, 0xc8, 0xc8, 0x50, 0x3b, 0xb6, 0x48, 0x79, 0x04, 0xdb, 0x7a, 0x46, 0xad, 0xa7, 0xc3,
      0x9d, 0x87, 0x66, 0xc4, 0xda, 0x7b, 0x68, 0xe6, 0xbd, 0x82, 0x81, 0x0a, 0x61, 0x83, 0x1d, 0x18,
      0xa8, 0xfc, 0x37, 0x04, 0xb9, 0x86, 0x3f, 0x99, 0x5b, 0x5d, 0x3c, 0x69, 0x4b, 0x9f, 0x91, 0x9f,
      0x8f, 0x0e, 0x7a, 0x78, 0x74, 0xd0, 0xef, 0x47, 0x07, 0x7d, 0x7f, 0x72, 0x7a, 0x0f, 0x4f, 0x4e,
      0xef, 0xd7, 0x93, 0xd3, 0xcb, 0x86, 0xfa, 0x0f, 0x79, 0xf3, 0x37, 0x00, 0x00, 0xff, 0xff, 0xf4,
      0x8e, 0xc3, 0xc2, 0x40, 0x03, 0x00, 0x00,
      // 568 bytes of a gzipped FileDescriptorProto
      0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x54, 0x53, 0x4d, 0x6f, 0xd3, 0x40,
      0x10, 0xcd, 0x26, 0x4e, 0xe2, 0x4c, 0xd2, 0xd6, 0xda, 0x56, 0x68, 0x55, 0x55, 0x96, 0xf1, 0x01,
      0xcc, 0x25, 0x87, 0x80, 0xb8, 0xa7, 0x96, 0x11, 0x51, 0x4b, 0x5a, 0xd6, 0x89, 0x38, 0x56, 0xeb,
      0x8f, 0x46, 0x16, 0xa9, 0x77, 0xb5, 0xde, 0x20, 0xf2, 0x2f, 0xf8, 0x15, 0xfc, 0x16, 0x8e, 0x3d,
      0x72, 0x44, 0xed, 0x89, 0x7f, 0x81, 0x76, 0x1d, 0xa7, 0xe5, 0xb6, 0xef, 0xcd, 0x7b, 0x33, 0xde,
      0x9d, 0x67, 0x80, 0x22, 0x51, 0x62, 0x2c, 0x24, 0x57, 0x1c, 0xb7, 0x45, 0x72, 0x3a, 0x4c, 0x58,
      0x55, 0xa4, 0x35, 0xe1, 0xff, 0xec, 0x80, 0x35, 0x3b, 0x5f, 0x5c, 0x63, 0x0c, 0xd6, 0xad, 0xe4,
      0x77, 0x04, 0x79, 0x28, 0x18, 0x50, 0x73, 0xc6, 0x87, 0xd0, 0x56, 0x9c, 0xb4, 0x0d, 0xd3, 0x56,
      0x1c, 0x9f, 0x40, 0xb7, 0xe4, 0x65, 0x9a, 0x93, 0x8e, 0x87, 0x02, 0x8b, 0xd6, 0x00, 0xbf, 0x04,
      0x4b, 0x6d, 0x45, 0x4e, 0x2c, 0x0f, 0x05, 0x87, 0x93, 0x83, 0xb1, 0x48, 0xc6, 0xba, 0xe3, 0x78,
      0xb1, 0x15, 0x39, 0x35, 0x25, 0x7c, 0x06, 0x03, 0x55, 0xdc, 0xe5, 0x95, 0x62, 0x77, 0x82, 0x74,
      0x3d, 0x14, 0x74, 0xe8, 0x13, 0xa1, 0xdb, 0x0a, 0xc9, 0xf9, 0x2d, 0xe9, 0x79, 0x28, 0x18, 0xd1,
      0x1a, 0x60, 0x02, 0x7d, 0xc1, 0xb6, 0x6b, 0xce, 0x32, 0xd2, 0x37, 0x7c, 0x03, 0xf1, 0x1b, 0xe8,
      0xae, 0x24, 0xdf, 0x08, 0x62, 0x7b, 0x28, 0x18, 0x4e, 0x8e, 0xf5, 0xc4, 0x58, 0xc9, 0xa2, 0x5c,
      0x2d, 0x8b, 0x52, 0xbd, 0x7f, 0xf7, 0x89, 0x09, 0x5a, 0x2b, 0x74, 0x93, 0x6f, 0xb9, 0xac, 0x0a,
      0x5e, 0x92, 0x81, 0xb9, 0x46, 0x03, 0xf5, 0xd0, 0xfc, 0xbb, 0x92, 0x8c, 0x40, 0x3d, 0xd4, 0x00,
      0x3f, 0x03, 0x4b, 0x7f, 0x36, 0x3e, 0x04, 0x98, 0xcd, 0x17, 0x11, 0x0d, 0x3f, 0x4e, 0x67, 0x73,
      0xa7, 0x85, 0x8f, 0xe1, 0x88, 0x46, 0x61, 0x34, 0xbb, 0x5e, 0xdc, 0xc4, 0xcb, 0x30, 0x8c, 0xe2,
      0xd8, 0x41, 0xcf, 0xc9, 0x0f, 0xd3, 0xd9, 0xe5, 0x92, 0x46, 0x4e, 0x1b, 0x8f, 0xc0, 0xa6, 0x57,
      0x97, 0x97, 0xe7, 0xd3, 0xf0, 0xc2, 0xe9, 0xe0, 0x13, 0x70, 0x1a, 0xc9, 0x9e, 0xb5, 0xfc, 0x09,
      0xd8, 0x21, 0x53, 0xf9, 0x8a, 0xcb, 0x2d, 0x1e, 0x42, 0x9f, 0x46, 0x9f, 0x97, 0x51, 0xbc, 0x70,
      0x5a, 0xc6, 0x1c, 0xc5, 0xd7, 0x57, 0xf3, 0x38, 0x72, 0x90, 0x2e, 0x2d, 0xe7, 0x17, 0xf3, 0xab,
      0x2f, 0x73, 0xa7, 0xed, 0x4f, 0xf7, 0xcf, 0xa1, 0x5f, 0x33, 0x2f, 0x53, 0xb9, 0x15, 0x2a, 0xcf,
      0xcc, 0xbe, 0x6c, 0xfa, 0x44, 0xe8, 0x2b, 0xa7, 0xbc, 0x54, 0x79, 0xa9, 0xcc, 0xe6, 0x46, 0xb4,
      0x81, 0xfe, 0x5f, 0xb4, 0x2f, 0xe1, 0x57, 0x70, 0x54, 0xc9, 0xf4, 0x46, 0x43, 0xc9, 0x52, 0x75,
      0x53, 0x64, 0xbb, 0xcd, 0x1f, 0x54, 0x32, 0x0d, 0x77, 0xec, 0x2c, 0xd3, 0xba, 0xac, 0x52, 0xff,
      0xe9, 0xea, 0x3c, 0x1c, 0x64, 0x95, 0x7a, 0xa6, 0xd3, 0xf1, 0xd9, 0x94, 0xa9, 0x49, 0x86, 0x8e,
      0xcf, 0xa6, 0x4c, 0x35, 0xc7, 0xe4, 0xaa, 0x22, 0x96, 0xd7, 0x09, 0x46, 0xd4, 0x9c, 0xf1, 0x29,
      0xd8, 0x29, 0x5b, 0xaf, 0x13, 0x96, 0x7e, 0x35, 0x41, 0x18, 0xd0, 0x3d, 0xc6, 0x2f, 0xa0, 0xa7,
      0x35, 0x61, 0x42, 0x7a, 0xc6, 0xb1, 0x43, 0xda, 0x23, 0xf9, 0xce, 0xd3, 0xaf, 0x3d, 0x0d, 0x6e,
      0x3c, 0x34, 0x21, 0xf6, 0x93, 0x87, 0x26, 0xfe, 0x6b, 0xe8, 0xea, 0x10, 0x56, 0xd8, 0x85, 0xae,
      0xce, 0x7f, 0x45, 0x90, 0xd7, 0x09, 0x86, 0x13, 0xbb, 0x89, 0x27, 0xad, 0x69, 0xff, 0x0c, 0x7a,
      0x32, 0xaf, 0x36, 0x6b, 0xa5, 0x3f, 0x37, 0x63, 0x8a, 0x19, 0xe1, 0x88, 0x9a, 0xf3, 0x39, 0xf9,
      0xf5, 0xe0, 0xa2, 0xfb, 0x07, 0x17, 0xfd, 0x79, 0x70, 0xd1, 0x8f, 0x47, 0xb7, 0x75, 0xff, 0xe8,
      0xb6, 0x7e, 0x3f, 0xba, 0xad, 0xa4, 0x67, 0xfe, 0x9f, 0xb7, 0xff, 0x02, 0x00, 0x00, 0xff, 0xff,
      0x95, 0x9e, 0xd1, 0xb1, 0x5e, 0x03, 0x00, 0x00,
      }
      func (m *IBTP) Marshal() (dAtA []byte, err error) {
      ......@@ -746,6 +757,38 @@ func (m *IBTPs) MarshalToSizedBuffer(dAtA []byte) (int, error) {
      return len(dAtA) - i, nil
      }
      func (m *Result) Marshal() (dAtA []byte, err error) {
      size := m.Size()
      dAtA = make([]byte, size)
      n, err := m.MarshalToSizedBuffer(dAtA[:size])
      if err != nil {
      return nil, err
      }
      return dAtA[:n], nil
      }
      func (m *Result) MarshalTo(dAtA []byte) (int, error) {
      size := m.Size()
      return m.MarshalToSizedBuffer(dAtA[:size])
      }
      func (m *Result) MarshalToSizedBuffer(dAtA []byte) (int, error) {
      i := len(dAtA)
      _ = i
      var l int
      _ = l
      if len(m.Data) > 0 {
      for iNdEx := len(m.Data) - 1; iNdEx >= 0; iNdEx-- {
      i -= len(m.Data[iNdEx])
      copy(dAtA[i:], m.Data[iNdEx])
      i = encodeVarintIbtp(dAtA, i, uint64(len(m.Data[iNdEx])))
      i--
      dAtA[i] = 0xa
      }
      }
      return len(dAtA) - i, nil
      }
      func encodeVarintIbtp(dAtA []byte, offset int, v uint64) int {
      offset -= sovIbtp(v)
      base := offset
      ......@@ -757,7 +800,6 @@ func encodeVarintIbtp(dAtA []byte, offset int, v uint64) int {
      dAtA[offset] = uint8(v)
      return base
      }
      func (m *IBTP) Size() (n int) {
      if m == nil {
      return 0
      ......@@ -882,14 +924,27 @@ func (m *IBTPs) Size() (n int) {
      return n
      }
      func (m *Result) Size() (n int) {
      if m == nil {
      return 0
      }
      var l int
      _ = l
      if len(m.Data) > 0 {
      for _, b := range m.Data {
      l = len(b)
      n += 1 + l + sovIbtp(uint64(l))
      }
      }
      return n
      }
      func sovIbtp(x uint64) (n int) {
      return (math_bits.Len64(x|1) + 6) / 7
      }
      func sozIbtp(x uint64) (n int) {
      return sovIbtp(uint64((x << 1) ^ uint64((int64(x) >> 63))))
      }
      func (m *IBTP) Unmarshal(dAtA []byte) error {
      l := len(dAtA)
      iNdEx := 0
      ......@@ -1231,7 +1286,6 @@ func (m *IBTP) Unmarshal(dAtA []byte) error {
      }
      return nil
      }
      func (m *Payload) Unmarshal(dAtA []byte) error {
      l := len(dAtA)
      iNdEx := 0
      ......@@ -1336,7 +1390,6 @@ func (m *Payload) Unmarshal(dAtA []byte) error {
      }
      return nil
      }
      func (m *Content) Unmarshal(dAtA []byte) error {
      l := len(dAtA)
      iNdEx := 0
      ......@@ -1643,7 +1696,6 @@ func (m *Content) Unmarshal(dAtA []byte) error {
      }
      return nil
      }
      func (m *IBTPs) Unmarshal(dAtA []byte) error {
      l := len(dAtA)
      iNdEx := 0
      ......@@ -1728,7 +1780,88 @@ func (m *IBTPs) Unmarshal(dAtA []byte) error {
      }
      return nil
      }
      func (m *Result) Unmarshal(dAtA []byte) error {
      l := len(dAtA)
      iNdEx := 0
      for iNdEx < l {
      preIndex := iNdEx
      var wire uint64
      for shift := uint(0); ; shift += 7 {
      if shift >= 64 {
      return ErrIntOverflowIbtp
      }
      if iNdEx >= l {
      return io.ErrUnexpectedEOF
      }
      b := dAtA[iNdEx]
      iNdEx++
      wire |= uint64(b&0x7F) << shift
      if b < 0x80 {
      break
      }
      }
      fieldNum := int32(wire >> 3)
      wireType := int(wire & 0x7)
      if wireType == 4 {
      return fmt.Errorf("proto: result: wiretype end group for non-group")
      }
      if fieldNum <= 0 {
      return fmt.Errorf("proto: result: illegal tag %d (wire type %d)", fieldNum, wire)
      }
      switch fieldNum {
      case 1:
      if wireType != 2 {
      return fmt.Errorf("proto: wrong wireType = %d for field Data", wireType)
      }
      var byteLen int
      for shift := uint(0); ; shift += 7 {
      if shift >= 64 {
      return ErrIntOverflowIbtp
      }
      if iNdEx >= l {
      return io.ErrUnexpectedEOF
      }
      b := dAtA[iNdEx]
      iNdEx++
      byteLen |= int(b&0x7F) << shift
      if b < 0x80 {
      break
      }
      }
      if byteLen < 0 {
      return ErrInvalidLengthIbtp
      }
      postIndex := iNdEx + byteLen
      if postIndex < 0 {
      return ErrInvalidLengthIbtp
      }
      if postIndex > l {
      return io.ErrUnexpectedEOF
      }
      m.Data = append(m.Data, make([]byte, postIndex-iNdEx))
      copy(m.Data[len(m.Data)-1], dAtA[iNdEx:postIndex])
      iNdEx = postIndex
      default:
      iNdEx = preIndex
      skippy, err := skipIbtp(dAtA[iNdEx:])
      if err != nil {
      return err
      }
      if (skippy < 0) || (iNdEx+skippy) < 0 {
      return ErrInvalidLengthIbtp
      }
      if (iNdEx + skippy) > l {
      return io.ErrUnexpectedEOF
      }
      iNdEx += skippy
      }
      }
      if iNdEx > l {
      return io.ErrUnexpectedEOF
      }
      return nil
      }
      func skipIbtp(dAtA []byte) (n int, err error) {
      l := len(dAtA)
      iNdEx := 0
      ......
      model/pb/ibtp.proto
      View file @ 71978d8d
      ......@@ -61,3 +61,7 @@ message content {
      message IBTPs {
      repeated IBTP ibtps = 1;
      }
      message result {
      repeated bytes data = 1;
      }
      model/pb/ibtpx.pb.go
      View file @ 71978d8d
      ......@@ -5,18 +5,15 @@ package pb
      import (
      fmt "fmt"
      proto "github.com/gogo/protobuf/proto"
      io "io"
      math "math"
      math_bits "math/bits"
      proto "github.com/gogo/protobuf/proto"
      )
      // Reference imports to suppress errors if they are not otherwise used.
      var _ = proto.Marshal
      var _ = fmt.Errorf
      var _ = math.Inf
      // This is a compile-time assertion to ensure that this generated file
      ......@@ -38,19 +35,14 @@ type IBTPX struct {
      }
      func (m *IBTPX) Reset() { *m = IBTPX{} }
      func (m *IBTPX) String() string { return proto.CompactTextString(m) }
      func (*IBTPX) ProtoMessage() {}
      func (*IBTPX) Descriptor() ([]byte, []int) {
      return fileDescriptor_8402d80e061d514a, []int{0}
      }
      func (m *IBTPX) XXX_Unmarshal(b []byte) error {
      return m.Unmarshal(b)
      }
      func (m *IBTPX) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
      if deterministic {
      return xxx_messageInfo_IBTPX.Marshal(b, m, deterministic)
      ......@@ -63,15 +55,12 @@ func (m *IBTPX) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
      return b[:n], nil
      }
      }
      func (m *IBTPX) XXX_Merge(src proto.Message) {
      xxx_messageInfo_IBTPX.Merge(m, src)
      }
      func (m *IBTPX) XXX_Size() int {
      return m.Size()
      }
      func (m *IBTPX) XXX_DiscardUnknown() {
      xxx_messageInfo_IBTPX.DiscardUnknown(m)
      }
      ......@@ -244,7 +233,6 @@ func encodeVarintIbtpx(dAtA []byte, offset int, v uint64) int {
      dAtA[offset] = uint8(v)
      return base
      }
      func (m *IBTPX) Size() (n int) {
      if m == nil {
      return 0
      ......@@ -287,11 +275,9 @@ func (m *IBTPX) Size() (n int) {
      func sovIbtpx(x uint64) (n int) {
      return (math_bits.Len64(x|1) + 6) / 7
      }
      func sozIbtpx(x uint64) (n int) {
      return sovIbtpx(uint64((x << 1) ^ uint64((int64(x) >> 63))))
      }
      func (m *IBTPX) Unmarshal(dAtA []byte) error {
      l := len(dAtA)
      iNdEx := 0
      ......@@ -545,7 +531,6 @@ func (m *IBTPX) Unmarshal(dAtA []byte) error {
      }
      return nil
      }
      func skipIbtpx(dAtA []byte) (n int, err error) {
      l := len(dAtA)
      iNdEx := 0
      ......
      model/pb/message.pb.go
      View file @ 71978d8d
      ......@@ -5,18 +5,15 @@ package pb
      import (
      fmt "fmt"
      proto "github.com/gogo/protobuf/proto"
      io "io"
      math "math"
      math_bits "math/bits"
      proto "github.com/gogo/protobuf/proto"
      )
      // Reference imports to suppress errors if they are not otherwise used.
      var _ = proto.Marshal
      var _ = fmt.Errorf
      var _ = math.Inf
      // This is a compile-time assertion to ensure that this generated file
      ......@@ -35,7 +32,7 @@ const (
      Message_APPCHAIN_GET Message_Type = 4
      Message_INTERCHAIN_META_GET Message_Type = 5
      Message_RULE_DEPLOY Message_Type = 6
      // 异步完成
      //异步完成
      Message_IBTP_GET Message_Type = 7
      Message_IBTP_SEND Message_Type = 8
      Message_IBTP_RECEIPT_SEND Message_Type = 9
      ......@@ -88,19 +85,14 @@ type Message struct {
      }
      func (m *Message) Reset() { *m = Message{} }
      func (m *Message) String() string { return proto.CompactTextString(m) }
      func (*Message) ProtoMessage() {}
      func (*Message) Descriptor() ([]byte, []int) {
      return fileDescriptor_33c57e4bae7b9afd, []int{0}
      }
      func (m *Message) XXX_Unmarshal(b []byte) error {
      return m.Unmarshal(b)
      }
      func (m *Message) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
      if deterministic {
      return xxx_messageInfo_Message.Marshal(b, m, deterministic)
      ......@@ -113,15 +105,12 @@ func (m *Message) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
      return b[:n], nil
      }
      }
      func (m *Message) XXX_Merge(src proto.Message) {
      xxx_messageInfo_Message.Merge(m, src)
      }
      func (m *Message) XXX_Size() int {
      return m.Size()
      }
      func (m *Message) XXX_DiscardUnknown() {
      xxx_messageInfo_Message.DiscardUnknown(m)
      }
      ......@@ -155,19 +144,14 @@ type Pack struct {
      }
      func (m *Pack) Reset() { *m = Pack{} }
      func (m *Pack) String() string { return proto.CompactTextString(m) }
      func (*Pack) ProtoMessage() {}
      func (*Pack) Descriptor() ([]byte, []int) {
      return fileDescriptor_33c57e4bae7b9afd, []int{1}
      }
      func (m *Pack) XXX_Unmarshal(b []byte) error {
      return m.Unmarshal(b)
      }
      func (m *Pack) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
      if deterministic {
      return xxx_messageInfo_Pack.Marshal(b, m, deterministic)
      ......@@ -180,15 +164,12 @@ func (m *Pack) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
      return b[:n], nil
      }
      }
      func (m *Pack) XXX_Merge(src proto.Message) {
      xxx_messageInfo_Pack.Merge(m, src)
      }
      func (m *Pack) XXX_Size() int {
      return m.Size()
      }
      func (m *Pack) XXX_DiscardUnknown() {
      xxx_messageInfo_Pack.DiscardUnknown(m)
      }
      ......@@ -215,19 +196,14 @@ type PeerInfo struct {
      }
      func (m *PeerInfo) Reset() { *m = PeerInfo{} }
      func (m *PeerInfo) String() string { return proto.CompactTextString(m) }
      func (*PeerInfo) ProtoMessage() {}
      func (*PeerInfo) Descriptor() ([]byte, []int) {
      return fileDescriptor_33c57e4bae7b9afd, []int{2}
      }
      func (m *PeerInfo) XXX_Unmarshal(b []byte) error {
      return m.Unmarshal(b)
      }
      func (m *PeerInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
      if deterministic {
      return xxx_messageInfo_PeerInfo.Marshal(b, m, deterministic)
      ......@@ -240,15 +216,12 @@ func (m *PeerInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
      return b[:n], nil
      }
      }
      func (m *PeerInfo) XXX_Merge(src proto.Message) {
      xxx_messageInfo_PeerInfo.Merge(m, src)
      }
      func (m *PeerInfo) XXX_Size() int {
      return m.Size()
      }
      func (m *PeerInfo) XXX_DiscardUnknown() {
      xxx_messageInfo_PeerInfo.DiscardUnknown(m)
      }
      ......@@ -441,7 +414,6 @@ func encodeVarintMessage(dAtA []byte, offset int, v uint64) int {
      dAtA[offset] = uint8(v)
      return base
      }
      func (m *Message) Size() (n int) {
      if m == nil {
      return 0
      ......@@ -498,11 +470,9 @@ func (m *PeerInfo) Size() (n int) {
      func sovMessage(x uint64) (n int) {
      return (math_bits.Len64(x|1) + 6) / 7
      }
      func sozMessage(x uint64) (n int) {
      return sovMessage(uint64((x << 1) ^ uint64((int64(x) >> 63))))
      }
      func (m *Message) Unmarshal(dAtA []byte) error {
      l := len(dAtA)
      iNdEx := 0
      ......@@ -640,7 +610,6 @@ func (m *Message) Unmarshal(dAtA []byte) error {
      }
      return nil
      }
      func (m *Pack) Unmarshal(dAtA []byte) error {
      l := len(dAtA)
      iNdEx := 0
      ......@@ -745,7 +714,6 @@ func (m *Pack) Unmarshal(dAtA []byte) error {
      }
      return nil
      }
      func (m *PeerInfo) Unmarshal(dAtA []byte) error {
      l := len(dAtA)
      iNdEx := 0
      ......@@ -860,7 +828,6 @@ func (m *PeerInfo) Unmarshal(dAtA []byte) error {
      }
      return nil
      }
      func skipMessage(dAtA []byte) (n int, err error) {
      l := len(dAtA)
      iNdEx := 0
      ......
      Markdown is supported
      0% or
      You are about to add 0 people to the discussion. Proceed with caution.
      Finish editing this message first!
      Please register or to comment