bwreserver

package
v0.1.2 Latest Latest
Warning

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

Go to latest
Published: Dec 21, 2020 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
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.

View Source
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
const (
	// Unspecified protocol
	Protocol_PROTOCOL_UNSPECIFIED Protocol = 0
	// UDP
	Protocol_PROTOCOL_UDP Protocol = 1
	// QUIC
	Protocol_PROTOCOL_QUIC Protocol = 2
)

func (Protocol) Descriptor

func (Protocol) Descriptor() protoreflect.EnumDescriptor

func (Protocol) Enum

func (x Protocol) Enum() *Protocol

func (Protocol) EnumDescriptor deprecated

func (Protocol) EnumDescriptor() ([]byte, []int)

Deprecated: Use Protocol.Descriptor instead.

func (Protocol) Number

func (x Protocol) Number() protoreflect.EnumNumber

func (Protocol) String

func (x Protocol) String() string

func (Protocol) Type

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.

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) Stats

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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL