Documentation ¶
Index ¶
- Variables
- func RegisterSessionServiceServer(s grpc.ServiceRegistrar, srv SessionServiceServer)
- type OpenSessionRequest
- func (*OpenSessionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *OpenSessionRequest) GetProtocol() Protocol
- func (x *OpenSessionRequest) GetSrcHost() []byte
- func (x *OpenSessionRequest) GetSrcIsdAs() uint64
- func (*OpenSessionRequest) ProtoMessage()
- func (x *OpenSessionRequest) ProtoReflect() protoreflect.Message
- func (x *OpenSessionRequest) Reset()
- func (x *OpenSessionRequest) String() string
- type OpenSessionResponse
- func (*OpenSessionResponse) Descriptor() ([]byte, []int)deprecated
- func (x *OpenSessionResponse) GetPort() uint32
- func (x *OpenSessionResponse) GetProtocol() Protocol
- func (x *OpenSessionResponse) GetSessionId() uint64
- func (*OpenSessionResponse) ProtoMessage()
- func (x *OpenSessionResponse) ProtoReflect() protoreflect.Message
- func (x *OpenSessionResponse) Reset()
- func (x *OpenSessionResponse) String() string
- type Protocol
- type SessionServiceClient
- type SessionServiceServer
- type StatsRequest
- type StatsResponse
- func (*StatsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *StatsResponse) GetBytesReceived() uint64
- func (x *StatsResponse) GetCurrent() *timestamp.Timestamp
- func (x *StatsResponse) GetStart() *timestamp.Timestamp
- func (*StatsResponse) ProtoMessage()
- func (x *StatsResponse) ProtoReflect() protoreflect.Message
- func (x *StatsResponse) Reset()
- func (x *StatsResponse) String() string
- type UnimplementedSessionServiceServer
- type UnsafeSessionServiceServer
Constants ¶
This section is empty.
Variables ¶
var ( Protocol_name = map[int32]string{ 0: "PROTOCOL_UNSPECIFIED", 1: "PROTOCOL_UDP", 2: "PROTOCOL_QUIC", } Protocol_value = map[string]int32{ "PROTOCOL_UNSPECIFIED": 0, "PROTOCOL_UDP": 1, "PROTOCOL_QUIC": 2, } )
Enum value maps for Protocol.
var File_proto_bwreserver_v1_bwreserver_proto protoreflect.FileDescriptor
Functions ¶
func RegisterSessionServiceServer ¶
func RegisterSessionServiceServer(s grpc.ServiceRegistrar, srv SessionServiceServer)
Types ¶
type OpenSessionRequest ¶
type OpenSessionRequest struct { // The source ISD-AS. SrcIsdAs uint64 `protobuf:"varint,1,opt,name=src_isd_as,json=srcIsdAs,proto3" json:"src_isd_as,omitempty"` // The source host that requests to open a data session. SrcHost []byte `protobuf:"bytes,2,opt,name=src_host,json=srcHost,proto3" json:"src_host,omitempty"` // The protocol to be used. Protocol Protocol `protobuf:"varint,3,opt,name=protocol,proto3,enum=anapaya.proto.bwreserver.v1.Protocol" json:"protocol,omitempty"` // contains filtered or unexported fields }
func (*OpenSessionRequest) Descriptor
deprecated
func (*OpenSessionRequest) Descriptor() ([]byte, []int)
Deprecated: Use OpenSessionRequest.ProtoReflect.Descriptor instead.
func (*OpenSessionRequest) GetProtocol ¶
func (x *OpenSessionRequest) GetProtocol() Protocol
func (*OpenSessionRequest) GetSrcHost ¶
func (x *OpenSessionRequest) GetSrcHost() []byte
func (*OpenSessionRequest) GetSrcIsdAs ¶
func (x *OpenSessionRequest) GetSrcIsdAs() uint64
func (*OpenSessionRequest) ProtoMessage ¶
func (*OpenSessionRequest) ProtoMessage()
func (*OpenSessionRequest) ProtoReflect ¶
func (x *OpenSessionRequest) ProtoReflect() protoreflect.Message
func (*OpenSessionRequest) Reset ¶
func (x *OpenSessionRequest) Reset()
func (*OpenSessionRequest) String ¶
func (x *OpenSessionRequest) String() string
type OpenSessionResponse ¶
type OpenSessionResponse struct { // The session ID for the data session. SessionId uint64 `protobuf:"varint,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"` // The destination port. Port uint32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"` // The protocol to be used. Protocol Protocol `protobuf:"varint,3,opt,name=protocol,proto3,enum=anapaya.proto.bwreserver.v1.Protocol" json:"protocol,omitempty"` // contains filtered or unexported fields }
func (*OpenSessionResponse) Descriptor
deprecated
func (*OpenSessionResponse) Descriptor() ([]byte, []int)
Deprecated: Use OpenSessionResponse.ProtoReflect.Descriptor instead.
func (*OpenSessionResponse) GetPort ¶
func (x *OpenSessionResponse) GetPort() uint32
func (*OpenSessionResponse) GetProtocol ¶
func (x *OpenSessionResponse) GetProtocol() Protocol
func (*OpenSessionResponse) GetSessionId ¶
func (x *OpenSessionResponse) GetSessionId() uint64
func (*OpenSessionResponse) ProtoMessage ¶
func (*OpenSessionResponse) ProtoMessage()
func (*OpenSessionResponse) ProtoReflect ¶
func (x *OpenSessionResponse) ProtoReflect() protoreflect.Message
func (*OpenSessionResponse) Reset ¶
func (x *OpenSessionResponse) Reset()
func (*OpenSessionResponse) String ¶
func (x *OpenSessionResponse) String() string
type Protocol ¶
type Protocol int32
func (Protocol) Descriptor ¶
func (Protocol) Descriptor() protoreflect.EnumDescriptor
func (Protocol) EnumDescriptor
deprecated
func (Protocol) Number ¶
func (x Protocol) Number() protoreflect.EnumNumber
func (Protocol) Type ¶
func (Protocol) Type() protoreflect.EnumType
type SessionServiceClient ¶
type SessionServiceClient interface { // OpenSession returns a network endpoint to use for a data connection to the server. OpenSession(ctx context.Context, in *OpenSessionRequest, opts ...grpc.CallOption) (*OpenSessionResponse, error) // Stats returns statistics for a client session. Stats(ctx context.Context, in *StatsRequest, opts ...grpc.CallOption) (*StatsResponse, error) }
SessionServiceClient is the client API for SessionService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewSessionServiceClient ¶
func NewSessionServiceClient(cc grpc.ClientConnInterface) SessionServiceClient
type SessionServiceServer ¶
type SessionServiceServer interface { // OpenSession returns a network endpoint to use for a data connection to the server. OpenSession(context.Context, *OpenSessionRequest) (*OpenSessionResponse, error) // Stats returns statistics for a client session. Stats(context.Context, *StatsRequest) (*StatsResponse, error) }
SessionServiceServer is the server API for SessionService service. All implementations should embed UnimplementedSessionServiceServer for forward compatibility
type StatsRequest ¶
type StatsRequest struct { // The session ID for the data session. SessionId uint64 `protobuf:"varint,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"` // contains filtered or unexported fields }
func (*StatsRequest) Descriptor
deprecated
func (*StatsRequest) Descriptor() ([]byte, []int)
Deprecated: Use StatsRequest.ProtoReflect.Descriptor instead.
func (*StatsRequest) GetSessionId ¶
func (x *StatsRequest) GetSessionId() uint64
func (*StatsRequest) ProtoMessage ¶
func (*StatsRequest) ProtoMessage()
func (*StatsRequest) ProtoReflect ¶
func (x *StatsRequest) ProtoReflect() protoreflect.Message
func (*StatsRequest) Reset ¶
func (x *StatsRequest) Reset()
func (*StatsRequest) String ¶
func (x *StatsRequest) String() string
type StatsResponse ¶
type StatsResponse struct { // The start timestamp of the session. Start *timestamp.Timestamp `protobuf:"bytes,1,opt,name=start,proto3" json:"start,omitempty"` // The current timestamp. Current *timestamp.Timestamp `protobuf:"bytes,2,opt,name=current,proto3" json:"current,omitempty"` // The number of bytes received from start to current. BytesReceived uint64 `protobuf:"varint,3,opt,name=bytes_received,json=bytesReceived,proto3" json:"bytes_received,omitempty"` // contains filtered or unexported fields }
func (*StatsResponse) Descriptor
deprecated
func (*StatsResponse) Descriptor() ([]byte, []int)
Deprecated: Use StatsResponse.ProtoReflect.Descriptor instead.
func (*StatsResponse) GetBytesReceived ¶
func (x *StatsResponse) GetBytesReceived() uint64
func (*StatsResponse) GetCurrent ¶
func (x *StatsResponse) GetCurrent() *timestamp.Timestamp
func (*StatsResponse) GetStart ¶
func (x *StatsResponse) GetStart() *timestamp.Timestamp
func (*StatsResponse) ProtoMessage ¶
func (*StatsResponse) ProtoMessage()
func (*StatsResponse) ProtoReflect ¶
func (x *StatsResponse) ProtoReflect() protoreflect.Message
func (*StatsResponse) Reset ¶
func (x *StatsResponse) Reset()
func (*StatsResponse) String ¶
func (x *StatsResponse) String() string
type UnimplementedSessionServiceServer ¶
type UnimplementedSessionServiceServer struct { }
UnimplementedSessionServiceServer should be embedded to have forward compatible implementations.
func (UnimplementedSessionServiceServer) OpenSession ¶
func (UnimplementedSessionServiceServer) OpenSession(context.Context, *OpenSessionRequest) (*OpenSessionResponse, error)
func (UnimplementedSessionServiceServer) Stats ¶
func (UnimplementedSessionServiceServer) Stats(context.Context, *StatsRequest) (*StatsResponse, error)
type UnsafeSessionServiceServer ¶
type UnsafeSessionServiceServer interface {
// contains filtered or unexported methods
}
UnsafeSessionServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to SessionServiceServer will result in compilation errors.