proto

package
v0.0.0-...-f8c89ea Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 29, 2019 License: MIT Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterPeerServer 

func RegisterPeerServer(s *grpc.Server, srv PeerServer)

func RegisterProxyServer 

func RegisterProxyServer(s *grpc.Server, srv ProxyServer)

func RegisterTabletServer 

func RegisterTabletServer(s *grpc.Server, srv TabletServer)

Types

type Empty 

type Empty struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Empty) Descriptor 

func (*Empty) Descriptor() ([]byte, []int)

func (*Empty) ProtoMessage 

func (*Empty) ProtoMessage()

func (*Empty) Reset 

func (m *Empty) Reset()

func (*Empty) String 

func (m *Empty) String() string

func (*Empty) XXX_DiscardUnknown 

func (m *Empty) XXX_DiscardUnknown()

func (*Empty) XXX_Marshal 

func (m *Empty) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Empty) XXX_Merge 

func (dst *Empty) XXX_Merge(src proto.Message)

func (*Empty) XXX_Size 

func (m *Empty) XXX_Size() int

func (*Empty) XXX_Unmarshal 

func (m *Empty) XXX_Unmarshal(b []byte) error

type ExchangeEntriesNotification 

type ExchangeEntriesNotification struct {
	Destinations         []*ProxyEntry `protobuf:"bytes,1,rep,name=destinations" json:"destinations,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*ExchangeEntriesNotification) Descriptor 

func (*ExchangeEntriesNotification) Descriptor() ([]byte, []int)

func (*ExchangeEntriesNotification) GetDestinations 

func (m *ExchangeEntriesNotification) GetDestinations() []*ProxyEntry

func (*ExchangeEntriesNotification) ProtoMessage 

func (*ExchangeEntriesNotification) ProtoMessage()

func (*ExchangeEntriesNotification) Reset 

func (m *ExchangeEntriesNotification) Reset()

func (*ExchangeEntriesNotification) String 

func (m *ExchangeEntriesNotification) String() string

func (*ExchangeEntriesNotification) XXX_DiscardUnknown 

func (m *ExchangeEntriesNotification) XXX_DiscardUnknown()

func (*ExchangeEntriesNotification) XXX_Marshal 

func (m *ExchangeEntriesNotification) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExchangeEntriesNotification) XXX_Merge 

func (dst *ExchangeEntriesNotification) XXX_Merge(src proto.Message)

func (*ExchangeEntriesNotification) XXX_Size 

func (m *ExchangeEntriesNotification) XXX_Size() int

func (*ExchangeEntriesNotification) XXX_Unmarshal 

func (m *ExchangeEntriesNotification) XXX_Unmarshal(b []byte) error

type ExchangeEntriesRequest 

type ExchangeEntriesRequest struct {
	Entries              []*PeerEntry `protobuf:"bytes,1,rep,name=entries" json:"entries,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*ExchangeEntriesRequest) Descriptor 

func (*ExchangeEntriesRequest) Descriptor() ([]byte, []int)

func (*ExchangeEntriesRequest) GetEntries 

func (m *ExchangeEntriesRequest) GetEntries() []*PeerEntry

func (*ExchangeEntriesRequest) ProtoMessage 

func (*ExchangeEntriesRequest) ProtoMessage()

func (*ExchangeEntriesRequest) Reset 

func (m *ExchangeEntriesRequest) Reset()

func (*ExchangeEntriesRequest) String 

func (m *ExchangeEntriesRequest) String() string

func (*ExchangeEntriesRequest) XXX_DiscardUnknown 

func (m *ExchangeEntriesRequest) XXX_DiscardUnknown()

func (*ExchangeEntriesRequest) XXX_Marshal 

func (m *ExchangeEntriesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExchangeEntriesRequest) XXX_Merge 

func (dst *ExchangeEntriesRequest) XXX_Merge(src proto.Message)

func (*ExchangeEntriesRequest) XXX_Size 

func (m *ExchangeEntriesRequest) XXX_Size() int

func (*ExchangeEntriesRequest) XXX_Unmarshal 

func (m *ExchangeEntriesRequest) XXX_Unmarshal(b []byte) error

type ExchangeEntriesResponse 

type ExchangeEntriesResponse struct {
	Entries              []*PeerEntry `protobuf:"bytes,1,rep,name=entries" json:"entries,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*ExchangeEntriesResponse) Descriptor 

func (*ExchangeEntriesResponse) Descriptor() ([]byte, []int)

func (*ExchangeEntriesResponse) GetEntries 

func (m *ExchangeEntriesResponse) GetEntries() []*PeerEntry

func (*ExchangeEntriesResponse) ProtoMessage 

func (*ExchangeEntriesResponse) ProtoMessage()

func (*ExchangeEntriesResponse) Reset 

func (m *ExchangeEntriesResponse) Reset()

func (*ExchangeEntriesResponse) String 

func (m *ExchangeEntriesResponse) String() string

func (*ExchangeEntriesResponse) XXX_DiscardUnknown 

func (m *ExchangeEntriesResponse) XXX_DiscardUnknown()

func (*ExchangeEntriesResponse) XXX_Marshal 

func (m *ExchangeEntriesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExchangeEntriesResponse) XXX_Merge 

func (dst *ExchangeEntriesResponse) XXX_Merge(src proto.Message)

func (*ExchangeEntriesResponse) XXX_Size 

func (m *ExchangeEntriesResponse) XXX_Size() int

func (*ExchangeEntriesResponse) XXX_Unmarshal 

func (m *ExchangeEntriesResponse) XXX_Unmarshal(b []byte) error

type FetchPeersRequest 

type FetchPeersRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FetchPeersRequest) Descriptor 

func (*FetchPeersRequest) Descriptor() ([]byte, []int)

func (*FetchPeersRequest) ProtoMessage 

func (*FetchPeersRequest) ProtoMessage()

func (*FetchPeersRequest) Reset 

func (m *FetchPeersRequest) Reset()

func (*FetchPeersRequest) String 

func (m *FetchPeersRequest) String() string

func (*FetchPeersRequest) XXX_DiscardUnknown 

func (m *FetchPeersRequest) XXX_DiscardUnknown()

func (*FetchPeersRequest) XXX_Marshal 

func (m *FetchPeersRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FetchPeersRequest) XXX_Merge 

func (dst *FetchPeersRequest) XXX_Merge(src proto.Message)

func (*FetchPeersRequest) XXX_Size 

func (m *FetchPeersRequest) XXX_Size() int

func (*FetchPeersRequest) XXX_Unmarshal 

func (m *FetchPeersRequest) XXX_Unmarshal(b []byte) error

type FetchPeersResponse 

type FetchPeersResponse struct {
	Entries              []*PeerEntry `protobuf:"bytes,1,rep,name=entries" json:"entries,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*FetchPeersResponse) Descriptor 

func (*FetchPeersResponse) Descriptor() ([]byte, []int)

func (*FetchPeersResponse) GetEntries 

func (m *FetchPeersResponse) GetEntries() []*PeerEntry

func (*FetchPeersResponse) ProtoMessage 

func (*FetchPeersResponse) ProtoMessage()

func (*FetchPeersResponse) Reset 

func (m *FetchPeersResponse) Reset()

func (*FetchPeersResponse) String 

func (m *FetchPeersResponse) String() string

func (*FetchPeersResponse) XXX_DiscardUnknown 

func (m *FetchPeersResponse) XXX_DiscardUnknown()

func (*FetchPeersResponse) XXX_Marshal 

func (m *FetchPeersResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FetchPeersResponse) XXX_Merge 

func (dst *FetchPeersResponse) XXX_Merge(src proto.Message)

func (*FetchPeersResponse) XXX_Size 

func (m *FetchPeersResponse) XXX_Size() int

func (*FetchPeersResponse) XXX_Unmarshal 

func (m *FetchPeersResponse) XXX_Unmarshal(b []byte) error

type GeneratePeerIDRequest 

type GeneratePeerIDRequest struct {
	Seed                 string   `protobuf:"bytes,1,opt,name=seed" json:"seed,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GeneratePeerIDRequest) Descriptor 

func (*GeneratePeerIDRequest) Descriptor() ([]byte, []int)

func (*GeneratePeerIDRequest) GetSeed 

func (m *GeneratePeerIDRequest) GetSeed() string

func (*GeneratePeerIDRequest) ProtoMessage 

func (*GeneratePeerIDRequest) ProtoMessage()

func (*GeneratePeerIDRequest) Reset 

func (m *GeneratePeerIDRequest) Reset()

func (*GeneratePeerIDRequest) String 

func (m *GeneratePeerIDRequest) String() string

func (*GeneratePeerIDRequest) XXX_DiscardUnknown 

func (m *GeneratePeerIDRequest) XXX_DiscardUnknown()

func (*GeneratePeerIDRequest) XXX_Marshal 

func (m *GeneratePeerIDRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GeneratePeerIDRequest) XXX_Merge 

func (dst *GeneratePeerIDRequest) XXX_Merge(src proto.Message)

func (*GeneratePeerIDRequest) XXX_Size 

func (m *GeneratePeerIDRequest) XXX_Size() int

func (*GeneratePeerIDRequest) XXX_Unmarshal 

func (m *GeneratePeerIDRequest) XXX_Unmarshal(b []byte) error

type GeneratePeerIDResponse 

type GeneratePeerIDResponse struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GeneratePeerIDResponse) Descriptor 

func (*GeneratePeerIDResponse) Descriptor() ([]byte, []int)

func (*GeneratePeerIDResponse) GetId 

func (m *GeneratePeerIDResponse) GetId() string

func (*GeneratePeerIDResponse) ProtoMessage 

func (*GeneratePeerIDResponse) ProtoMessage()

func (*GeneratePeerIDResponse) Reset 

func (m *GeneratePeerIDResponse) Reset()

func (*GeneratePeerIDResponse) String 

func (m *GeneratePeerIDResponse) String() string

func (*GeneratePeerIDResponse) XXX_DiscardUnknown 

func (m *GeneratePeerIDResponse) XXX_DiscardUnknown()

func (*GeneratePeerIDResponse) XXX_Marshal 

func (m *GeneratePeerIDResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GeneratePeerIDResponse) XXX_Merge 

func (dst *GeneratePeerIDResponse) XXX_Merge(src proto.Message)

func (*GeneratePeerIDResponse) XXX_Size 

func (m *GeneratePeerIDResponse) XXX_Size() int

func (*GeneratePeerIDResponse) XXX_Unmarshal 

func (m *GeneratePeerIDResponse) XXX_Unmarshal(b []byte) error

type GetPeerIDResponse 

type GetPeerIDResponse struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetPeerIDResponse) Descriptor 

func (*GetPeerIDResponse) Descriptor() ([]byte, []int)

func (*GetPeerIDResponse) GetId 

func (m *GetPeerIDResponse) GetId() string

func (*GetPeerIDResponse) ProtoMessage 

func (*GetPeerIDResponse) ProtoMessage()

func (*GetPeerIDResponse) Reset 

func (m *GetPeerIDResponse) Reset()

func (*GetPeerIDResponse) String 

func (m *GetPeerIDResponse) String() string

func (*GetPeerIDResponse) XXX_DiscardUnknown 

func (m *GetPeerIDResponse) XXX_DiscardUnknown()

func (*GetPeerIDResponse) XXX_Marshal 

func (m *GetPeerIDResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetPeerIDResponse) XXX_Merge 

func (dst *GetPeerIDResponse) XXX_Merge(src proto.Message)

func (*GetPeerIDResponse) XXX_Size 

func (m *GetPeerIDResponse) XXX_Size() int

func (*GetPeerIDResponse) XXX_Unmarshal 

func (m *GetPeerIDResponse) XXX_Unmarshal(b []byte) error

type LookUpPeerRequest 

type LookUpPeerRequest struct {
	Latitude             float32  `protobuf:"fixed32,1,opt,name=latitude" json:"latitude,omitempty"`
	Longitude            float32  `protobuf:"fixed32,2,opt,name=longitude" json:"longitude,omitempty"`
	Distance             float32  `protobuf:"fixed32,3,opt,name=distance" json:"distance,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*LookUpPeerRequest) Descriptor 

func (*LookUpPeerRequest) Descriptor() ([]byte, []int)

func (*LookUpPeerRequest) GetDistance 

func (m *LookUpPeerRequest) GetDistance() float32

func (*LookUpPeerRequest) GetLatitude 

func (m *LookUpPeerRequest) GetLatitude() float32

func (*LookUpPeerRequest) GetLongitude 

func (m *LookUpPeerRequest) GetLongitude() float32

func (*LookUpPeerRequest) ProtoMessage 

func (*LookUpPeerRequest) ProtoMessage()

func (*LookUpPeerRequest) Reset 

func (m *LookUpPeerRequest) Reset()

func (*LookUpPeerRequest) String 

func (m *LookUpPeerRequest) String() string

func (*LookUpPeerRequest) XXX_DiscardUnknown 

func (m *LookUpPeerRequest) XXX_DiscardUnknown()

func (*LookUpPeerRequest) XXX_Marshal 

func (m *LookUpPeerRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LookUpPeerRequest) XXX_Merge 

func (dst *LookUpPeerRequest) XXX_Merge(src proto.Message)

func (*LookUpPeerRequest) XXX_Size 

func (m *LookUpPeerRequest) XXX_Size() int

func (*LookUpPeerRequest) XXX_Unmarshal 

func (m *LookUpPeerRequest) XXX_Unmarshal(b []byte) error

type LookUpPeerResponse 

type LookUpPeerResponse struct {
	Entries              []*PeerEntry `protobuf:"bytes,1,rep,name=entries" json:"entries,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*LookUpPeerResponse) Descriptor 

func (*LookUpPeerResponse) Descriptor() ([]byte, []int)

func (*LookUpPeerResponse) GetEntries 

func (m *LookUpPeerResponse) GetEntries() []*PeerEntry

func (*LookUpPeerResponse) ProtoMessage 

func (*LookUpPeerResponse) ProtoMessage()

func (*LookUpPeerResponse) Reset 

func (m *LookUpPeerResponse) Reset()

func (*LookUpPeerResponse) String 

func (m *LookUpPeerResponse) String() string

func (*LookUpPeerResponse) XXX_DiscardUnknown 

func (m *LookUpPeerResponse) XXX_DiscardUnknown()

func (*LookUpPeerResponse) XXX_Marshal 

func (m *LookUpPeerResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LookUpPeerResponse) XXX_Merge 

func (dst *LookUpPeerResponse) XXX_Merge(src proto.Message)

func (*LookUpPeerResponse) XXX_Size 

func (m *LookUpPeerResponse) XXX_Size() int

func (*LookUpPeerResponse) XXX_Unmarshal 

func (m *LookUpPeerResponse) XXX_Unmarshal(b []byte) error

type LookUpRequest 

type LookUpRequest struct {
	Id                   uint32   `protobuf:"varint,1,opt,name=id" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*LookUpRequest) Descriptor 

func (*LookUpRequest) Descriptor() ([]byte, []int)

func (*LookUpRequest) GetId 

func (m *LookUpRequest) GetId() uint32

func (*LookUpRequest) ProtoMessage 

func (*LookUpRequest) ProtoMessage()

func (*LookUpRequest) Reset 

func (m *LookUpRequest) Reset()

func (*LookUpRequest) String 

func (m *LookUpRequest) String() string

func (*LookUpRequest) XXX_DiscardUnknown 

func (m *LookUpRequest) XXX_DiscardUnknown()

func (*LookUpRequest) XXX_Marshal 

func (m *LookUpRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LookUpRequest) XXX_Merge 

func (dst *LookUpRequest) XXX_Merge(src proto.Message)

func (*LookUpRequest) XXX_Size 

func (m *LookUpRequest) XXX_Size() int

func (*LookUpRequest) XXX_Unmarshal 

func (m *LookUpRequest) XXX_Unmarshal(b []byte) error

type NoticeFromProxyRequest 

type NoticeFromProxyRequest struct {
	Id                   uint32   `protobuf:"varint,5,opt,name=id" json:"id,omitempty"`
	GrpcPort             string   `protobuf:"bytes,1,opt,name=grpc_port,json=grpcPort" json:"grpc_port,omitempty"`
	TcpPort              string   `protobuf:"bytes,2,opt,name=tcp_port,json=tcpPort" json:"tcp_port,omitempty"`
	UdpPort              string   `protobuf:"bytes,3,opt,name=udp_port,json=udpPort" json:"udp_port,omitempty"`
	Addr                 string   `protobuf:"bytes,4,opt,name=addr" json:"addr,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NoticeFromProxyRequest) Descriptor 

func (*NoticeFromProxyRequest) Descriptor() ([]byte, []int)

func (*NoticeFromProxyRequest) GetAddr 

func (m *NoticeFromProxyRequest) GetAddr() string

func (*NoticeFromProxyRequest) GetGrpcPort 

func (m *NoticeFromProxyRequest) GetGrpcPort() string

func (*NoticeFromProxyRequest) GetId 

func (m *NoticeFromProxyRequest) GetId() uint32

func (*NoticeFromProxyRequest) GetTcpPort 

func (m *NoticeFromProxyRequest) GetTcpPort() string

func (*NoticeFromProxyRequest) GetUdpPort 

func (m *NoticeFromProxyRequest) GetUdpPort() string

func (*NoticeFromProxyRequest) ProtoMessage 

func (*NoticeFromProxyRequest) ProtoMessage()

func (*NoticeFromProxyRequest) Reset 

func (m *NoticeFromProxyRequest) Reset()

func (*NoticeFromProxyRequest) String 

func (m *NoticeFromProxyRequest) String() string

func (*NoticeFromProxyRequest) XXX_DiscardUnknown 

func (m *NoticeFromProxyRequest) XXX_DiscardUnknown()

func (*NoticeFromProxyRequest) XXX_Marshal 

func (m *NoticeFromProxyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NoticeFromProxyRequest) XXX_Merge 

func (dst *NoticeFromProxyRequest) XXX_Merge(src proto.Message)

func (*NoticeFromProxyRequest) XXX_Size 

func (m *NoticeFromProxyRequest) XXX_Size() int

func (*NoticeFromProxyRequest) XXX_Unmarshal 

func (m *NoticeFromProxyRequest) XXX_Unmarshal(b []byte) error

type PeerClient 

type PeerClient interface {
	NoticeFromProxyRPC(ctx context.Context, in *NoticeFromProxyRequest, opts ...grpc.CallOption) (*Empty, error)
}

PeerClient is the client API for Peer service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewPeerClient 

func NewPeerClient(cc *grpc.ClientConn) PeerClient

type PeerEntry 

type PeerEntry struct {
	PeerId               string   `protobuf:"bytes,1,opt,name=peer_id,json=peerId" json:"peer_id,omitempty"`
	ProxyIp              string   `protobuf:"bytes,2,opt,name=proxy_ip,json=proxyIp" json:"proxy_ip,omitempty"`
	Latitude             float32  `protobuf:"fixed32,4,opt,name=latitude" json:"latitude,omitempty"`
	Longitude            float32  `protobuf:"fixed32,5,opt,name=longitude" json:"longitude,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PeerEntry) Descriptor 

func (*PeerEntry) Descriptor() ([]byte, []int)

func (*PeerEntry) GetLatitude 

func (m *PeerEntry) GetLatitude() float32

func (*PeerEntry) GetLongitude 

func (m *PeerEntry) GetLongitude() float32

func (*PeerEntry) GetPeerId 

func (m *PeerEntry) GetPeerId() string

func (*PeerEntry) GetProxyIp 

func (m *PeerEntry) GetProxyIp() string

func (*PeerEntry) ProtoMessage 

func (*PeerEntry) ProtoMessage()

func (*PeerEntry) Reset 

func (m *PeerEntry) Reset()

func (*PeerEntry) String 

func (m *PeerEntry) String() string

func (*PeerEntry) XXX_DiscardUnknown 

func (m *PeerEntry) XXX_DiscardUnknown()

func (*PeerEntry) XXX_Marshal 

func (m *PeerEntry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PeerEntry) XXX_Merge 

func (dst *PeerEntry) XXX_Merge(src proto.Message)

func (*PeerEntry) XXX_Size 

func (m *PeerEntry) XXX_Size() int

func (*PeerEntry) XXX_Unmarshal 

func (m *PeerEntry) XXX_Unmarshal(b []byte) error

type PeerJoinRequest 

type PeerJoinRequest struct {
	PeerId               []byte   `protobuf:"bytes,1,opt,name=peer_id,json=peerId,proto3" json:"peer_id,omitempty"`
	LocalIp              string   `protobuf:"bytes,2,opt,name=local_ip,json=localIp" json:"local_ip,omitempty"`
	LocalPort            string   `protobuf:"bytes,3,opt,name=local_port,json=localPort" json:"local_port,omitempty"`
	Latitude             float32  `protobuf:"fixed32,4,opt,name=latitude" json:"latitude,omitempty"`
	Longitude            float32  `protobuf:"fixed32,5,opt,name=longitude" json:"longitude,omitempty"`
	Protocol             string   `protobuf:"bytes,6,opt,name=protocol" json:"protocol,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PeerJoinRequest) Descriptor 

func (*PeerJoinRequest) Descriptor() ([]byte, []int)

func (*PeerJoinRequest) GetLatitude 

func (m *PeerJoinRequest) GetLatitude() float32

func (*PeerJoinRequest) GetLocalIp 

func (m *PeerJoinRequest) GetLocalIp() string

func (*PeerJoinRequest) GetLocalPort 

func (m *PeerJoinRequest) GetLocalPort() string

func (*PeerJoinRequest) GetLongitude 

func (m *PeerJoinRequest) GetLongitude() float32

func (*PeerJoinRequest) GetPeerId 

func (m *PeerJoinRequest) GetPeerId() []byte

func (*PeerJoinRequest) GetProtocol 

func (m *PeerJoinRequest) GetProtocol() string

func (*PeerJoinRequest) ProtoMessage 

func (*PeerJoinRequest) ProtoMessage()

func (*PeerJoinRequest) Reset 

func (m *PeerJoinRequest) Reset()

func (*PeerJoinRequest) String 

func (m *PeerJoinRequest) String() string

func (*PeerJoinRequest) XXX_DiscardUnknown 

func (m *PeerJoinRequest) XXX_DiscardUnknown()

func (*PeerJoinRequest) XXX_Marshal 

func (m *PeerJoinRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PeerJoinRequest) XXX_Merge 

func (dst *PeerJoinRequest) XXX_Merge(src proto.Message)

func (*PeerJoinRequest) XXX_Size 

func (m *PeerJoinRequest) XXX_Size() int

func (*PeerJoinRequest) XXX_Unmarshal 

func (m *PeerJoinRequest) XXX_Unmarshal(b []byte) error

type PeerJoinResponse 

type PeerJoinResponse struct {
	Success              bool     `protobuf:"varint,1,opt,name=success" json:"success,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PeerJoinResponse) Descriptor 

func (*PeerJoinResponse) Descriptor() ([]byte, []int)

func (*PeerJoinResponse) GetSuccess 

func (m *PeerJoinResponse) GetSuccess() bool

func (*PeerJoinResponse) ProtoMessage 

func (*PeerJoinResponse) ProtoMessage()

func (*PeerJoinResponse) Reset 

func (m *PeerJoinResponse) Reset()

func (*PeerJoinResponse) String 

func (m *PeerJoinResponse) String() string

func (*PeerJoinResponse) XXX_DiscardUnknown 

func (m *PeerJoinResponse) XXX_DiscardUnknown()

func (*PeerJoinResponse) XXX_Marshal 

func (m *PeerJoinResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PeerJoinResponse) XXX_Merge 

func (dst *PeerJoinResponse) XXX_Merge(src proto.Message)

func (*PeerJoinResponse) XXX_Size 

func (m *PeerJoinResponse) XXX_Size() int

func (*PeerJoinResponse) XXX_Unmarshal 

func (m *PeerJoinResponse) XXX_Unmarshal(b []byte) error

type PeerServer 

type PeerServer interface {
	NoticeFromProxyRPC(context.Context, *NoticeFromProxyRequest) (*Empty, error)
}

type ProxyClient 

type ProxyClient interface {
	Heartbeat(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error)
	GeneratePeerID(ctx context.Context, in *GeneratePeerIDRequest, opts ...grpc.CallOption) (*GeneratePeerIDResponse, error)
	ExchangeEntriesStubRPC(ctx context.Context, in *ExchangeEntriesNotification, opts ...grpc.CallOption) (*Empty, error)
	ExchangeEntriesDriverRPC(ctx context.Context, in *ExchangeEntriesRequest, opts ...grpc.CallOption) (*ExchangeEntriesResponse, error)
	LookUpPeersRPC(ctx context.Context, in *LookUpPeerRequest, opts ...grpc.CallOption) (*LookUpPeerResponse, error)
	FetchPeersRPC(ctx context.Context, in *FetchPeersRequest, opts ...grpc.CallOption) (*FetchPeersResponse, error)
}

ProxyClient is the client API for Proxy service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewProxyClient 

func NewProxyClient(cc *grpc.ClientConn) ProxyClient

type ProxyEntries 

type ProxyEntries struct {
	Entries              []*ProxyEntry `protobuf:"bytes,1,rep,name=entries" json:"entries,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*ProxyEntries) Descriptor 

func (*ProxyEntries) Descriptor() ([]byte, []int)

func (*ProxyEntries) GetEntries 

func (m *ProxyEntries) GetEntries() []*ProxyEntry

func (*ProxyEntries) ProtoMessage 

func (*ProxyEntries) ProtoMessage()

func (*ProxyEntries) Reset 

func (m *ProxyEntries) Reset()

func (*ProxyEntries) String 

func (m *ProxyEntries) String() string

func (*ProxyEntries) XXX_DiscardUnknown 

func (m *ProxyEntries) XXX_DiscardUnknown()

func (*ProxyEntries) XXX_Marshal 

func (m *ProxyEntries) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ProxyEntries) XXX_Merge 

func (dst *ProxyEntries) XXX_Merge(src proto.Message)

func (*ProxyEntries) XXX_Size 

func (m *ProxyEntries) XXX_Size() int

func (*ProxyEntries) XXX_Unmarshal 

func (m *ProxyEntries) XXX_Unmarshal(b []byte) error

type ProxyEntry 

type ProxyEntry struct {
	Id                   uint32   `protobuf:"varint,7,opt,name=id" json:"id,omitempty"`
	UniqueKey            string   `protobuf:"bytes,8,opt,name=unique_key,json=uniqueKey" json:"unique_key,omitempty"`
	GlobalIp             string   `protobuf:"bytes,1,opt,name=global_ip,json=globalIp" json:"global_ip,omitempty"`
	GlobalPort           string   `protobuf:"bytes,2,opt,name=global_port,json=globalPort" json:"global_port,omitempty"`
	Latitude             float32  `protobuf:"fixed32,3,opt,name=latitude" json:"latitude,omitempty"`
	Longitude            float32  `protobuf:"fixed32,4,opt,name=longitude" json:"longitude,omitempty"`
	CreatedAt            int64    `protobuf:"varint,5,opt,name=created_at,json=createdAt" json:"created_at,omitempty"`
	UpdatedAt            int64    `protobuf:"varint,6,opt,name=updated_at,json=updatedAt" json:"updated_at,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ProxyEntry) Descriptor 

func (*ProxyEntry) Descriptor() ([]byte, []int)

func (*ProxyEntry) GetCreatedAt 

func (m *ProxyEntry) GetCreatedAt() int64

func (*ProxyEntry) GetGlobalIp 

func (m *ProxyEntry) GetGlobalIp() string

func (*ProxyEntry) GetGlobalPort 

func (m *ProxyEntry) GetGlobalPort() string

func (*ProxyEntry) GetId 

func (m *ProxyEntry) GetId() uint32

func (*ProxyEntry) GetLatitude 

func (m *ProxyEntry) GetLatitude() float32

func (*ProxyEntry) GetLongitude 

func (m *ProxyEntry) GetLongitude() float32

func (*ProxyEntry) GetUniqueKey 

func (m *ProxyEntry) GetUniqueKey() string

func (*ProxyEntry) GetUpdatedAt 

func (m *ProxyEntry) GetUpdatedAt() int64

func (*ProxyEntry) ProtoMessage 

func (*ProxyEntry) ProtoMessage()

func (*ProxyEntry) Reset 

func (m *ProxyEntry) Reset()

func (*ProxyEntry) String 

func (m *ProxyEntry) String() string

func (*ProxyEntry) XXX_DiscardUnknown 

func (m *ProxyEntry) XXX_DiscardUnknown()

func (*ProxyEntry) XXX_Marshal 

func (m *ProxyEntry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ProxyEntry) XXX_Merge 

func (dst *ProxyEntry) XXX_Merge(src proto.Message)

func (*ProxyEntry) XXX_Size 

func (m *ProxyEntry) XXX_Size() int

func (*ProxyEntry) XXX_Unmarshal 

func (m *ProxyEntry) XXX_Unmarshal(b []byte) error

type ProxyJoinRequest 

type ProxyJoinRequest struct {
	UniqueKey            string   `protobuf:"bytes,1,opt,name=unique_key,json=uniqueKey" json:"unique_key,omitempty"`
	GlobalPort           string   `protobuf:"bytes,2,opt,name=global_port,json=globalPort" json:"global_port,omitempty"`
	Latitude             float32  `protobuf:"fixed32,3,opt,name=latitude" json:"latitude,omitempty"`
	Longitude            float32  `protobuf:"fixed32,4,opt,name=longitude" json:"longitude,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ProxyJoinRequest) Descriptor 

func (*ProxyJoinRequest) Descriptor() ([]byte, []int)

func (*ProxyJoinRequest) GetGlobalPort 

func (m *ProxyJoinRequest) GetGlobalPort() string

func (*ProxyJoinRequest) GetLatitude 

func (m *ProxyJoinRequest) GetLatitude() float32

func (*ProxyJoinRequest) GetLongitude 

func (m *ProxyJoinRequest) GetLongitude() float32

func (*ProxyJoinRequest) GetUniqueKey 

func (m *ProxyJoinRequest) GetUniqueKey() string

func (*ProxyJoinRequest) ProtoMessage 

func (*ProxyJoinRequest) ProtoMessage()

func (*ProxyJoinRequest) Reset 

func (m *ProxyJoinRequest) Reset()

func (*ProxyJoinRequest) String 

func (m *ProxyJoinRequest) String() string

func (*ProxyJoinRequest) XXX_DiscardUnknown 

func (m *ProxyJoinRequest) XXX_DiscardUnknown()

func (*ProxyJoinRequest) XXX_Marshal 

func (m *ProxyJoinRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ProxyJoinRequest) XXX_Merge 

func (dst *ProxyJoinRequest) XXX_Merge(src proto.Message)

func (*ProxyJoinRequest) XXX_Size 

func (m *ProxyJoinRequest) XXX_Size() int

func (*ProxyJoinRequest) XXX_Unmarshal 

func (m *ProxyJoinRequest) XXX_Unmarshal(b []byte) error

type ProxyServer 

type ProxyServer interface {
	Heartbeat(context.Context, *Empty) (*Empty, error)
	GeneratePeerID(context.Context, *GeneratePeerIDRequest) (*GeneratePeerIDResponse, error)
	ExchangeEntriesStubRPC(context.Context, *ExchangeEntriesNotification) (*Empty, error)
	ExchangeEntriesDriverRPC(context.Context, *ExchangeEntriesRequest) (*ExchangeEntriesResponse, error)
	LookUpPeersRPC(context.Context, *LookUpPeerRequest) (*LookUpPeerResponse, error)
	FetchPeersRPC(context.Context, *FetchPeersRequest) (*FetchPeersResponse, error)
}

type TabletClient 

type TabletClient interface {
	ProxyJoinRPC(ctx context.Context, in *ProxyJoinRequest, opts ...grpc.CallOption) (*ProxyEntry, error)
	LookUpRPC(ctx context.Context, in *LookUpRequest, opts ...grpc.CallOption) (*ProxyEntry, error)
	LookUpPeersRPC(ctx context.Context, in *LookUpPeerRequest, opts ...grpc.CallOption) (*LookUpPeerResponse, error)
}

TabletClient is the client API for Tablet service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewTabletClient 

func NewTabletClient(cc *grpc.ClientConn) TabletClient

type TabletServer 

type TabletServer interface {
	ProxyJoinRPC(context.Context, *ProxyJoinRequest) (*ProxyEntry, error)
	LookUpRPC(context.Context, *LookUpRequest) (*ProxyEntry, error)
	LookUpPeersRPC(context.Context, *LookUpPeerRequest) (*LookUpPeerResponse, error)
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.