| // Code generated by protoc-gen-gogo. DO NOT EDIT. | |
| // source: overlay.proto | |
| package overlay | |
| import ( | |
| fmt "fmt" | |
| _ "github.com/gogo/protobuf/gogoproto" | |
| proto "github.com/gogo/protobuf/proto" | |
| io "io" | |
| math "math" | |
| math_bits "math/bits" | |
| reflect "reflect" | |
| strings "strings" | |
| ) | |
| // 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 | |
| // is compatible with the proto package it is being compiled against. | |
| // A compilation error at this line likely means your copy of the | |
| // proto package needs to be updated. | |
| const _ = proto.GoGoProtoPackageIsVersion3 // please upgrade the proto package | |
| // PeerRecord defines the information corresponding to a peer | |
| // container in the overlay network. | |
| type PeerRecord struct { | |
| // Endpoint IP is the IP of the container attachment on the | |
| // given overlay network. | |
| EndpointIP string `protobuf:"bytes,1,opt,name=endpoint_ip,json=endpointIp,proto3" json:"endpoint_ip,omitempty"` | |
| // Endpoint MAC is the mac address of the container attachment | |
| // on the given overlay network. | |
| EndpointMAC string `protobuf:"bytes,2,opt,name=endpoint_mac,json=endpointMac,proto3" json:"endpoint_mac,omitempty"` | |
| // Tunnel Endpoint IP defines the host IP for the host in | |
| // which this container is running and can be reached by | |
| // building a tunnel to that host IP. | |
| TunnelEndpointIP string `protobuf:"bytes,3,opt,name=tunnel_endpoint_ip,json=tunnelEndpointIp,proto3" json:"tunnel_endpoint_ip,omitempty"` | |
| } | |
| func (m *PeerRecord) Reset() { *m = PeerRecord{} } | |
| func (*PeerRecord) ProtoMessage() {} | |
| func (*PeerRecord) Descriptor() ([]byte, []int) { | |
| return fileDescriptor_61fc82527fbe24ad, []int{0} | |
| } | |
| func (m *PeerRecord) XXX_Unmarshal(b []byte) error { | |
| return m.Unmarshal(b) | |
| } | |
| func (m *PeerRecord) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { | |
| if deterministic { | |
| return xxx_messageInfo_PeerRecord.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 *PeerRecord) XXX_Merge(src proto.Message) { | |
| xxx_messageInfo_PeerRecord.Merge(m, src) | |
| } | |
| func (m *PeerRecord) XXX_Size() int { | |
| return m.Size() | |
| } | |
| func (m *PeerRecord) XXX_DiscardUnknown() { | |
| xxx_messageInfo_PeerRecord.DiscardUnknown(m) | |
| } | |
| var xxx_messageInfo_PeerRecord proto.InternalMessageInfo | |
| func (m *PeerRecord) GetEndpointIP() string { | |
| if m != nil { | |
| return m.EndpointIP | |
| } | |
| return "" | |
| } | |
| func (m *PeerRecord) GetEndpointMAC() string { | |
| if m != nil { | |
| return m.EndpointMAC | |
| } | |
| return "" | |
| } | |
| func (m *PeerRecord) GetTunnelEndpointIP() string { | |
| if m != nil { | |
| return m.TunnelEndpointIP | |
| } | |
| return "" | |
| } | |
| func init() { | |
| proto.RegisterType((*PeerRecord)(nil), "overlay.PeerRecord") | |
| } | |
| func init() { proto.RegisterFile("overlay.proto", fileDescriptor_61fc82527fbe24ad) } | |
| var fileDescriptor_61fc82527fbe24ad = []byte{ | |
| // 233 bytes of a gzipped FileDescriptorProto | |
| 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xe2, 0xe2, 0xcd, 0x2f, 0x4b, 0x2d, | |
| 0xca, 0x49, 0xac, 0xd4, 0x2b, 0x28, 0xca, 0x2f, 0xc9, 0x17, 0x62, 0x87, 0x72, 0xa5, 0x74, 0xd3, | |
| 0x33, 0x4b, 0x32, 0x4a, 0x93, 0xf4, 0x92, 0xf3, 0x73, 0xf5, 0xd3, 0xf3, 0xd3, 0xf3, 0xf5, 0xc1, | |
| 0xf2, 0x49, 0xa5, 0x69, 0x60, 0x1e, 0x98, 0x03, 0x66, 0x41, 0xf4, 0x29, 0x6d, 0x65, 0xe4, 0xe2, | |
| 0x0a, 0x48, 0x4d, 0x2d, 0x0a, 0x4a, 0x4d, 0xce, 0x2f, 0x4a, 0x11, 0xd2, 0xe7, 0xe2, 0x4e, 0xcd, | |
| 0x4b, 0x29, 0xc8, 0xcf, 0xcc, 0x2b, 0x89, 0xcf, 0x2c, 0x90, 0x60, 0x54, 0x60, 0xd4, 0xe0, 0x74, | |
| 0xe2, 0x7b, 0x74, 0x4f, 0x9e, 0xcb, 0x15, 0x2a, 0xec, 0x19, 0x10, 0xc4, 0x05, 0x53, 0xe2, 0x59, | |
| 0x20, 0x64, 0xc4, 0xc5, 0x03, 0xd7, 0x90, 0x9b, 0x98, 0x2c, 0xc1, 0x04, 0xd6, 0xc1, 0xff, 0xe8, | |
| 0x9e, 0x3c, 0x37, 0x4c, 0x87, 0xaf, 0xa3, 0x73, 0x10, 0xdc, 0x54, 0xdf, 0xc4, 0x64, 0x21, 0x27, | |
| 0x2e, 0xa1, 0x92, 0xd2, 0xbc, 0xbc, 0xd4, 0x9c, 0x78, 0x64, 0xbb, 0x98, 0xc1, 0x3a, 0x45, 0x1e, | |
| 0xdd, 0x93, 0x17, 0x08, 0x01, 0xcb, 0x22, 0xd9, 0x28, 0x50, 0x82, 0x2a, 0x52, 0xe0, 0xa4, 0x72, | |
| 0xe3, 0xa1, 0x1c, 0xc3, 0x87, 0x87, 0x72, 0x8c, 0x0d, 0x8f, 0xe4, 0x18, 0x4f, 0x3c, 0x92, 0x63, | |
| 0xbc, 0xf0, 0x48, 0x8e, 0xf1, 0xc1, 0x23, 0x39, 0xc6, 0x09, 0x8f, 0xe5, 0x18, 0x2e, 0x3c, 0x96, | |
| 0x63, 0xb8, 0xf1, 0x58, 0x8e, 0x21, 0x89, 0x0d, 0xec, 0x49, 0x63, 0x40, 0x00, 0x00, 0x00, 0xff, | |
| 0xff, 0xd4, 0x37, 0x59, 0xc8, 0x2d, 0x01, 0x00, 0x00, | |
| } | |
| func (this *PeerRecord) GoString() string { | |
| if this == nil { | |
| return "nil" | |
| } | |
| s := make([]string, 0, 7) | |
| s = append(s, "&overlay.PeerRecord{") | |
| s = append(s, "EndpointIP: "+fmt.Sprintf("%#v", this.EndpointIP)+",\n") | |
| s = append(s, "EndpointMAC: "+fmt.Sprintf("%#v", this.EndpointMAC)+",\n") | |
| s = append(s, "TunnelEndpointIP: "+fmt.Sprintf("%#v", this.TunnelEndpointIP)+",\n") | |
| s = append(s, "}") | |
| return strings.Join(s, "") | |
| } | |
| func valueToGoStringOverlay(v interface{}, typ string) string { | |
| rv := reflect.ValueOf(v) | |
| if rv.IsNil() { | |
| return "nil" | |
| } | |
| pv := reflect.Indirect(rv).Interface() | |
| return fmt.Sprintf("func(v %v) *%v { return &v } ( %#v )", typ, typ, pv) | |
| } | |
| func (m *PeerRecord) 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 *PeerRecord) MarshalTo(dAtA []byte) (int, error) { | |
| size := m.Size() | |
| return m.MarshalToSizedBuffer(dAtA[:size]) | |
| } | |
| func (m *PeerRecord) MarshalToSizedBuffer(dAtA []byte) (int, error) { | |
| i := len(dAtA) | |
| _ = i | |
| var l int | |
| _ = l | |
| if len(m.TunnelEndpointIP) > 0 { | |
| i -= len(m.TunnelEndpointIP) | |
| copy(dAtA[i:], m.TunnelEndpointIP) | |
| i = encodeVarintOverlay(dAtA, i, uint64(len(m.TunnelEndpointIP))) | |
| i-- | |
| dAtA[i] = 0x1a | |
| } | |
| if len(m.EndpointMAC) > 0 { | |
| i -= len(m.EndpointMAC) | |
| copy(dAtA[i:], m.EndpointMAC) | |
| i = encodeVarintOverlay(dAtA, i, uint64(len(m.EndpointMAC))) | |
| i-- | |
| dAtA[i] = 0x12 | |
| } | |
| if len(m.EndpointIP) > 0 { | |
| i -= len(m.EndpointIP) | |
| copy(dAtA[i:], m.EndpointIP) | |
| i = encodeVarintOverlay(dAtA, i, uint64(len(m.EndpointIP))) | |
| i-- | |
| dAtA[i] = 0xa | |
| } | |
| return len(dAtA) - i, nil | |
| } | |
| func encodeVarintOverlay(dAtA []byte, offset int, v uint64) int { | |
| offset -= sovOverlay(v) | |
| base := offset | |
| for v >= 1<<7 { | |
| dAtA[offset] = uint8(v&0x7f | 0x80) | |
| v >>= 7 | |
| offset++ | |
| } | |
| dAtA[offset] = uint8(v) | |
| return base | |
| } | |
| func (m *PeerRecord) Size() (n int) { | |
| if m == nil { | |
| return 0 | |
| } | |
| var l int | |
| _ = l | |
| l = len(m.EndpointIP) | |
| if l > 0 { | |
| n += 1 + l + sovOverlay(uint64(l)) | |
| } | |
| l = len(m.EndpointMAC) | |
| if l > 0 { | |
| n += 1 + l + sovOverlay(uint64(l)) | |
| } | |
| l = len(m.TunnelEndpointIP) | |
| if l > 0 { | |
| n += 1 + l + sovOverlay(uint64(l)) | |
| } | |
| return n | |
| } | |
| func sovOverlay(x uint64) (n int) { | |
| return (math_bits.Len64(x|1) + 6) / 7 | |
| } | |
| func sozOverlay(x uint64) (n int) { | |
| return sovOverlay(uint64((x << 1) ^ uint64((int64(x) >> 63)))) | |
| } | |
| func (this *PeerRecord) String() string { | |
| if this == nil { | |
| return "nil" | |
| } | |
| s := strings.Join([]string{`&PeerRecord{`, | |
| `EndpointIP:` + fmt.Sprintf("%v", this.EndpointIP) + `,`, | |
| `EndpointMAC:` + fmt.Sprintf("%v", this.EndpointMAC) + `,`, | |
| `TunnelEndpointIP:` + fmt.Sprintf("%v", this.TunnelEndpointIP) + `,`, | |
| `}`, | |
| }, "") | |
| return s | |
| } | |
| func valueToStringOverlay(v interface{}) string { | |
| rv := reflect.ValueOf(v) | |
| if rv.IsNil() { | |
| return "nil" | |
| } | |
| pv := reflect.Indirect(rv).Interface() | |
| return fmt.Sprintf("*%v", pv) | |
| } | |
| func (m *PeerRecord) 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 ErrIntOverflowOverlay | |
| } | |
| 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: PeerRecord: wiretype end group for non-group") | |
| } | |
| if fieldNum <= 0 { | |
| return fmt.Errorf("proto: PeerRecord: illegal tag %d (wire type %d)", fieldNum, wire) | |
| } | |
| switch fieldNum { | |
| case 1: | |
| if wireType != 2 { | |
| return fmt.Errorf("proto: wrong wireType = %d for field EndpointIP", wireType) | |
| } | |
| var stringLen uint64 | |
| for shift := uint(0); ; shift += 7 { | |
| if shift >= 64 { | |
| return ErrIntOverflowOverlay | |
| } | |
| if iNdEx >= l { | |
| return io.ErrUnexpectedEOF | |
| } | |
| b := dAtA[iNdEx] | |
| iNdEx++ | |
| stringLen |= uint64(b&0x7F) << shift | |
| if b < 0x80 { | |
| break | |
| } | |
| } | |
| intStringLen := int(stringLen) | |
| if intStringLen < 0 { | |
| return ErrInvalidLengthOverlay | |
| } | |
| postIndex := iNdEx + intStringLen | |
| if postIndex < 0 { | |
| return ErrInvalidLengthOverlay | |
| } | |
| if postIndex > l { | |
| return io.ErrUnexpectedEOF | |
| } | |
| m.EndpointIP = string(dAtA[iNdEx:postIndex]) | |
| iNdEx = postIndex | |
| case 2: | |
| if wireType != 2 { | |
| return fmt.Errorf("proto: wrong wireType = %d for field EndpointMAC", wireType) | |
| } | |
| var stringLen uint64 | |
| for shift := uint(0); ; shift += 7 { | |
| if shift >= 64 { | |
| return ErrIntOverflowOverlay | |
| } | |
| if iNdEx >= l { | |
| return io.ErrUnexpectedEOF | |
| } | |
| b := dAtA[iNdEx] | |
| iNdEx++ | |
| stringLen |= uint64(b&0x7F) << shift | |
| if b < 0x80 { | |
| break | |
| } | |
| } | |
| intStringLen := int(stringLen) | |
| if intStringLen < 0 { | |
| return ErrInvalidLengthOverlay | |
| } | |
| postIndex := iNdEx + intStringLen | |
| if postIndex < 0 { | |
| return ErrInvalidLengthOverlay | |
| } | |
| if postIndex > l { | |
| return io.ErrUnexpectedEOF | |
| } | |
| m.EndpointMAC = string(dAtA[iNdEx:postIndex]) | |
| iNdEx = postIndex | |
| case 3: | |
| if wireType != 2 { | |
| return fmt.Errorf("proto: wrong wireType = %d for field TunnelEndpointIP", wireType) | |
| } | |
| var stringLen uint64 | |
| for shift := uint(0); ; shift += 7 { | |
| if shift >= 64 { | |
| return ErrIntOverflowOverlay | |
| } | |
| if iNdEx >= l { | |
| return io.ErrUnexpectedEOF | |
| } | |
| b := dAtA[iNdEx] | |
| iNdEx++ | |
| stringLen |= uint64(b&0x7F) << shift | |
| if b < 0x80 { | |
| break | |
| } | |
| } | |
| intStringLen := int(stringLen) | |
| if intStringLen < 0 { | |
| return ErrInvalidLengthOverlay | |
| } | |
| postIndex := iNdEx + intStringLen | |
| if postIndex < 0 { | |
| return ErrInvalidLengthOverlay | |
| } | |
| if postIndex > l { | |
| return io.ErrUnexpectedEOF | |
| } | |
| m.TunnelEndpointIP = string(dAtA[iNdEx:postIndex]) | |
| iNdEx = postIndex | |
| default: | |
| iNdEx = preIndex | |
| skippy, err := skipOverlay(dAtA[iNdEx:]) | |
| if err != nil { | |
| return err | |
| } | |
| if (skippy < 0) || (iNdEx+skippy) < 0 { | |
| return ErrInvalidLengthOverlay | |
| } | |
| if (iNdEx + skippy) > l { | |
| return io.ErrUnexpectedEOF | |
| } | |
| iNdEx += skippy | |
| } | |
| } | |
| if iNdEx > l { | |
| return io.ErrUnexpectedEOF | |
| } | |
| return nil | |
| } | |
| func skipOverlay(dAtA []byte) (n int, err error) { | |
| l := len(dAtA) | |
| iNdEx := 0 | |
| depth := 0 | |
| for iNdEx < l { | |
| var wire uint64 | |
| for shift := uint(0); ; shift += 7 { | |
| if shift >= 64 { | |
| return 0, ErrIntOverflowOverlay | |
| } | |
| if iNdEx >= l { | |
| return 0, io.ErrUnexpectedEOF | |
| } | |
| b := dAtA[iNdEx] | |
| iNdEx++ | |
| wire |= (uint64(b) & 0x7F) << shift | |
| if b < 0x80 { | |
| break | |
| } | |
| } | |
| wireType := int(wire & 0x7) | |
| switch wireType { | |
| case 0: | |
| for shift := uint(0); ; shift += 7 { | |
| if shift >= 64 { | |
| return 0, ErrIntOverflowOverlay | |
| } | |
| if iNdEx >= l { | |
| return 0, io.ErrUnexpectedEOF | |
| } | |
| iNdEx++ | |
| if dAtA[iNdEx-1] < 0x80 { | |
| break | |
| } | |
| } | |
| case 1: | |
| iNdEx += 8 | |
| case 2: | |
| var length int | |
| for shift := uint(0); ; shift += 7 { | |
| if shift >= 64 { | |
| return 0, ErrIntOverflowOverlay | |
| } | |
| if iNdEx >= l { | |
| return 0, io.ErrUnexpectedEOF | |
| } | |
| b := dAtA[iNdEx] | |
| iNdEx++ | |
| length |= (int(b) & 0x7F) << shift | |
| if b < 0x80 { | |
| break | |
| } | |
| } | |
| if length < 0 { | |
| return 0, ErrInvalidLengthOverlay | |
| } | |
| iNdEx += length | |
| case 3: | |
| depth++ | |
| case 4: | |
| if depth == 0 { | |
| return 0, ErrUnexpectedEndOfGroupOverlay | |
| } | |
| depth-- | |
| case 5: | |
| iNdEx += 4 | |
| default: | |
| return 0, fmt.Errorf("proto: illegal wireType %d", wireType) | |
| } | |
| if iNdEx < 0 { | |
| return 0, ErrInvalidLengthOverlay | |
| } | |
| if depth == 0 { | |
| return iNdEx, nil | |
| } | |
| } | |
| return 0, io.ErrUnexpectedEOF | |
| } | |
| var ( | |
| ErrInvalidLengthOverlay = fmt.Errorf("proto: negative length found during unmarshaling") | |
| ErrIntOverflowOverlay = fmt.Errorf("proto: integer overflow") | |
| ErrUnexpectedEndOfGroupOverlay = fmt.Errorf("proto: unexpected end of group") | |
| ) |