Documentation ¶
Index ¶
- Variables
- func RegisterUnityPrivateServiceServer(s *grpc.Server, srv UnityPrivateServiceServer)
- func RegisterUnityPublicServiceServer(s *grpc.Server, srv UnityPublicServiceServer)
- type Address
- func (*Address) Descriptor() ([]byte, []int)
- func (m *Address) GetIp() []byte
- func (m *Address) GetPort() uint64
- func (m *Address) Marshal() (dAtA []byte, err error)
- func (m *Address) MarshalTo(dAtA []byte) (int, error)
- func (m *Address) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Address) ProtoMessage()
- func (m *Address) Reset()
- func (m *Address) Size() (n int)
- func (m *Address) String() string
- func (m *Address) Unmarshal(dAtA []byte) error
- func (m *Address) XXX_DiscardUnknown()
- func (m *Address) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Address) XXX_Merge(src proto.Message)
- func (m *Address) XXX_Size() int
- func (m *Address) XXX_Unmarshal(b []byte) error
- type ConnectRequest
- func (*ConnectRequest) Descriptor() ([]byte, []int)
- func (m *ConnectRequest) GetUserid() uint64
- func (m *ConnectRequest) Marshal() (dAtA []byte, err error)
- func (m *ConnectRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *ConnectRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ConnectRequest) ProtoMessage()
- func (m *ConnectRequest) Reset()
- func (m *ConnectRequest) Size() (n int)
- func (m *ConnectRequest) String() string
- func (m *ConnectRequest) Unmarshal(dAtA []byte) error
- func (m *ConnectRequest) XXX_DiscardUnknown()
- func (m *ConnectRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ConnectRequest) XXX_Merge(src proto.Message)
- func (m *ConnectRequest) XXX_Size() int
- func (m *ConnectRequest) XXX_Unmarshal(b []byte) error
- type ConnectResponse
- func (*ConnectResponse) Descriptor() ([]byte, []int)
- func (m *ConnectResponse) GetAddress() []byte
- func (m *ConnectResponse) GetServerPeer() *Peer
- func (m *ConnectResponse) GetSource() *Address
- func (m *ConnectResponse) Marshal() (dAtA []byte, err error)
- func (m *ConnectResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *ConnectResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ConnectResponse) ProtoMessage()
- func (m *ConnectResponse) Reset()
- func (m *ConnectResponse) Size() (n int)
- func (m *ConnectResponse) String() string
- func (m *ConnectResponse) Unmarshal(dAtA []byte) error
- func (m *ConnectResponse) XXX_DiscardUnknown()
- func (m *ConnectResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ConnectResponse) XXX_Merge(src proto.Message)
- func (m *ConnectResponse) XXX_Size() int
- func (m *ConnectResponse) XXX_Unmarshal(b []byte) error
- type HeartbeatRequest
- func (*HeartbeatRequest) Descriptor() ([]byte, []int)
- func (m *HeartbeatRequest) Marshal() (dAtA []byte, err error)
- func (m *HeartbeatRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *HeartbeatRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*HeartbeatRequest) ProtoMessage()
- func (m *HeartbeatRequest) Reset()
- func (m *HeartbeatRequest) Size() (n int)
- func (m *HeartbeatRequest) String() string
- func (m *HeartbeatRequest) Unmarshal(dAtA []byte) error
- func (m *HeartbeatRequest) XXX_DiscardUnknown()
- func (m *HeartbeatRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *HeartbeatRequest) XXX_Merge(src proto.Message)
- func (m *HeartbeatRequest) XXX_Size() int
- func (m *HeartbeatRequest) XXX_Unmarshal(b []byte) error
- type HeartbeatResponse
- func (*HeartbeatResponse) Descriptor() ([]byte, []int)
- func (m *HeartbeatResponse) Marshal() (dAtA []byte, err error)
- func (m *HeartbeatResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *HeartbeatResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*HeartbeatResponse) ProtoMessage()
- func (m *HeartbeatResponse) Reset()
- func (m *HeartbeatResponse) Size() (n int)
- func (m *HeartbeatResponse) String() string
- func (m *HeartbeatResponse) Unmarshal(dAtA []byte) error
- func (m *HeartbeatResponse) XXX_DiscardUnknown()
- func (m *HeartbeatResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *HeartbeatResponse) XXX_Merge(src proto.Message)
- func (m *HeartbeatResponse) XXX_Size() int
- func (m *HeartbeatResponse) XXX_Unmarshal(b []byte) error
- type Peer
- func (*Peer) Descriptor() ([]byte, []int)
- func (m *Peer) GetEndpoint() *Address
- func (m *Peer) GetIp() []byte
- func (m *Peer) GetPublicKey() []byte
- func (m *Peer) Marshal() (dAtA []byte, err error)
- func (m *Peer) MarshalTo(dAtA []byte) (int, error)
- func (m *Peer) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Peer) ProtoMessage()
- func (m *Peer) Reset()
- func (m *Peer) Size() (n int)
- func (m *Peer) String() string
- func (m *Peer) Unmarshal(dAtA []byte) error
- func (m *Peer) XXX_DiscardUnknown()
- func (m *Peer) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Peer) XXX_Merge(src proto.Message)
- func (m *Peer) XXX_Size() int
- func (m *Peer) XXX_Unmarshal(b []byte) error
- type UnimplementedUnityPrivateServiceServer
- type UnimplementedUnityPublicServiceServer
- type UnityPrivateServiceClient
- type UnityPrivateServiceServer
- type UnityPublicServiceClient
- type UnityPublicServiceServer
Constants ¶
This section is empty.
Variables ¶
Functions ¶
func RegisterUnityPrivateServiceServer ¶
func RegisterUnityPrivateServiceServer(s *grpc.Server, srv UnityPrivateServiceServer)
func RegisterUnityPublicServiceServer ¶
func RegisterUnityPublicServiceServer(s *grpc.Server, srv UnityPublicServiceServer)
Types ¶
type Address ¶
type Address struct { Ip []byte `protobuf:"bytes,1,opt,name=ip,proto3" json:"ip,omitempty"` Port uint64 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Address) Descriptor ¶
func (*Address) MarshalToSizedBuffer ¶
func (*Address) ProtoMessage ¶
func (*Address) ProtoMessage()
func (*Address) XXX_DiscardUnknown ¶
func (m *Address) XXX_DiscardUnknown()
func (*Address) XXX_Marshal ¶
func (*Address) XXX_Unmarshal ¶
type ConnectRequest ¶
type ConnectRequest struct { Userid uint64 `protobuf:"varint,1,opt,name=userid,proto3" json:"userid,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ConnectRequest) Descriptor ¶
func (*ConnectRequest) Descriptor() ([]byte, []int)
func (*ConnectRequest) GetUserid ¶
func (m *ConnectRequest) GetUserid() uint64
func (*ConnectRequest) Marshal ¶
func (m *ConnectRequest) Marshal() (dAtA []byte, err error)
func (*ConnectRequest) MarshalToSizedBuffer ¶
func (m *ConnectRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ConnectRequest) ProtoMessage ¶
func (*ConnectRequest) ProtoMessage()
func (*ConnectRequest) Reset ¶
func (m *ConnectRequest) Reset()
func (*ConnectRequest) Size ¶
func (m *ConnectRequest) Size() (n int)
func (*ConnectRequest) String ¶
func (m *ConnectRequest) String() string
func (*ConnectRequest) Unmarshal ¶
func (m *ConnectRequest) Unmarshal(dAtA []byte) error
func (*ConnectRequest) XXX_DiscardUnknown ¶
func (m *ConnectRequest) XXX_DiscardUnknown()
func (*ConnectRequest) XXX_Marshal ¶
func (m *ConnectRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ConnectRequest) XXX_Merge ¶
func (m *ConnectRequest) XXX_Merge(src proto.Message)
func (*ConnectRequest) XXX_Size ¶
func (m *ConnectRequest) XXX_Size() int
func (*ConnectRequest) XXX_Unmarshal ¶
func (m *ConnectRequest) XXX_Unmarshal(b []byte) error
type ConnectResponse ¶
type ConnectResponse struct { Source *Address `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"` Address []byte `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"` ServerPeer *Peer `protobuf:"bytes,3,opt,name=server_peer,json=serverPeer,proto3" json:"server_peer,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ConnectResponse) Descriptor ¶
func (*ConnectResponse) Descriptor() ([]byte, []int)
func (*ConnectResponse) GetAddress ¶
func (m *ConnectResponse) GetAddress() []byte
func (*ConnectResponse) GetServerPeer ¶
func (m *ConnectResponse) GetServerPeer() *Peer
func (*ConnectResponse) GetSource ¶
func (m *ConnectResponse) GetSource() *Address
func (*ConnectResponse) Marshal ¶
func (m *ConnectResponse) Marshal() (dAtA []byte, err error)
func (*ConnectResponse) MarshalToSizedBuffer ¶
func (m *ConnectResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ConnectResponse) ProtoMessage ¶
func (*ConnectResponse) ProtoMessage()
func (*ConnectResponse) Reset ¶
func (m *ConnectResponse) Reset()
func (*ConnectResponse) Size ¶
func (m *ConnectResponse) Size() (n int)
func (*ConnectResponse) String ¶
func (m *ConnectResponse) String() string
func (*ConnectResponse) Unmarshal ¶
func (m *ConnectResponse) Unmarshal(dAtA []byte) error
func (*ConnectResponse) XXX_DiscardUnknown ¶
func (m *ConnectResponse) XXX_DiscardUnknown()
func (*ConnectResponse) XXX_Marshal ¶
func (m *ConnectResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ConnectResponse) XXX_Merge ¶
func (m *ConnectResponse) XXX_Merge(src proto.Message)
func (*ConnectResponse) XXX_Size ¶
func (m *ConnectResponse) XXX_Size() int
func (*ConnectResponse) XXX_Unmarshal ¶
func (m *ConnectResponse) XXX_Unmarshal(b []byte) error
type HeartbeatRequest ¶
type HeartbeatRequest struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*HeartbeatRequest) Descriptor ¶
func (*HeartbeatRequest) Descriptor() ([]byte, []int)
func (*HeartbeatRequest) Marshal ¶
func (m *HeartbeatRequest) Marshal() (dAtA []byte, err error)
func (*HeartbeatRequest) MarshalToSizedBuffer ¶
func (m *HeartbeatRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*HeartbeatRequest) ProtoMessage ¶
func (*HeartbeatRequest) ProtoMessage()
func (*HeartbeatRequest) Reset ¶
func (m *HeartbeatRequest) Reset()
func (*HeartbeatRequest) Size ¶
func (m *HeartbeatRequest) Size() (n int)
func (*HeartbeatRequest) String ¶
func (m *HeartbeatRequest) String() string
func (*HeartbeatRequest) Unmarshal ¶
func (m *HeartbeatRequest) Unmarshal(dAtA []byte) error
func (*HeartbeatRequest) XXX_DiscardUnknown ¶
func (m *HeartbeatRequest) XXX_DiscardUnknown()
func (*HeartbeatRequest) XXX_Marshal ¶
func (m *HeartbeatRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*HeartbeatRequest) XXX_Merge ¶
func (m *HeartbeatRequest) XXX_Merge(src proto.Message)
func (*HeartbeatRequest) XXX_Size ¶
func (m *HeartbeatRequest) XXX_Size() int
func (*HeartbeatRequest) XXX_Unmarshal ¶
func (m *HeartbeatRequest) XXX_Unmarshal(b []byte) error
type HeartbeatResponse ¶
type HeartbeatResponse struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*HeartbeatResponse) Descriptor ¶
func (*HeartbeatResponse) Descriptor() ([]byte, []int)
func (*HeartbeatResponse) Marshal ¶
func (m *HeartbeatResponse) Marshal() (dAtA []byte, err error)
func (*HeartbeatResponse) MarshalTo ¶
func (m *HeartbeatResponse) MarshalTo(dAtA []byte) (int, error)
func (*HeartbeatResponse) MarshalToSizedBuffer ¶
func (m *HeartbeatResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*HeartbeatResponse) ProtoMessage ¶
func (*HeartbeatResponse) ProtoMessage()
func (*HeartbeatResponse) Reset ¶
func (m *HeartbeatResponse) Reset()
func (*HeartbeatResponse) Size ¶
func (m *HeartbeatResponse) Size() (n int)
func (*HeartbeatResponse) String ¶
func (m *HeartbeatResponse) String() string
func (*HeartbeatResponse) Unmarshal ¶
func (m *HeartbeatResponse) Unmarshal(dAtA []byte) error
func (*HeartbeatResponse) XXX_DiscardUnknown ¶
func (m *HeartbeatResponse) XXX_DiscardUnknown()
func (*HeartbeatResponse) XXX_Marshal ¶
func (m *HeartbeatResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*HeartbeatResponse) XXX_Merge ¶
func (m *HeartbeatResponse) XXX_Merge(src proto.Message)
func (*HeartbeatResponse) XXX_Size ¶
func (m *HeartbeatResponse) XXX_Size() int
func (*HeartbeatResponse) XXX_Unmarshal ¶
func (m *HeartbeatResponse) XXX_Unmarshal(b []byte) error
type Peer ¶
type Peer struct { Ip []byte `protobuf:"bytes,1,opt,name=ip,proto3" json:"ip,omitempty"` PublicKey []byte `protobuf:"bytes,2,opt,name=public_key,json=publicKey,proto3" json:"public_key,omitempty"` Endpoint *Address `protobuf:"bytes,3,opt,name=endpoint,proto3" json:"endpoint,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Peer) Descriptor ¶
func (*Peer) GetEndpoint ¶
func (*Peer) GetPublicKey ¶
func (*Peer) ProtoMessage ¶
func (*Peer) ProtoMessage()
func (*Peer) XXX_DiscardUnknown ¶
func (m *Peer) XXX_DiscardUnknown()
func (*Peer) XXX_Unmarshal ¶
type UnimplementedUnityPrivateServiceServer ¶
type UnimplementedUnityPrivateServiceServer struct { }
UnimplementedUnityPrivateServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedUnityPrivateServiceServer) Heartbeat ¶
func (*UnimplementedUnityPrivateServiceServer) Heartbeat(ctx context.Context, req *HeartbeatRequest) (*HeartbeatResponse, error)
type UnimplementedUnityPublicServiceServer ¶
type UnimplementedUnityPublicServiceServer struct { }
UnimplementedUnityPublicServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedUnityPublicServiceServer) Connect ¶
func (*UnimplementedUnityPublicServiceServer) Connect(ctx context.Context, req *ConnectRequest) (*ConnectResponse, error)
type UnityPrivateServiceClient ¶
type UnityPrivateServiceClient interface {
Heartbeat(ctx context.Context, in *HeartbeatRequest, opts ...grpc.CallOption) (*HeartbeatResponse, error)
}
UnityPrivateServiceClient is the client API for UnityPrivateService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewUnityPrivateServiceClient ¶
func NewUnityPrivateServiceClient(cc *grpc.ClientConn) UnityPrivateServiceClient
type UnityPrivateServiceServer ¶
type UnityPrivateServiceServer interface {
Heartbeat(context.Context, *HeartbeatRequest) (*HeartbeatResponse, error)
}
UnityPrivateServiceServer is the server API for UnityPrivateService service.
type UnityPublicServiceClient ¶
type UnityPublicServiceClient interface {
Connect(ctx context.Context, in *ConnectRequest, opts ...grpc.CallOption) (*ConnectResponse, error)
}
UnityPublicServiceClient is the client API for UnityPublicService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewUnityPublicServiceClient ¶
func NewUnityPublicServiceClient(cc *grpc.ClientConn) UnityPublicServiceClient
type UnityPublicServiceServer ¶
type UnityPublicServiceServer interface {
Connect(context.Context, *ConnectRequest) (*ConnectResponse, error)
}
UnityPublicServiceServer is the server API for UnityPublicService service.