socket

package
v1.6.8 Latest Latest
Warning

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

 Go to latest Published: Aug 30, 2023 License: Apache-2.0 Imports: 3 Imported by: 0

Documentation

Index

Constants

View Source 
const Default_AcceptRequest_TimeoutSeconds float64 = -1
View Source 
const Default_CloseRequest_SendOffset int64 = -1
View Source 
const Default_ConnectRequest_TimeoutSeconds float64 = -1
View Source 
const Default_CreateSocketRequest_ListenBacklog int32 = 0
View Source 
const Default_PollRequest_TimeoutSeconds float64 = -1
View Source 
const Default_ReceiveRequest_Flags int32 = 0
View Source 
const Default_ReceiveRequest_TimeoutSeconds float64 = -1
View Source 
const Default_RemoteSocketServiceError_SystemError int32 = 0
View Source 
const Default_SendRequest_Flags int32 = 0
View Source 
const Default_SendRequest_TimeoutSeconds float64 = -1

Variables

View Source 
var CreateSocketRequest_SocketFamily_name = map[int32]string{
	1: "IPv4",
	2: "IPv6",
}
View Source 
var CreateSocketRequest_SocketFamily_value = map[string]int32{
	"IPv4": 1,
	"IPv6": 2,
}
View Source 
var CreateSocketRequest_SocketProtocol_name = map[int32]string{
	1: "TCP",
	2: "UDP",
}
View Source 
var CreateSocketRequest_SocketProtocol_value = map[string]int32{
	"TCP": 1,
	"UDP": 2,
}
View Source 
var PollEvent_PollEventFlag_name = map[int32]string{
	0:    "SOCKET_POLLNONE",
	1:    "SOCKET_POLLIN",
	2:    "SOCKET_POLLPRI",
	4:    "SOCKET_POLLOUT",
	8:    "SOCKET_POLLERR",
	16:   "SOCKET_POLLHUP",
	32:   "SOCKET_POLLNVAL",
	64:   "SOCKET_POLLRDNORM",
	128:  "SOCKET_POLLRDBAND",
	256:  "SOCKET_POLLWRNORM",
	512:  "SOCKET_POLLWRBAND",
	1024: "SOCKET_POLLMSG",
	4096: "SOCKET_POLLREMOVE",
	8192: "SOCKET_POLLRDHUP",
}
View Source 
var PollEvent_PollEventFlag_value = map[string]int32{
	"SOCKET_POLLNONE":   0,
	"SOCKET_POLLIN":     1,
	"SOCKET_POLLPRI":    2,
	"SOCKET_POLLOUT":    4,
	"SOCKET_POLLERR":    8,
	"SOCKET_POLLHUP":    16,
	"SOCKET_POLLNVAL":   32,
	"SOCKET_POLLRDNORM": 64,
	"SOCKET_POLLRDBAND": 128,
	"SOCKET_POLLWRNORM": 256,
	"SOCKET_POLLWRBAND": 512,
	"SOCKET_POLLMSG":    1024,
	"SOCKET_POLLREMOVE": 4096,
	"SOCKET_POLLRDHUP":  8192,
}
View Source 
var ReceiveRequest_Flags_name = map[int32]string{
	1: "MSG_OOB",
	2: "MSG_PEEK",
}
View Source 
var ReceiveRequest_Flags_value = map[string]int32{
	"MSG_OOB":  1,
	"MSG_PEEK": 2,
}
View Source 
var RemoteSocketServiceError_ErrorCode_name = map[int32]string{
	1: "SYSTEM_ERROR",
	2: "GAI_ERROR",
	4: "FAILURE",
	5: "PERMISSION_DENIED",
	6: "INVALID_REQUEST",
	7: "SOCKET_CLOSED",
}
View Source 
var RemoteSocketServiceError_ErrorCode_value = map[string]int32{
	"SYSTEM_ERROR":      1,
	"GAI_ERROR":         2,
	"FAILURE":           4,
	"PERMISSION_DENIED": 5,
	"INVALID_REQUEST":   6,
	"SOCKET_CLOSED":     7,
}
View Source 
var RemoteSocketServiceError_SystemError_name = map[int32]string{}/* 131 elements not displayed */
View Source 
var RemoteSocketServiceError_SystemError_value = map[string]int32{}/* 134 elements not displayed */
View Source 
var ResolveReply_ErrorCode_name = map[int32]string{
	1:  "SOCKET_EAI_ADDRFAMILY",
	2:  "SOCKET_EAI_AGAIN",
	3:  "SOCKET_EAI_BADFLAGS",
	4:  "SOCKET_EAI_FAIL",
	5:  "SOCKET_EAI_FAMILY",
	6:  "SOCKET_EAI_MEMORY",
	7:  "SOCKET_EAI_NODATA",
	8:  "SOCKET_EAI_NONAME",
	9:  "SOCKET_EAI_SERVICE",
	10: "SOCKET_EAI_SOCKTYPE",
	11: "SOCKET_EAI_SYSTEM",
	12: "SOCKET_EAI_BADHINTS",
	13: "SOCKET_EAI_PROTOCOL",
	14: "SOCKET_EAI_OVERFLOW",
	15: "SOCKET_EAI_MAX",
}
View Source 
var ResolveReply_ErrorCode_value = map[string]int32{
	"SOCKET_EAI_ADDRFAMILY": 1,
	"SOCKET_EAI_AGAIN":      2,
	"SOCKET_EAI_BADFLAGS":   3,
	"SOCKET_EAI_FAIL":       4,
	"SOCKET_EAI_FAMILY":     5,
	"SOCKET_EAI_MEMORY":     6,
	"SOCKET_EAI_NODATA":     7,
	"SOCKET_EAI_NONAME":     8,
	"SOCKET_EAI_SERVICE":    9,
	"SOCKET_EAI_SOCKTYPE":   10,
	"SOCKET_EAI_SYSTEM":     11,
	"SOCKET_EAI_BADHINTS":   12,
	"SOCKET_EAI_PROTOCOL":   13,
	"SOCKET_EAI_OVERFLOW":   14,
	"SOCKET_EAI_MAX":        15,
}
View Source 
var ShutDownRequest_How_name = map[int32]string{
	1: "SOCKET_SHUT_RD",
	2: "SOCKET_SHUT_WR",
	3: "SOCKET_SHUT_RDWR",
}
View Source 
var ShutDownRequest_How_value = map[string]int32{
	"SOCKET_SHUT_RD":   1,
	"SOCKET_SHUT_WR":   2,
	"SOCKET_SHUT_RDWR": 3,
}
View Source 
var SocketOption_SocketOptionLevel_name = map[int32]string{
	0:  "SOCKET_SOL_IP",
	1:  "SOCKET_SOL_SOCKET",
	6:  "SOCKET_SOL_TCP",
	17: "SOCKET_SOL_UDP",
}
View Source 
var SocketOption_SocketOptionLevel_value = map[string]int32{
	"SOCKET_SOL_IP":     0,
	"SOCKET_SOL_SOCKET": 1,
	"SOCKET_SOL_TCP":    6,
	"SOCKET_SOL_UDP":    17,
}
View Source 
var SocketOption_SocketOptionName_name = map[int32]string{
	1:  "SOCKET_SO_DEBUG",
	2:  "SOCKET_SO_REUSEADDR",
	3:  "SOCKET_SO_TYPE",
	4:  "SOCKET_SO_ERROR",
	5:  "SOCKET_SO_DONTROUTE",
	6:  "SOCKET_SO_BROADCAST",
	7:  "SOCKET_SO_SNDBUF",
	8:  "SOCKET_SO_RCVBUF",
	9:  "SOCKET_SO_KEEPALIVE",
	10: "SOCKET_SO_OOBINLINE",
	13: "SOCKET_SO_LINGER",
	20: "SOCKET_SO_RCVTIMEO",
	21: "SOCKET_SO_SNDTIMEO",

	11: "SOCKET_TCP_INFO",
	12: "SOCKET_TCP_QUICKACK",
}
View Source 
var SocketOption_SocketOptionName_value = map[string]int32{
	"SOCKET_SO_DEBUG":         1,
	"SOCKET_SO_REUSEADDR":     2,
	"SOCKET_SO_TYPE":          3,
	"SOCKET_SO_ERROR":         4,
	"SOCKET_SO_DONTROUTE":     5,
	"SOCKET_SO_BROADCAST":     6,
	"SOCKET_SO_SNDBUF":        7,
	"SOCKET_SO_RCVBUF":        8,
	"SOCKET_SO_KEEPALIVE":     9,
	"SOCKET_SO_OOBINLINE":     10,
	"SOCKET_SO_LINGER":        13,
	"SOCKET_SO_RCVTIMEO":      20,
	"SOCKET_SO_SNDTIMEO":      21,
	"SOCKET_IP_TOS":           1,
	"SOCKET_IP_TTL":           2,
	"SOCKET_IP_HDRINCL":       3,
	"SOCKET_IP_OPTIONS":       4,
	"SOCKET_TCP_NODELAY":      1,
	"SOCKET_TCP_MAXSEG":       2,
	"SOCKET_TCP_CORK":         3,
	"SOCKET_TCP_KEEPIDLE":     4,
	"SOCKET_TCP_KEEPINTVL":    5,
	"SOCKET_TCP_KEEPCNT":      6,
	"SOCKET_TCP_SYNCNT":       7,
	"SOCKET_TCP_LINGER2":      8,
	"SOCKET_TCP_DEFER_ACCEPT": 9,
	"SOCKET_TCP_WINDOW_CLAMP": 10,
	"SOCKET_TCP_INFO":         11,
	"SOCKET_TCP_QUICKACK":     12,
}

Functions

This section is empty.

Types

type AcceptReply 

type AcceptReply struct {
	NewSocketDescriptor  []byte       `protobuf:"bytes,2,opt,name=new_socket_descriptor,json=newSocketDescriptor" json:"new_socket_descriptor,omitempty"`
	RemoteAddress        *AddressPort `protobuf:"bytes,3,opt,name=remote_address,json=remoteAddress" json:"remote_address,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*AcceptReply) Descriptor 

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

func (*AcceptReply) GetNewSocketDescriptor 

func (m *AcceptReply) GetNewSocketDescriptor() []byte

func (*AcceptReply) GetRemoteAddress 

func (m *AcceptReply) GetRemoteAddress() *AddressPort

func (*AcceptReply) ProtoMessage 

func (*AcceptReply) ProtoMessage()

func (*AcceptReply) Reset 

func (m *AcceptReply) Reset()

func (*AcceptReply) String 

func (m *AcceptReply) String() string

func (*AcceptReply) XXX_DiscardUnknown 

func (m *AcceptReply) XXX_DiscardUnknown()

func (*AcceptReply) XXX_Marshal 

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

func (*AcceptReply) XXX_Merge 

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

func (*AcceptReply) XXX_Size 

func (m *AcceptReply) XXX_Size() int

func (*AcceptReply) XXX_Unmarshal 

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

type AcceptRequest 

type AcceptRequest struct {
	SocketDescriptor     *string  `protobuf:"bytes,1,req,name=socket_descriptor,json=socketDescriptor" json:"socket_descriptor,omitempty"`
	TimeoutSeconds       *float64 `protobuf:"fixed64,2,opt,name=timeout_seconds,json=timeoutSeconds,def=-1" json:"timeout_seconds,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AcceptRequest) Descriptor 

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

func (*AcceptRequest) GetSocketDescriptor 

func (m *AcceptRequest) GetSocketDescriptor() string

func (*AcceptRequest) GetTimeoutSeconds 

func (m *AcceptRequest) GetTimeoutSeconds() float64

func (*AcceptRequest) ProtoMessage 

func (*AcceptRequest) ProtoMessage()

func (*AcceptRequest) Reset 

func (m *AcceptRequest) Reset()

func (*AcceptRequest) String 

func (m *AcceptRequest) String() string

func (*AcceptRequest) XXX_DiscardUnknown 

func (m *AcceptRequest) XXX_DiscardUnknown()

func (*AcceptRequest) XXX_Marshal 

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

func (*AcceptRequest) XXX_Merge 

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

func (*AcceptRequest) XXX_Size 

func (m *AcceptRequest) XXX_Size() int

func (*AcceptRequest) XXX_Unmarshal 

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

type AddressPort 

type AddressPort struct {
	Port                 *int32   `protobuf:"varint,1,req,name=port" json:"port,omitempty"`
	PackedAddress        []byte   `protobuf:"bytes,2,opt,name=packed_address,json=packedAddress" json:"packed_address,omitempty"`
	HostnameHint         *string  `protobuf:"bytes,3,opt,name=hostname_hint,json=hostnameHint" json:"hostname_hint,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AddressPort) Descriptor 

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

func (*AddressPort) GetHostnameHint 

func (m *AddressPort) GetHostnameHint() string

func (*AddressPort) GetPackedAddress 

func (m *AddressPort) GetPackedAddress() []byte

func (*AddressPort) GetPort 

func (m *AddressPort) GetPort() int32

func (*AddressPort) ProtoMessage 

func (*AddressPort) ProtoMessage()

func (*AddressPort) Reset 

func (m *AddressPort) Reset()

func (*AddressPort) String 

func (m *AddressPort) String() string

func (*AddressPort) XXX_DiscardUnknown 

func (m *AddressPort) XXX_DiscardUnknown()

func (*AddressPort) XXX_Marshal 

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

func (*AddressPort) XXX_Merge 

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

func (*AddressPort) XXX_Size 

func (m *AddressPort) XXX_Size() int

func (*AddressPort) XXX_Unmarshal 

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

type BindReply 

type BindReply struct {
	ProxyExternalIp      *AddressPort `protobuf:"bytes,1,opt,name=proxy_external_ip,json=proxyExternalIp" json:"proxy_external_ip,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*BindReply) Descriptor 

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

func (*BindReply) GetProxyExternalIp 

func (m *BindReply) GetProxyExternalIp() *AddressPort

func (*BindReply) ProtoMessage 

func (*BindReply) ProtoMessage()

func (*BindReply) Reset 

func (m *BindReply) Reset()

func (*BindReply) String 

func (m *BindReply) String() string

func (*BindReply) XXX_DiscardUnknown 

func (m *BindReply) XXX_DiscardUnknown()

func (*BindReply) XXX_Marshal 

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

func (*BindReply) XXX_Merge 

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

func (*BindReply) XXX_Size 

func (m *BindReply) XXX_Size() int

func (*BindReply) XXX_Unmarshal 

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

type BindRequest 

type BindRequest struct {
	SocketDescriptor     *string      `protobuf:"bytes,1,req,name=socket_descriptor,json=socketDescriptor" json:"socket_descriptor,omitempty"`
	ProxyExternalIp      *AddressPort `protobuf:"bytes,2,req,name=proxy_external_ip,json=proxyExternalIp" json:"proxy_external_ip,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*BindRequest) Descriptor 

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

func (*BindRequest) GetProxyExternalIp 

func (m *BindRequest) GetProxyExternalIp() *AddressPort

func (*BindRequest) GetSocketDescriptor 

func (m *BindRequest) GetSocketDescriptor() string

func (*BindRequest) ProtoMessage 

func (*BindRequest) ProtoMessage()

func (*BindRequest) Reset 

func (m *BindRequest) Reset()

func (*BindRequest) String 

func (m *BindRequest) String() string

func (*BindRequest) XXX_DiscardUnknown 

func (m *BindRequest) XXX_DiscardUnknown()

func (*BindRequest) XXX_Marshal 

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

func (*BindRequest) XXX_Merge 

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

func (*BindRequest) XXX_Size 

func (m *BindRequest) XXX_Size() int

func (*BindRequest) XXX_Unmarshal 

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

type CloseReply 

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

func (*CloseReply) Descriptor 

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

func (*CloseReply) ProtoMessage 

func (*CloseReply) ProtoMessage()

func (*CloseReply) Reset 

func (m *CloseReply) Reset()

func (*CloseReply) String 

func (m *CloseReply) String() string

func (*CloseReply) XXX_DiscardUnknown 

func (m *CloseReply) XXX_DiscardUnknown()

func (*CloseReply) XXX_Marshal 

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

func (*CloseReply) XXX_Merge 

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

func (*CloseReply) XXX_Size 

func (m *CloseReply) XXX_Size() int

func (*CloseReply) XXX_Unmarshal 

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

type CloseRequest 

type CloseRequest struct {
	SocketDescriptor     *string  `protobuf:"bytes,1,req,name=socket_descriptor,json=socketDescriptor" json:"socket_descriptor,omitempty"`
	SendOffset           *int64   `protobuf:"varint,2,opt,name=send_offset,json=sendOffset,def=-1" json:"send_offset,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CloseRequest) Descriptor 

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

func (*CloseRequest) GetSendOffset 

func (m *CloseRequest) GetSendOffset() int64

func (*CloseRequest) GetSocketDescriptor 

func (m *CloseRequest) GetSocketDescriptor() string

func (*CloseRequest) ProtoMessage 

func (*CloseRequest) ProtoMessage()

func (*CloseRequest) Reset 

func (m *CloseRequest) Reset()

func (*CloseRequest) String 

func (m *CloseRequest) String() string

func (*CloseRequest) XXX_DiscardUnknown 

func (m *CloseRequest) XXX_DiscardUnknown()

func (*CloseRequest) XXX_Marshal 

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

func (*CloseRequest) XXX_Merge 

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

func (*CloseRequest) XXX_Size 

func (m *CloseRequest) XXX_Size() int

func (*CloseRequest) XXX_Unmarshal 

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

type ConnectReply 

type ConnectReply struct {
	ProxyExternalIp              *AddressPort `protobuf:"bytes,1,opt,name=proxy_external_ip,json=proxyExternalIp" json:"proxy_external_ip,omitempty"`
	XXX_NoUnkeyedLiteral         struct{}     `json:"-"`
	proto.XXX_InternalExtensions `json:"-"`
	XXX_unrecognized             []byte `json:"-"`
	XXX_sizecache                int32  `json:"-"`
}

func (*ConnectReply) Descriptor 

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

func (*ConnectReply) ExtensionRangeArray 

func (*ConnectReply) ExtensionRangeArray() []proto.ExtensionRange

func (*ConnectReply) GetProxyExternalIp 

func (m *ConnectReply) GetProxyExternalIp() *AddressPort

func (*ConnectReply) ProtoMessage 

func (*ConnectReply) ProtoMessage()

func (*ConnectReply) Reset 

func (m *ConnectReply) Reset()

func (*ConnectReply) String 

func (m *ConnectReply) String() string

func (*ConnectReply) XXX_DiscardUnknown 

func (m *ConnectReply) XXX_DiscardUnknown()

func (*ConnectReply) XXX_Marshal 

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

func (*ConnectReply) XXX_Merge 

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

func (*ConnectReply) XXX_Size 

func (m *ConnectReply) XXX_Size() int

func (*ConnectReply) XXX_Unmarshal 

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

type ConnectRequest 

type ConnectRequest struct {
	SocketDescriptor     *string      `protobuf:"bytes,1,req,name=socket_descriptor,json=socketDescriptor" json:"socket_descriptor,omitempty"`
	RemoteIp             *AddressPort `protobuf:"bytes,2,req,name=remote_ip,json=remoteIp" json:"remote_ip,omitempty"`
	TimeoutSeconds       *float64     `protobuf:"fixed64,3,opt,name=timeout_seconds,json=timeoutSeconds,def=-1" json:"timeout_seconds,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*ConnectRequest) Descriptor 

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

func (*ConnectRequest) GetRemoteIp 

func (m *ConnectRequest) GetRemoteIp() *AddressPort

func (*ConnectRequest) GetSocketDescriptor 

func (m *ConnectRequest) GetSocketDescriptor() string

func (*ConnectRequest) GetTimeoutSeconds 

func (m *ConnectRequest) GetTimeoutSeconds() float64

func (*ConnectRequest) ProtoMessage 

func (*ConnectRequest) ProtoMessage()

func (*ConnectRequest) Reset 

func (m *ConnectRequest) Reset()

func (*ConnectRequest) String 

func (m *ConnectRequest) String() string

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 (dst *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 CreateSocketReply 

type CreateSocketReply struct {
	SocketDescriptor             *string      `protobuf:"bytes,1,opt,name=socket_descriptor,json=socketDescriptor" json:"socket_descriptor,omitempty"`
	ServerAddress                *AddressPort `protobuf:"bytes,3,opt,name=server_address,json=serverAddress" json:"server_address,omitempty"`
	ProxyExternalIp              *AddressPort `protobuf:"bytes,4,opt,name=proxy_external_ip,json=proxyExternalIp" json:"proxy_external_ip,omitempty"`
	XXX_NoUnkeyedLiteral         struct{}     `json:"-"`
	proto.XXX_InternalExtensions `json:"-"`
	XXX_unrecognized             []byte `json:"-"`
	XXX_sizecache                int32  `json:"-"`
}

func (*CreateSocketReply) Descriptor 

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

func (*CreateSocketReply) ExtensionRangeArray 

func (*CreateSocketReply) ExtensionRangeArray() []proto.ExtensionRange

func (*CreateSocketReply) GetProxyExternalIp 

func (m *CreateSocketReply) GetProxyExternalIp() *AddressPort

func (*CreateSocketReply) GetServerAddress 

func (m *CreateSocketReply) GetServerAddress() *AddressPort

func (*CreateSocketReply) GetSocketDescriptor 

func (m *CreateSocketReply) GetSocketDescriptor() string

func (*CreateSocketReply) ProtoMessage 

func (*CreateSocketReply) ProtoMessage()

func (*CreateSocketReply) Reset 

func (m *CreateSocketReply) Reset()

func (*CreateSocketReply) String 

func (m *CreateSocketReply) String() string

func (*CreateSocketReply) XXX_DiscardUnknown 

func (m *CreateSocketReply) XXX_DiscardUnknown()

func (*CreateSocketReply) XXX_Marshal 

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

func (*CreateSocketReply) XXX_Merge 

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

func (*CreateSocketReply) XXX_Size 

func (m *CreateSocketReply) XXX_Size() int

func (*CreateSocketReply) XXX_Unmarshal 

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

type CreateSocketRequest 

type CreateSocketRequest struct {
	Family               *CreateSocketRequest_SocketFamily   `protobuf:"varint,1,req,name=family,enum=appengine.CreateSocketRequest_SocketFamily" json:"family,omitempty"`
	Protocol             *CreateSocketRequest_SocketProtocol `protobuf:"varint,2,req,name=protocol,enum=appengine.CreateSocketRequest_SocketProtocol" json:"protocol,omitempty"`
	SocketOptions        []*SocketOption                     `protobuf:"bytes,3,rep,name=socket_options,json=socketOptions" json:"socket_options,omitempty"`
	ProxyExternalIp      *AddressPort                        `protobuf:"bytes,4,opt,name=proxy_external_ip,json=proxyExternalIp" json:"proxy_external_ip,omitempty"`
	ListenBacklog        *int32                              `protobuf:"varint,5,opt,name=listen_backlog,json=listenBacklog,def=0" json:"listen_backlog,omitempty"`
	RemoteIp             *AddressPort                        `protobuf:"bytes,6,opt,name=remote_ip,json=remoteIp" json:"remote_ip,omitempty"`
	AppId                *string                             `protobuf:"bytes,9,opt,name=app_id,json=appId" json:"app_id,omitempty"`
	ProjectId            *int64                              `protobuf:"varint,10,opt,name=project_id,json=projectId" json:"project_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                            `json:"-"`
	XXX_unrecognized     []byte                              `json:"-"`
	XXX_sizecache        int32                               `json:"-"`
}

func (*CreateSocketRequest) Descriptor 

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

func (*CreateSocketRequest) GetAppId 

func (m *CreateSocketRequest) GetAppId() string

func (*CreateSocketRequest) GetFamily 

func (m *CreateSocketRequest) GetFamily() CreateSocketRequest_SocketFamily

func (*CreateSocketRequest) GetListenBacklog 

func (m *CreateSocketRequest) GetListenBacklog() int32

func (*CreateSocketRequest) GetProjectId 

func (m *CreateSocketRequest) GetProjectId() int64

func (*CreateSocketRequest) GetProtocol 

func (m *CreateSocketRequest) GetProtocol() CreateSocketRequest_SocketProtocol

func (*CreateSocketRequest) GetProxyExternalIp 

func (m *CreateSocketRequest) GetProxyExternalIp() *AddressPort

func (*CreateSocketRequest) GetRemoteIp 

func (m *CreateSocketRequest) GetRemoteIp() *AddressPort

func (*CreateSocketRequest) GetSocketOptions 

func (m *CreateSocketRequest) GetSocketOptions() []*SocketOption

func (*CreateSocketRequest) ProtoMessage 

func (*CreateSocketRequest) ProtoMessage()

func (*CreateSocketRequest) Reset 

func (m *CreateSocketRequest) Reset()

func (*CreateSocketRequest) String 

func (m *CreateSocketRequest) String() string

func (*CreateSocketRequest) XXX_DiscardUnknown 

func (m *CreateSocketRequest) XXX_DiscardUnknown()

func (*CreateSocketRequest) XXX_Marshal 

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

func (*CreateSocketRequest) XXX_Merge 

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

func (*CreateSocketRequest) XXX_Size 

func (m *CreateSocketRequest) XXX_Size() int

func (*CreateSocketRequest) XXX_Unmarshal 

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

type CreateSocketRequest_SocketFamily 

type CreateSocketRequest_SocketFamily int32
const (
	CreateSocketRequest_IPv4 CreateSocketRequest_SocketFamily = 1
	CreateSocketRequest_IPv6 CreateSocketRequest_SocketFamily = 2
)

func (CreateSocketRequest_SocketFamily) Enum 

func (x CreateSocketRequest_SocketFamily) Enum() *CreateSocketRequest_SocketFamily

func (CreateSocketRequest_SocketFamily) EnumDescriptor 

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

func (CreateSocketRequest_SocketFamily) String 

func (x CreateSocketRequest_SocketFamily) String() string

func (*CreateSocketRequest_SocketFamily) UnmarshalJSON 

func (x *CreateSocketRequest_SocketFamily) UnmarshalJSON(data []byte) error

type CreateSocketRequest_SocketProtocol 

type CreateSocketRequest_SocketProtocol int32
const (
	CreateSocketRequest_TCP CreateSocketRequest_SocketProtocol = 1
	CreateSocketRequest_UDP CreateSocketRequest_SocketProtocol = 2
)

func (CreateSocketRequest_SocketProtocol) Enum 

func (x CreateSocketRequest_SocketProtocol) Enum() *CreateSocketRequest_SocketProtocol

func (CreateSocketRequest_SocketProtocol) EnumDescriptor 

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

func (CreateSocketRequest_SocketProtocol) String 

func (x CreateSocketRequest_SocketProtocol) String() string

func (*CreateSocketRequest_SocketProtocol) UnmarshalJSON 

func (x *CreateSocketRequest_SocketProtocol) UnmarshalJSON(data []byte) error

type GetPeerNameReply 

type GetPeerNameReply struct {
	PeerIp               *AddressPort `protobuf:"bytes,2,opt,name=peer_ip,json=peerIp" json:"peer_ip,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*GetPeerNameReply) Descriptor 

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

func (*GetPeerNameReply) GetPeerIp 

func (m *GetPeerNameReply) GetPeerIp() *AddressPort

func (*GetPeerNameReply) ProtoMessage 

func (*GetPeerNameReply) ProtoMessage()

func (*GetPeerNameReply) Reset 

func (m *GetPeerNameReply) Reset()

func (*GetPeerNameReply) String 

func (m *GetPeerNameReply) String() string

func (*GetPeerNameReply) XXX_DiscardUnknown 

func (m *GetPeerNameReply) XXX_DiscardUnknown()

func (*GetPeerNameReply) XXX_Marshal 

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

func (*GetPeerNameReply) XXX_Merge 

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

func (*GetPeerNameReply) XXX_Size 

func (m *GetPeerNameReply) XXX_Size() int

func (*GetPeerNameReply) XXX_Unmarshal 

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

type GetPeerNameRequest 

type GetPeerNameRequest struct {
	SocketDescriptor     *string  `protobuf:"bytes,1,req,name=socket_descriptor,json=socketDescriptor" json:"socket_descriptor,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetPeerNameRequest) Descriptor 

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

func (*GetPeerNameRequest) GetSocketDescriptor 

func (m *GetPeerNameRequest) GetSocketDescriptor() string

func (*GetPeerNameRequest) ProtoMessage 

func (*GetPeerNameRequest) ProtoMessage()

func (*GetPeerNameRequest) Reset 

func (m *GetPeerNameRequest) Reset()

func (*GetPeerNameRequest) String 

func (m *GetPeerNameRequest) String() string

func (*GetPeerNameRequest) XXX_DiscardUnknown 

func (m *GetPeerNameRequest) XXX_DiscardUnknown()

func (*GetPeerNameRequest) XXX_Marshal 

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

func (*GetPeerNameRequest) XXX_Merge 

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

func (*GetPeerNameRequest) XXX_Size 

func (m *GetPeerNameRequest) XXX_Size() int

func (*GetPeerNameRequest) XXX_Unmarshal 

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

type GetSocketNameReply 

type GetSocketNameReply struct {
	ProxyExternalIp      *AddressPort `protobuf:"bytes,2,opt,name=proxy_external_ip,json=proxyExternalIp" json:"proxy_external_ip,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*GetSocketNameReply) Descriptor 

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

func (*GetSocketNameReply) GetProxyExternalIp 

func (m *GetSocketNameReply) GetProxyExternalIp() *AddressPort

func (*GetSocketNameReply) ProtoMessage 

func (*GetSocketNameReply) ProtoMessage()

func (*GetSocketNameReply) Reset 

func (m *GetSocketNameReply) Reset()

func (*GetSocketNameReply) String 

func (m *GetSocketNameReply) String() string

func (*GetSocketNameReply) XXX_DiscardUnknown 

func (m *GetSocketNameReply) XXX_DiscardUnknown()

func (*GetSocketNameReply) XXX_Marshal 

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

func (*GetSocketNameReply) XXX_Merge 

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

func (*GetSocketNameReply) XXX_Size 

func (m *GetSocketNameReply) XXX_Size() int

func (*GetSocketNameReply) XXX_Unmarshal 

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

type GetSocketNameRequest 

type GetSocketNameRequest struct {
	SocketDescriptor     *string  `protobuf:"bytes,1,req,name=socket_descriptor,json=socketDescriptor" json:"socket_descriptor,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetSocketNameRequest) Descriptor 

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

func (*GetSocketNameRequest) GetSocketDescriptor 

func (m *GetSocketNameRequest) GetSocketDescriptor() string

func (*GetSocketNameRequest) ProtoMessage 

func (*GetSocketNameRequest) ProtoMessage()

func (*GetSocketNameRequest) Reset 

func (m *GetSocketNameRequest) Reset()

func (*GetSocketNameRequest) String 

func (m *GetSocketNameRequest) String() string

func (*GetSocketNameRequest) XXX_DiscardUnknown 

func (m *GetSocketNameRequest) XXX_DiscardUnknown()

func (*GetSocketNameRequest) XXX_Marshal 

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

func (*GetSocketNameRequest) XXX_Merge 

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

func (*GetSocketNameRequest) XXX_Size 

func (m *GetSocketNameRequest) XXX_Size() int

func (*GetSocketNameRequest) XXX_Unmarshal 

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

type GetSocketOptionsReply 

type GetSocketOptionsReply struct {
	Options              []*SocketOption `protobuf:"bytes,2,rep,name=options" json:"options,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*GetSocketOptionsReply) Descriptor 

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

func (*GetSocketOptionsReply) GetOptions 

func (m *GetSocketOptionsReply) GetOptions() []*SocketOption

func (*GetSocketOptionsReply) ProtoMessage 

func (*GetSocketOptionsReply) ProtoMessage()

func (*GetSocketOptionsReply) Reset 

func (m *GetSocketOptionsReply) Reset()

func (*GetSocketOptionsReply) String 

func (m *GetSocketOptionsReply) String() string

func (*GetSocketOptionsReply) XXX_DiscardUnknown 

func (m *GetSocketOptionsReply) XXX_DiscardUnknown()

func (*GetSocketOptionsReply) XXX_Marshal 

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

func (*GetSocketOptionsReply) XXX_Merge 

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

func (*GetSocketOptionsReply) XXX_Size 

func (m *GetSocketOptionsReply) XXX_Size() int

func (*GetSocketOptionsReply) XXX_Unmarshal 

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

type GetSocketOptionsRequest 

type GetSocketOptionsRequest struct {
	SocketDescriptor     *string         `protobuf:"bytes,1,req,name=socket_descriptor,json=socketDescriptor" json:"socket_descriptor,omitempty"`
	Options              []*SocketOption `protobuf:"bytes,2,rep,name=options" json:"options,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*GetSocketOptionsRequest) Descriptor 

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

func (*GetSocketOptionsRequest) GetOptions 

func (m *GetSocketOptionsRequest) GetOptions() []*SocketOption

func (*GetSocketOptionsRequest) GetSocketDescriptor 

func (m *GetSocketOptionsRequest) GetSocketDescriptor() string

func (*GetSocketOptionsRequest) ProtoMessage 

func (*GetSocketOptionsRequest) ProtoMessage()

func (*GetSocketOptionsRequest) Reset 

func (m *GetSocketOptionsRequest) Reset()

func (*GetSocketOptionsRequest) String 

func (m *GetSocketOptionsRequest) String() string

func (*GetSocketOptionsRequest) XXX_DiscardUnknown 

func (m *GetSocketOptionsRequest) XXX_DiscardUnknown()

func (*GetSocketOptionsRequest) XXX_Marshal 

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

func (*GetSocketOptionsRequest) XXX_Merge 

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

func (*GetSocketOptionsRequest) XXX_Size 

func (m *GetSocketOptionsRequest) XXX_Size() int

func (*GetSocketOptionsRequest) XXX_Unmarshal 

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

type ListenReply 

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

func (*ListenReply) Descriptor 

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

func (*ListenReply) ProtoMessage 

func (*ListenReply) ProtoMessage()

func (*ListenReply) Reset 

func (m *ListenReply) Reset()

func (*ListenReply) String 

func (m *ListenReply) String() string

func (*ListenReply) XXX_DiscardUnknown 

func (m *ListenReply) XXX_DiscardUnknown()

func (*ListenReply) XXX_Marshal 

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

func (*ListenReply) XXX_Merge 

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

func (*ListenReply) XXX_Size 

func (m *ListenReply) XXX_Size() int

func (*ListenReply) XXX_Unmarshal 

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

type ListenRequest 

type ListenRequest struct {
	SocketDescriptor     *string  `protobuf:"bytes,1,req,name=socket_descriptor,json=socketDescriptor" json:"socket_descriptor,omitempty"`
	Backlog              *int32   `protobuf:"varint,2,req,name=backlog" json:"backlog,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListenRequest) Descriptor 

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

func (*ListenRequest) GetBacklog 

func (m *ListenRequest) GetBacklog() int32

func (*ListenRequest) GetSocketDescriptor 

func (m *ListenRequest) GetSocketDescriptor() string

func (*ListenRequest) ProtoMessage 

func (*ListenRequest) ProtoMessage()

func (*ListenRequest) Reset 

func (m *ListenRequest) Reset()

func (*ListenRequest) String 

func (m *ListenRequest) String() string

func (*ListenRequest) XXX_DiscardUnknown 

func (m *ListenRequest) XXX_DiscardUnknown()

func (*ListenRequest) XXX_Marshal 

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

func (*ListenRequest) XXX_Merge 

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

func (*ListenRequest) XXX_Size 

func (m *ListenRequest) XXX_Size() int

func (*ListenRequest) XXX_Unmarshal 

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

type PollEvent 

type PollEvent struct {
	SocketDescriptor     *string  `protobuf:"bytes,1,req,name=socket_descriptor,json=socketDescriptor" json:"socket_descriptor,omitempty"`
	RequestedEvents      *int32   `protobuf:"varint,2,req,name=requested_events,json=requestedEvents" json:"requested_events,omitempty"`
	ObservedEvents       *int32   `protobuf:"varint,3,req,name=observed_events,json=observedEvents" json:"observed_events,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PollEvent) Descriptor 

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

func (*PollEvent) GetObservedEvents 

func (m *PollEvent) GetObservedEvents() int32

func (*PollEvent) GetRequestedEvents 

func (m *PollEvent) GetRequestedEvents() int32

func (*PollEvent) GetSocketDescriptor 

func (m *PollEvent) GetSocketDescriptor() string

func (*PollEvent) ProtoMessage 

func (*PollEvent) ProtoMessage()

func (*PollEvent) Reset 

func (m *PollEvent) Reset()

func (*PollEvent) String 

func (m *PollEvent) String() string

func (*PollEvent) XXX_DiscardUnknown 

func (m *PollEvent) XXX_DiscardUnknown()

func (*PollEvent) XXX_Marshal 

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

func (*PollEvent) XXX_Merge 

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

func (*PollEvent) XXX_Size 

func (m *PollEvent) XXX_Size() int

func (*PollEvent) XXX_Unmarshal 

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

type PollEvent_PollEventFlag 

type PollEvent_PollEventFlag int32
const (
	PollEvent_SOCKET_POLLNONE   PollEvent_PollEventFlag = 0
	PollEvent_SOCKET_POLLIN     PollEvent_PollEventFlag = 1
	PollEvent_SOCKET_POLLPRI    PollEvent_PollEventFlag = 2
	PollEvent_SOCKET_POLLOUT    PollEvent_PollEventFlag = 4
	PollEvent_SOCKET_POLLERR    PollEvent_PollEventFlag = 8
	PollEvent_SOCKET_POLLHUP    PollEvent_PollEventFlag = 16
	PollEvent_SOCKET_POLLNVAL   PollEvent_PollEventFlag = 32
	PollEvent_SOCKET_POLLRDNORM PollEvent_PollEventFlag = 64
	PollEvent_SOCKET_POLLRDBAND PollEvent_PollEventFlag = 128
	PollEvent_SOCKET_POLLWRNORM PollEvent_PollEventFlag = 256
	PollEvent_SOCKET_POLLWRBAND PollEvent_PollEventFlag = 512
	PollEvent_SOCKET_POLLMSG    PollEvent_PollEventFlag = 1024
	PollEvent_SOCKET_POLLREMOVE PollEvent_PollEventFlag = 4096
	PollEvent_SOCKET_POLLRDHUP  PollEvent_PollEventFlag = 8192
)

func (PollEvent_PollEventFlag) Enum 

func (x PollEvent_PollEventFlag) Enum() *PollEvent_PollEventFlag

func (PollEvent_PollEventFlag) EnumDescriptor 

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

func (PollEvent_PollEventFlag) String 

func (x PollEvent_PollEventFlag) String() string

func (*PollEvent_PollEventFlag) UnmarshalJSON 

func (x *PollEvent_PollEventFlag) UnmarshalJSON(data []byte) error

type PollReply 

type PollReply struct {
	Events               []*PollEvent `protobuf:"bytes,2,rep,name=events" json:"events,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*PollReply) Descriptor 

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

func (*PollReply) GetEvents 

func (m *PollReply) GetEvents() []*PollEvent

func (*PollReply) ProtoMessage 

func (*PollReply) ProtoMessage()

func (*PollReply) Reset 

func (m *PollReply) Reset()

func (*PollReply) String 

func (m *PollReply) String() string

func (*PollReply) XXX_DiscardUnknown 

func (m *PollReply) XXX_DiscardUnknown()

func (*PollReply) XXX_Marshal 

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

func (*PollReply) XXX_Merge 

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

func (*PollReply) XXX_Size 

func (m *PollReply) XXX_Size() int

func (*PollReply) XXX_Unmarshal 

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

type PollRequest 

type PollRequest struct {
	Events               []*PollEvent `protobuf:"bytes,1,rep,name=events" json:"events,omitempty"`
	TimeoutSeconds       *float64     `protobuf:"fixed64,2,opt,name=timeout_seconds,json=timeoutSeconds,def=-1" json:"timeout_seconds,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*PollRequest) Descriptor 

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

func (*PollRequest) GetEvents 

func (m *PollRequest) GetEvents() []*PollEvent

func (*PollRequest) GetTimeoutSeconds 

func (m *PollRequest) GetTimeoutSeconds() float64

func (*PollRequest) ProtoMessage 

func (*PollRequest) ProtoMessage()

func (*PollRequest) Reset 

func (m *PollRequest) Reset()

func (*PollRequest) String 

func (m *PollRequest) String() string

func (*PollRequest) XXX_DiscardUnknown 

func (m *PollRequest) XXX_DiscardUnknown()

func (*PollRequest) XXX_Marshal 

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

func (*PollRequest) XXX_Merge 

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

func (*PollRequest) XXX_Size 

func (m *PollRequest) XXX_Size() int

func (*PollRequest) XXX_Unmarshal 

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

type ReceiveReply 

type ReceiveReply struct {
	StreamOffset         *int64       `protobuf:"varint,2,opt,name=stream_offset,json=streamOffset" json:"stream_offset,omitempty"`
	Data                 []byte       `protobuf:"bytes,3,opt,name=data" json:"data,omitempty"`
	ReceivedFrom         *AddressPort `protobuf:"bytes,4,opt,name=received_from,json=receivedFrom" json:"received_from,omitempty"`
	BufferSize           *int32       `protobuf:"varint,5,opt,name=buffer_size,json=bufferSize" json:"buffer_size,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*ReceiveReply) Descriptor 

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

func (*ReceiveReply) GetBufferSize 

func (m *ReceiveReply) GetBufferSize() int32

func (*ReceiveReply) GetData 

func (m *ReceiveReply) GetData() []byte

func (*ReceiveReply) GetReceivedFrom 

func (m *ReceiveReply) GetReceivedFrom() *AddressPort

func (*ReceiveReply) GetStreamOffset 

func (m *ReceiveReply) GetStreamOffset() int64

func (*ReceiveReply) ProtoMessage 

func (*ReceiveReply) ProtoMessage()

func (*ReceiveReply) Reset 

func (m *ReceiveReply) Reset()

func (*ReceiveReply) String 

func (m *ReceiveReply) String() string

func (*ReceiveReply) XXX_DiscardUnknown 

func (m *ReceiveReply) XXX_DiscardUnknown()

func (*ReceiveReply) XXX_Marshal 

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

func (*ReceiveReply) XXX_Merge 

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

func (*ReceiveReply) XXX_Size 

func (m *ReceiveReply) XXX_Size() int

func (*ReceiveReply) XXX_Unmarshal 

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

type ReceiveRequest 

type ReceiveRequest struct {
	SocketDescriptor     *string  `protobuf:"bytes,1,req,name=socket_descriptor,json=socketDescriptor" json:"socket_descriptor,omitempty"`
	DataSize             *int32   `protobuf:"varint,2,req,name=data_size,json=dataSize" json:"data_size,omitempty"`
	Flags                *int32   `protobuf:"varint,3,opt,name=flags,def=0" json:"flags,omitempty"`
	TimeoutSeconds       *float64 `protobuf:"fixed64,5,opt,name=timeout_seconds,json=timeoutSeconds,def=-1" json:"timeout_seconds,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ReceiveRequest) Descriptor 

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

func (*ReceiveRequest) GetDataSize 

func (m *ReceiveRequest) GetDataSize() int32

func (*ReceiveRequest) GetFlags 

func (m *ReceiveRequest) GetFlags() int32

func (*ReceiveRequest) GetSocketDescriptor 

func (m *ReceiveRequest) GetSocketDescriptor() string

func (*ReceiveRequest) GetTimeoutSeconds 

func (m *ReceiveRequest) GetTimeoutSeconds() float64

func (*ReceiveRequest) ProtoMessage 

func (*ReceiveRequest) ProtoMessage()

func (*ReceiveRequest) Reset 

func (m *ReceiveRequest) Reset()

func (*ReceiveRequest) String 

func (m *ReceiveRequest) String() string

func (*ReceiveRequest) XXX_DiscardUnknown 

func (m *ReceiveRequest) XXX_DiscardUnknown()

func (*ReceiveRequest) XXX_Marshal 

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

func (*ReceiveRequest) XXX_Merge 

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

func (*ReceiveRequest) XXX_Size 

func (m *ReceiveRequest) XXX_Size() int

func (*ReceiveRequest) XXX_Unmarshal 

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

type ReceiveRequest_Flags 

type ReceiveRequest_Flags int32
const (
	ReceiveRequest_MSG_OOB  ReceiveRequest_Flags = 1
	ReceiveRequest_MSG_PEEK ReceiveRequest_Flags = 2
)

func (ReceiveRequest_Flags) Enum 

func (x ReceiveRequest_Flags) Enum() *ReceiveRequest_Flags

func (ReceiveRequest_Flags) EnumDescriptor 

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

func (ReceiveRequest_Flags) String 

func (x ReceiveRequest_Flags) String() string

func (*ReceiveRequest_Flags) UnmarshalJSON 

func (x *ReceiveRequest_Flags) UnmarshalJSON(data []byte) error

type RemoteSocketServiceError 

type RemoteSocketServiceError struct {
	SystemError          *int32   `protobuf:"varint,1,opt,name=system_error,json=systemError,def=0" json:"system_error,omitempty"`
	ErrorDetail          *string  `protobuf:"bytes,2,opt,name=error_detail,json=errorDetail" json:"error_detail,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RemoteSocketServiceError) Descriptor 

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

func (*RemoteSocketServiceError) GetErrorDetail 

func (m *RemoteSocketServiceError) GetErrorDetail() string

func (*RemoteSocketServiceError) GetSystemError 

func (m *RemoteSocketServiceError) GetSystemError() int32

func (*RemoteSocketServiceError) ProtoMessage 

func (*RemoteSocketServiceError) ProtoMessage()

func (*RemoteSocketServiceError) Reset 

func (m *RemoteSocketServiceError) Reset()

func (*RemoteSocketServiceError) String 

func (m *RemoteSocketServiceError) String() string

func (*RemoteSocketServiceError) XXX_DiscardUnknown 

func (m *RemoteSocketServiceError) XXX_DiscardUnknown()

func (*RemoteSocketServiceError) XXX_Marshal 

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

func (*RemoteSocketServiceError) XXX_Merge 

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

func (*RemoteSocketServiceError) XXX_Size 

func (m *RemoteSocketServiceError) XXX_Size() int

func (*RemoteSocketServiceError) XXX_Unmarshal 

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

type RemoteSocketServiceError_ErrorCode 

type RemoteSocketServiceError_ErrorCode int32
const (
	RemoteSocketServiceError_SYSTEM_ERROR      RemoteSocketServiceError_ErrorCode = 1
	RemoteSocketServiceError_GAI_ERROR         RemoteSocketServiceError_ErrorCode = 2
	RemoteSocketServiceError_FAILURE           RemoteSocketServiceError_ErrorCode = 4
	RemoteSocketServiceError_PERMISSION_DENIED RemoteSocketServiceError_ErrorCode = 5
	RemoteSocketServiceError_INVALID_REQUEST   RemoteSocketServiceError_ErrorCode = 6
	RemoteSocketServiceError_SOCKET_CLOSED     RemoteSocketServiceError_ErrorCode = 7
)

func (RemoteSocketServiceError_ErrorCode) Enum 

func (x RemoteSocketServiceError_ErrorCode) Enum() *RemoteSocketServiceError_ErrorCode

func (RemoteSocketServiceError_ErrorCode) EnumDescriptor 

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

func (RemoteSocketServiceError_ErrorCode) String 

func (x RemoteSocketServiceError_ErrorCode) String() string

func (*RemoteSocketServiceError_ErrorCode) UnmarshalJSON 

func (x *RemoteSocketServiceError_ErrorCode) UnmarshalJSON(data []byte) error

type RemoteSocketServiceError_SystemError 

type RemoteSocketServiceError_SystemError int32
const (
	RemoteSocketServiceError_SYS_SUCCESS         RemoteSocketServiceError_SystemError = 0
	RemoteSocketServiceError_SYS_EPERM           RemoteSocketServiceError_SystemError = 1
	RemoteSocketServiceError_SYS_ENOENT          RemoteSocketServiceError_SystemError = 2
	RemoteSocketServiceError_SYS_ESRCH           RemoteSocketServiceError_SystemError = 3
	RemoteSocketServiceError_SYS_EINTR           RemoteSocketServiceError_SystemError = 4
	RemoteSocketServiceError_SYS_EIO             RemoteSocketServiceError_SystemError = 5
	RemoteSocketServiceError_SYS_ENXIO           RemoteSocketServiceError_SystemError = 6
	RemoteSocketServiceError_SYS_E2BIG           RemoteSocketServiceError_SystemError = 7
	RemoteSocketServiceError_SYS_ENOEXEC         RemoteSocketServiceError_SystemError = 8
	RemoteSocketServiceError_SYS_EBADF           RemoteSocketServiceError_SystemError = 9
	RemoteSocketServiceError_SYS_ECHILD          RemoteSocketServiceError_SystemError = 10
	RemoteSocketServiceError_SYS_EAGAIN          RemoteSocketServiceError_SystemError = 11
	RemoteSocketServiceError_SYS_EWOULDBLOCK     RemoteSocketServiceError_SystemError = 11
	RemoteSocketServiceError_SYS_ENOMEM          RemoteSocketServiceError_SystemError = 12
	RemoteSocketServiceError_SYS_EACCES          RemoteSocketServiceError_SystemError = 13
	RemoteSocketServiceError_SYS_EFAULT          RemoteSocketServiceError_SystemError = 14
	RemoteSocketServiceError_SYS_ENOTBLK         RemoteSocketServiceError_SystemError = 15
	RemoteSocketServiceError_SYS_EBUSY           RemoteSocketServiceError_SystemError = 16
	RemoteSocketServiceError_SYS_EEXIST          RemoteSocketServiceError_SystemError = 17
	RemoteSocketServiceError_SYS_EXDEV           RemoteSocketServiceError_SystemError = 18
	RemoteSocketServiceError_SYS_ENODEV          RemoteSocketServiceError_SystemError = 19
	RemoteSocketServiceError_SYS_ENOTDIR         RemoteSocketServiceError_SystemError = 20
	RemoteSocketServiceError_SYS_EISDIR          RemoteSocketServiceError_SystemError = 21
	RemoteSocketServiceError_SYS_EINVAL          RemoteSocketServiceError_SystemError = 22
	RemoteSocketServiceError_SYS_ENFILE          RemoteSocketServiceError_SystemError = 23
	RemoteSocketServiceError_SYS_EMFILE          RemoteSocketServiceError_SystemError = 24
	RemoteSocketServiceError_SYS_ENOTTY          RemoteSocketServiceError_SystemError = 25
	RemoteSocketServiceError_SYS_ETXTBSY         RemoteSocketServiceError_SystemError = 26
	RemoteSocketServiceError_SYS_EFBIG           RemoteSocketServiceError_SystemError = 27
	RemoteSocketServiceError_SYS_ENOSPC          RemoteSocketServiceError_SystemError = 28
	RemoteSocketServiceError_SYS_ESPIPE          RemoteSocketServiceError_SystemError = 29
	RemoteSocketServiceError_SYS_EROFS           RemoteSocketServiceError_SystemError = 30
	RemoteSocketServiceError_SYS_EMLINK          RemoteSocketServiceError_SystemError = 31
	RemoteSocketServiceError_SYS_EPIPE           RemoteSocketServiceError_SystemError = 32
	RemoteSocketServiceError_SYS_EDOM            RemoteSocketServiceError_SystemError = 33
	RemoteSocketServiceError_SYS_ERANGE          RemoteSocketServiceError_SystemError = 34
	RemoteSocketServiceError_SYS_EDEADLK         RemoteSocketServiceError_SystemError = 35
	RemoteSocketServiceError_SYS_EDEADLOCK       RemoteSocketServiceError_SystemError = 35
	RemoteSocketServiceError_SYS_ENAMETOOLONG    RemoteSocketServiceError_SystemError = 36
	RemoteSocketServiceError_SYS_ENOLCK          RemoteSocketServiceError_SystemError = 37
	RemoteSocketServiceError_SYS_ENOSYS          RemoteSocketServiceError_SystemError = 38
	RemoteSocketServiceError_SYS_ENOTEMPTY       RemoteSocketServiceError_SystemError = 39
	RemoteSocketServiceError_SYS_ELOOP           RemoteSocketServiceError_SystemError = 40
	RemoteSocketServiceError_SYS_ENOMSG          RemoteSocketServiceError_SystemError = 42
	RemoteSocketServiceError_SYS_EIDRM           RemoteSocketServiceError_SystemError = 43
	RemoteSocketServiceError_SYS_ECHRNG          RemoteSocketServiceError_SystemError = 44
	RemoteSocketServiceError_SYS_EL2NSYNC        RemoteSocketServiceError_SystemError = 45
	RemoteSocketServiceError_SYS_EL3HLT          RemoteSocketServiceError_SystemError = 46
	RemoteSocketServiceError_SYS_EL3RST          RemoteSocketServiceError_SystemError = 47
	RemoteSocketServiceError_SYS_ELNRNG          RemoteSocketServiceError_SystemError = 48
	RemoteSocketServiceError_SYS_EUNATCH         RemoteSocketServiceError_SystemError = 49
	RemoteSocketServiceError_SYS_ENOCSI          RemoteSocketServiceError_SystemError = 50
	RemoteSocketServiceError_SYS_EL2HLT          RemoteSocketServiceError_SystemError = 51
	RemoteSocketServiceError_SYS_EBADE           RemoteSocketServiceError_SystemError = 52
	RemoteSocketServiceError_SYS_EBADR           RemoteSocketServiceError_SystemError = 53
	RemoteSocketServiceError_SYS_EXFULL          RemoteSocketServiceError_SystemError = 54
	RemoteSocketServiceError_SYS_ENOANO          RemoteSocketServiceError_SystemError = 55
	RemoteSocketServiceError_SYS_EBADRQC         RemoteSocketServiceError_SystemError = 56
	RemoteSocketServiceError_SYS_EBADSLT         RemoteSocketServiceError_SystemError = 57
	RemoteSocketServiceError_SYS_EBFONT          RemoteSocketServiceError_SystemError = 59
	RemoteSocketServiceError_SYS_ENOSTR          RemoteSocketServiceError_SystemError = 60
	RemoteSocketServiceError_SYS_ENODATA         RemoteSocketServiceError_SystemError = 61
	RemoteSocketServiceError_SYS_ETIME           RemoteSocketServiceError_SystemError = 62
	RemoteSocketServiceError_SYS_ENOSR           RemoteSocketServiceError_SystemError = 63
	RemoteSocketServiceError_SYS_ENONET          RemoteSocketServiceError_SystemError = 64
	RemoteSocketServiceError_SYS_ENOPKG          RemoteSocketServiceError_SystemError = 65
	RemoteSocketServiceError_SYS_EREMOTE         RemoteSocketServiceError_SystemError = 66
	RemoteSocketServiceError_SYS_ENOLINK         RemoteSocketServiceError_SystemError = 67
	RemoteSocketServiceError_SYS_EADV            RemoteSocketServiceError_SystemError = 68
	RemoteSocketServiceError_SYS_ESRMNT          RemoteSocketServiceError_SystemError = 69
	RemoteSocketServiceError_SYS_ECOMM           RemoteSocketServiceError_SystemError = 70
	RemoteSocketServiceError_SYS_EPROTO          RemoteSocketServiceError_SystemError = 71
	RemoteSocketServiceError_SYS_EMULTIHOP       RemoteSocketServiceError_SystemError = 72
	RemoteSocketServiceError_SYS_EDOTDOT         RemoteSocketServiceError_SystemError = 73
	RemoteSocketServiceError_SYS_EBADMSG         RemoteSocketServiceError_SystemError = 74
	RemoteSocketServiceError_SYS_EOVERFLOW       RemoteSocketServiceError_SystemError = 75
	RemoteSocketServiceError_SYS_ENOTUNIQ        RemoteSocketServiceError_SystemError = 76
	RemoteSocketServiceError_SYS_EBADFD          RemoteSocketServiceError_SystemError = 77
	RemoteSocketServiceError_SYS_EREMCHG         RemoteSocketServiceError_SystemError = 78
	RemoteSocketServiceError_SYS_ELIBACC         RemoteSocketServiceError_SystemError = 79
	RemoteSocketServiceError_SYS_ELIBBAD         RemoteSocketServiceError_SystemError = 80
	RemoteSocketServiceError_SYS_ELIBSCN         RemoteSocketServiceError_SystemError = 81
	RemoteSocketServiceError_SYS_ELIBMAX         RemoteSocketServiceError_SystemError = 82
	RemoteSocketServiceError_SYS_ELIBEXEC        RemoteSocketServiceError_SystemError = 83
	RemoteSocketServiceError_SYS_EILSEQ          RemoteSocketServiceError_SystemError = 84
	RemoteSocketServiceError_SYS_ERESTART        RemoteSocketServiceError_SystemError = 85
	RemoteSocketServiceError_SYS_ESTRPIPE        RemoteSocketServiceError_SystemError = 86
	RemoteSocketServiceError_SYS_EUSERS          RemoteSocketServiceError_SystemError = 87
	RemoteSocketServiceError_SYS_ENOTSOCK        RemoteSocketServiceError_SystemError = 88
	RemoteSocketServiceError_SYS_EDESTADDRREQ    RemoteSocketServiceError_SystemError = 89
	RemoteSocketServiceError_SYS_EMSGSIZE        RemoteSocketServiceError_SystemError = 90
	RemoteSocketServiceError_SYS_EPROTOTYPE      RemoteSocketServiceError_SystemError = 91
	RemoteSocketServiceError_SYS_ENOPROTOOPT     RemoteSocketServiceError_SystemError = 92
	RemoteSocketServiceError_SYS_EPROTONOSUPPORT RemoteSocketServiceError_SystemError = 93
	RemoteSocketServiceError_SYS_ESOCKTNOSUPPORT RemoteSocketServiceError_SystemError = 94
	RemoteSocketServiceError_SYS_EOPNOTSUPP      RemoteSocketServiceError_SystemError = 95
	RemoteSocketServiceError_SYS_ENOTSUP         RemoteSocketServiceError_SystemError = 95
	RemoteSocketServiceError_SYS_EPFNOSUPPORT    RemoteSocketServiceError_SystemError = 96
	RemoteSocketServiceError_SYS_EAFNOSUPPORT    RemoteSocketServiceError_SystemError = 97
	RemoteSocketServiceError_SYS_EADDRINUSE      RemoteSocketServiceError_SystemError = 98
	RemoteSocketServiceError_SYS_EADDRNOTAVAIL   RemoteSocketServiceError_SystemError = 99
	RemoteSocketServiceError_SYS_ENETDOWN        RemoteSocketServiceError_SystemError = 100
	RemoteSocketServiceError_SYS_ENETUNREACH     RemoteSocketServiceError_SystemError = 101
	RemoteSocketServiceError_SYS_ENETRESET       RemoteSocketServiceError_SystemError = 102
	RemoteSocketServiceError_SYS_ECONNABORTED    RemoteSocketServiceError_SystemError = 103
	RemoteSocketServiceError_SYS_ECONNRESET      RemoteSocketServiceError_SystemError = 104
	RemoteSocketServiceError_SYS_ENOBUFS         RemoteSocketServiceError_SystemError = 105
	RemoteSocketServiceError_SYS_EISCONN         RemoteSocketServiceError_SystemError = 106
	RemoteSocketServiceError_SYS_ENOTCONN        RemoteSocketServiceError_SystemError = 107
	RemoteSocketServiceError_SYS_ESHUTDOWN       RemoteSocketServiceError_SystemError = 108
	RemoteSocketServiceError_SYS_ETOOMANYREFS    RemoteSocketServiceError_SystemError = 109
	RemoteSocketServiceError_SYS_ETIMEDOUT       RemoteSocketServiceError_SystemError = 110
	RemoteSocketServiceError_SYS_ECONNREFUSED    RemoteSocketServiceError_SystemError = 111
	RemoteSocketServiceError_SYS_EHOSTDOWN       RemoteSocketServiceError_SystemError = 112
	RemoteSocketServiceError_SYS_EHOSTUNREACH    RemoteSocketServiceError_SystemError = 113
	RemoteSocketServiceError_SYS_EALREADY        RemoteSocketServiceError_SystemError = 114
	RemoteSocketServiceError_SYS_EINPROGRESS     RemoteSocketServiceError_SystemError = 115
	RemoteSocketServiceError_SYS_ESTALE          RemoteSocketServiceError_SystemError = 116
	RemoteSocketServiceError_SYS_EUCLEAN         RemoteSocketServiceError_SystemError = 117
	RemoteSocketServiceError_SYS_ENOTNAM         RemoteSocketServiceError_SystemError = 118
	RemoteSocketServiceError_SYS_ENAVAIL         RemoteSocketServiceError_SystemError = 119
	RemoteSocketServiceError_SYS_EISNAM          RemoteSocketServiceError_SystemError = 120
	RemoteSocketServiceError_SYS_EREMOTEIO       RemoteSocketServiceError_SystemError = 121
	RemoteSocketServiceError_SYS_EDQUOT          RemoteSocketServiceError_SystemError = 122
	RemoteSocketServiceError_SYS_ENOMEDIUM       RemoteSocketServiceError_SystemError = 123
	RemoteSocketServiceError_SYS_EMEDIUMTYPE     RemoteSocketServiceError_SystemError = 124
	RemoteSocketServiceError_SYS_ECANCELED       RemoteSocketServiceError_SystemError = 125
	RemoteSocketServiceError_SYS_ENOKEY          RemoteSocketServiceError_SystemError = 126
	RemoteSocketServiceError_SYS_EKEYEXPIRED     RemoteSocketServiceError_SystemError = 127
	RemoteSocketServiceError_SYS_EKEYREVOKED     RemoteSocketServiceError_SystemError = 128
	RemoteSocketServiceError_SYS_EKEYREJECTED    RemoteSocketServiceError_SystemError = 129
	RemoteSocketServiceError_SYS_EOWNERDEAD      RemoteSocketServiceError_SystemError = 130
	RemoteSocketServiceError_SYS_ENOTRECOVERABLE RemoteSocketServiceError_SystemError = 131
	RemoteSocketServiceError_SYS_ERFKILL         RemoteSocketServiceError_SystemError = 132
)

func (RemoteSocketServiceError_SystemError) Enum 

func (x RemoteSocketServiceError_SystemError) Enum() *RemoteSocketServiceError_SystemError

func (RemoteSocketServiceError_SystemError) EnumDescriptor 

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

func (RemoteSocketServiceError_SystemError) String 

func (x RemoteSocketServiceError_SystemError) String() string

func (*RemoteSocketServiceError_SystemError) UnmarshalJSON 

func (x *RemoteSocketServiceError_SystemError) UnmarshalJSON(data []byte) error

type ResolveReply 

type ResolveReply struct {
	PackedAddress        [][]byte `protobuf:"bytes,2,rep,name=packed_address,json=packedAddress" json:"packed_address,omitempty"`
	CanonicalName        *string  `protobuf:"bytes,3,opt,name=canonical_name,json=canonicalName" json:"canonical_name,omitempty"`
	Aliases              []string `protobuf:"bytes,4,rep,name=aliases" json:"aliases,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ResolveReply) Descriptor 

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

func (*ResolveReply) GetAliases 

func (m *ResolveReply) GetAliases() []string

func (*ResolveReply) GetCanonicalName 

func (m *ResolveReply) GetCanonicalName() string

func (*ResolveReply) GetPackedAddress 

func (m *ResolveReply) GetPackedAddress() [][]byte

func (*ResolveReply) ProtoMessage 

func (*ResolveReply) ProtoMessage()

func (*ResolveReply) Reset 

func (m *ResolveReply) Reset()

func (*ResolveReply) String 

func (m *ResolveReply) String() string

func (*ResolveReply) XXX_DiscardUnknown 

func (m *ResolveReply) XXX_DiscardUnknown()

func (*ResolveReply) XXX_Marshal 

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

func (*ResolveReply) XXX_Merge 

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

func (*ResolveReply) XXX_Size 

func (m *ResolveReply) XXX_Size() int

func (*ResolveReply) XXX_Unmarshal 

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

type ResolveReply_ErrorCode 

type ResolveReply_ErrorCode int32
const (
	ResolveReply_SOCKET_EAI_ADDRFAMILY ResolveReply_ErrorCode = 1
	ResolveReply_SOCKET_EAI_AGAIN      ResolveReply_ErrorCode = 2
	ResolveReply_SOCKET_EAI_BADFLAGS   ResolveReply_ErrorCode = 3
	ResolveReply_SOCKET_EAI_FAIL       ResolveReply_ErrorCode = 4
	ResolveReply_SOCKET_EAI_FAMILY     ResolveReply_ErrorCode = 5
	ResolveReply_SOCKET_EAI_MEMORY     ResolveReply_ErrorCode = 6
	ResolveReply_SOCKET_EAI_NODATA     ResolveReply_ErrorCode = 7
	ResolveReply_SOCKET_EAI_NONAME     ResolveReply_ErrorCode = 8
	ResolveReply_SOCKET_EAI_SERVICE    ResolveReply_ErrorCode = 9
	ResolveReply_SOCKET_EAI_SOCKTYPE   ResolveReply_ErrorCode = 10
	ResolveReply_SOCKET_EAI_SYSTEM     ResolveReply_ErrorCode = 11
	ResolveReply_SOCKET_EAI_BADHINTS   ResolveReply_ErrorCode = 12
	ResolveReply_SOCKET_EAI_PROTOCOL   ResolveReply_ErrorCode = 13
	ResolveReply_SOCKET_EAI_OVERFLOW   ResolveReply_ErrorCode = 14
	ResolveReply_SOCKET_EAI_MAX        ResolveReply_ErrorCode = 15
)

func (ResolveReply_ErrorCode) Enum 

func (x ResolveReply_ErrorCode) Enum() *ResolveReply_ErrorCode

func (ResolveReply_ErrorCode) EnumDescriptor 

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

func (ResolveReply_ErrorCode) String 

func (x ResolveReply_ErrorCode) String() string

func (*ResolveReply_ErrorCode) UnmarshalJSON 

func (x *ResolveReply_ErrorCode) UnmarshalJSON(data []byte) error

type ResolveRequest 

type ResolveRequest struct {
	Name                 *string                            `protobuf:"bytes,1,req,name=name" json:"name,omitempty"`
	AddressFamilies      []CreateSocketRequest_SocketFamily `` /* 148-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                           `json:"-"`
	XXX_unrecognized     []byte                             `json:"-"`
	XXX_sizecache        int32                              `json:"-"`
}

func (*ResolveRequest) Descriptor 

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

func (*ResolveRequest) GetAddressFamilies 

func (m *ResolveRequest) GetAddressFamilies() []CreateSocketRequest_SocketFamily

func (*ResolveRequest) GetName 

func (m *ResolveRequest) GetName() string

func (*ResolveRequest) ProtoMessage 

func (*ResolveRequest) ProtoMessage()

func (*ResolveRequest) Reset 

func (m *ResolveRequest) Reset()

func (*ResolveRequest) String 

func (m *ResolveRequest) String() string

func (*ResolveRequest) XXX_DiscardUnknown 

func (m *ResolveRequest) XXX_DiscardUnknown()

func (*ResolveRequest) XXX_Marshal 

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

func (*ResolveRequest) XXX_Merge 

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

func (*ResolveRequest) XXX_Size 

func (m *ResolveRequest) XXX_Size() int

func (*ResolveRequest) XXX_Unmarshal 

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

type SendReply 

type SendReply struct {
	DataSent             *int32   `protobuf:"varint,1,opt,name=data_sent,json=dataSent" json:"data_sent,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SendReply) Descriptor 

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

func (*SendReply) GetDataSent 

func (m *SendReply) GetDataSent() int32

func (*SendReply) ProtoMessage 

func (*SendReply) ProtoMessage()

func (*SendReply) Reset 

func (m *SendReply) Reset()

func (*SendReply) String 

func (m *SendReply) String() string

func (*SendReply) XXX_DiscardUnknown 

func (m *SendReply) XXX_DiscardUnknown()

func (*SendReply) XXX_Marshal 

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

func (*SendReply) XXX_Merge 

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

func (*SendReply) XXX_Size 

func (m *SendReply) XXX_Size() int

func (*SendReply) XXX_Unmarshal 

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

type SendRequest 

type SendRequest struct {
	SocketDescriptor     *string      `protobuf:"bytes,1,req,name=socket_descriptor,json=socketDescriptor" json:"socket_descriptor,omitempty"`
	Data                 []byte       `protobuf:"bytes,2,req,name=data" json:"data,omitempty"`
	StreamOffset         *int64       `protobuf:"varint,3,req,name=stream_offset,json=streamOffset" json:"stream_offset,omitempty"`
	Flags                *int32       `protobuf:"varint,4,opt,name=flags,def=0" json:"flags,omitempty"`
	SendTo               *AddressPort `protobuf:"bytes,5,opt,name=send_to,json=sendTo" json:"send_to,omitempty"`
	TimeoutSeconds       *float64     `protobuf:"fixed64,6,opt,name=timeout_seconds,json=timeoutSeconds,def=-1" json:"timeout_seconds,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*SendRequest) Descriptor 

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

func (*SendRequest) GetData 

func (m *SendRequest) GetData() []byte

func (*SendRequest) GetFlags 

func (m *SendRequest) GetFlags() int32

func (*SendRequest) GetSendTo 

func (m *SendRequest) GetSendTo() *AddressPort

func (*SendRequest) GetSocketDescriptor 

func (m *SendRequest) GetSocketDescriptor() string

func (*SendRequest) GetStreamOffset 

func (m *SendRequest) GetStreamOffset() int64

func (*SendRequest) GetTimeoutSeconds 

func (m *SendRequest) GetTimeoutSeconds() float64

func (*SendRequest) ProtoMessage 

func (*SendRequest) ProtoMessage()

func (*SendRequest) Reset 

func (m *SendRequest) Reset()

func (*SendRequest) String 

func (m *SendRequest) String() string

func (*SendRequest) XXX_DiscardUnknown 

func (m *SendRequest) XXX_DiscardUnknown()

func (*SendRequest) XXX_Marshal 

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

func (*SendRequest) XXX_Merge 

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

func (*SendRequest) XXX_Size 

func (m *SendRequest) XXX_Size() int

func (*SendRequest) XXX_Unmarshal 

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

type SetSocketOptionsReply 

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

func (*SetSocketOptionsReply) Descriptor 

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

func (*SetSocketOptionsReply) ProtoMessage 

func (*SetSocketOptionsReply) ProtoMessage()

func (*SetSocketOptionsReply) Reset 

func (m *SetSocketOptionsReply) Reset()

func (*SetSocketOptionsReply) String 

func (m *SetSocketOptionsReply) String() string

func (*SetSocketOptionsReply) XXX_DiscardUnknown 

func (m *SetSocketOptionsReply) XXX_DiscardUnknown()

func (*SetSocketOptionsReply) XXX_Marshal 

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

func (*SetSocketOptionsReply) XXX_Merge 

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

func (*SetSocketOptionsReply) XXX_Size 

func (m *SetSocketOptionsReply) XXX_Size() int

func (*SetSocketOptionsReply) XXX_Unmarshal 

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

type SetSocketOptionsRequest 

type SetSocketOptionsRequest struct {
	SocketDescriptor     *string         `protobuf:"bytes,1,req,name=socket_descriptor,json=socketDescriptor" json:"socket_descriptor,omitempty"`
	Options              []*SocketOption `protobuf:"bytes,2,rep,name=options" json:"options,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*SetSocketOptionsRequest) Descriptor 

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

func (*SetSocketOptionsRequest) GetOptions 

func (m *SetSocketOptionsRequest) GetOptions() []*SocketOption

func (*SetSocketOptionsRequest) GetSocketDescriptor 

func (m *SetSocketOptionsRequest) GetSocketDescriptor() string

func (*SetSocketOptionsRequest) ProtoMessage 

func (*SetSocketOptionsRequest) ProtoMessage()

func (*SetSocketOptionsRequest) Reset 

func (m *SetSocketOptionsRequest) Reset()

func (*SetSocketOptionsRequest) String 

func (m *SetSocketOptionsRequest) String() string

func (*SetSocketOptionsRequest) XXX_DiscardUnknown 

func (m *SetSocketOptionsRequest) XXX_DiscardUnknown()

func (*SetSocketOptionsRequest) XXX_Marshal 

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

func (*SetSocketOptionsRequest) XXX_Merge 

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

func (*SetSocketOptionsRequest) XXX_Size 

func (m *SetSocketOptionsRequest) XXX_Size() int

func (*SetSocketOptionsRequest) XXX_Unmarshal 

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

type ShutDownReply 

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

func (*ShutDownReply) Descriptor 

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

func (*ShutDownReply) ProtoMessage 

func (*ShutDownReply) ProtoMessage()

func (*ShutDownReply) Reset 

func (m *ShutDownReply) Reset()

func (*ShutDownReply) String 

func (m *ShutDownReply) String() string

func (*ShutDownReply) XXX_DiscardUnknown 

func (m *ShutDownReply) XXX_DiscardUnknown()

func (*ShutDownReply) XXX_Marshal 

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

func (*ShutDownReply) XXX_Merge 

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

func (*ShutDownReply) XXX_Size 

func (m *ShutDownReply) XXX_Size() int

func (*ShutDownReply) XXX_Unmarshal 

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

type ShutDownRequest 

type ShutDownRequest struct {
	SocketDescriptor     *string              `protobuf:"bytes,1,req,name=socket_descriptor,json=socketDescriptor" json:"socket_descriptor,omitempty"`
	How                  *ShutDownRequest_How `protobuf:"varint,2,req,name=how,enum=appengine.ShutDownRequest_How" json:"how,omitempty"`
	SendOffset           *int64               `protobuf:"varint,3,req,name=send_offset,json=sendOffset" json:"send_offset,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*ShutDownRequest) Descriptor 

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

func (*ShutDownRequest) GetHow 

func (m *ShutDownRequest) GetHow() ShutDownRequest_How

func (*ShutDownRequest) GetSendOffset 

func (m *ShutDownRequest) GetSendOffset() int64

func (*ShutDownRequest) GetSocketDescriptor 

func (m *ShutDownRequest) GetSocketDescriptor() string

func (*ShutDownRequest) ProtoMessage 

func (*ShutDownRequest) ProtoMessage()

func (*ShutDownRequest) Reset 

func (m *ShutDownRequest) Reset()

func (*ShutDownRequest) String 

func (m *ShutDownRequest) String() string

func (*ShutDownRequest) XXX_DiscardUnknown 

func (m *ShutDownRequest) XXX_DiscardUnknown()

func (*ShutDownRequest) XXX_Marshal 

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

func (*ShutDownRequest) XXX_Merge 

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

func (*ShutDownRequest) XXX_Size 

func (m *ShutDownRequest) XXX_Size() int

func (*ShutDownRequest) XXX_Unmarshal 

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

type ShutDownRequest_How 

type ShutDownRequest_How int32
const (
	ShutDownRequest_SOCKET_SHUT_RD   ShutDownRequest_How = 1
	ShutDownRequest_SOCKET_SHUT_WR   ShutDownRequest_How = 2
	ShutDownRequest_SOCKET_SHUT_RDWR ShutDownRequest_How = 3
)

func (ShutDownRequest_How) Enum 

func (x ShutDownRequest_How) Enum() *ShutDownRequest_How

func (ShutDownRequest_How) EnumDescriptor 

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

func (ShutDownRequest_How) String 

func (x ShutDownRequest_How) String() string

func (*ShutDownRequest_How) UnmarshalJSON 

func (x *ShutDownRequest_How) UnmarshalJSON(data []byte) error

type SocketOption 

type SocketOption struct {
	Level                *SocketOption_SocketOptionLevel `protobuf:"varint,1,req,name=level,enum=appengine.SocketOption_SocketOptionLevel" json:"level,omitempty"`
	Option               *SocketOption_SocketOptionName  `protobuf:"varint,2,req,name=option,enum=appengine.SocketOption_SocketOptionName" json:"option,omitempty"`
	Value                []byte                          `protobuf:"bytes,3,req,name=value" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                        `json:"-"`
	XXX_unrecognized     []byte                          `json:"-"`
	XXX_sizecache        int32                           `json:"-"`
}

func (*SocketOption) Descriptor 

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

func (*SocketOption) GetLevel 

func (m *SocketOption) GetLevel() SocketOption_SocketOptionLevel

func (*SocketOption) GetOption 

func (m *SocketOption) GetOption() SocketOption_SocketOptionName

func (*SocketOption) GetValue 

func (m *SocketOption) GetValue() []byte

func (*SocketOption) ProtoMessage 

func (*SocketOption) ProtoMessage()

func (*SocketOption) Reset 

func (m *SocketOption) Reset()

func (*SocketOption) String 

func (m *SocketOption) String() string

func (*SocketOption) XXX_DiscardUnknown 

func (m *SocketOption) XXX_DiscardUnknown()

func (*SocketOption) XXX_Marshal 

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

func (*SocketOption) XXX_Merge 

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

func (*SocketOption) XXX_Size 

func (m *SocketOption) XXX_Size() int

func (*SocketOption) XXX_Unmarshal 

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

type SocketOption_SocketOptionLevel 

type SocketOption_SocketOptionLevel int32
const (
	SocketOption_SOCKET_SOL_IP     SocketOption_SocketOptionLevel = 0
	SocketOption_SOCKET_SOL_SOCKET SocketOption_SocketOptionLevel = 1
	SocketOption_SOCKET_SOL_TCP    SocketOption_SocketOptionLevel = 6
	SocketOption_SOCKET_SOL_UDP    SocketOption_SocketOptionLevel = 17
)

func (SocketOption_SocketOptionLevel) Enum 

func (x SocketOption_SocketOptionLevel) Enum() *SocketOption_SocketOptionLevel

func (SocketOption_SocketOptionLevel) EnumDescriptor 

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

func (SocketOption_SocketOptionLevel) String 

func (x SocketOption_SocketOptionLevel) String() string

func (*SocketOption_SocketOptionLevel) UnmarshalJSON 

func (x *SocketOption_SocketOptionLevel) UnmarshalJSON(data []byte) error

type SocketOption_SocketOptionName 

type SocketOption_SocketOptionName int32
const (
	SocketOption_SOCKET_SO_DEBUG         SocketOption_SocketOptionName = 1
	SocketOption_SOCKET_SO_REUSEADDR     SocketOption_SocketOptionName = 2
	SocketOption_SOCKET_SO_TYPE          SocketOption_SocketOptionName = 3
	SocketOption_SOCKET_SO_ERROR         SocketOption_SocketOptionName = 4
	SocketOption_SOCKET_SO_DONTROUTE     SocketOption_SocketOptionName = 5
	SocketOption_SOCKET_SO_BROADCAST     SocketOption_SocketOptionName = 6
	SocketOption_SOCKET_SO_SNDBUF        SocketOption_SocketOptionName = 7
	SocketOption_SOCKET_SO_RCVBUF        SocketOption_SocketOptionName = 8
	SocketOption_SOCKET_SO_KEEPALIVE     SocketOption_SocketOptionName = 9
	SocketOption_SOCKET_SO_OOBINLINE     SocketOption_SocketOptionName = 10
	SocketOption_SOCKET_SO_LINGER        SocketOption_SocketOptionName = 13
	SocketOption_SOCKET_SO_RCVTIMEO      SocketOption_SocketOptionName = 20
	SocketOption_SOCKET_SO_SNDTIMEO      SocketOption_SocketOptionName = 21
	SocketOption_SOCKET_IP_TOS           SocketOption_SocketOptionName = 1
	SocketOption_SOCKET_IP_TTL           SocketOption_SocketOptionName = 2
	SocketOption_SOCKET_IP_HDRINCL       SocketOption_SocketOptionName = 3
	SocketOption_SOCKET_IP_OPTIONS       SocketOption_SocketOptionName = 4
	SocketOption_SOCKET_TCP_NODELAY      SocketOption_SocketOptionName = 1
	SocketOption_SOCKET_TCP_MAXSEG       SocketOption_SocketOptionName = 2
	SocketOption_SOCKET_TCP_CORK         SocketOption_SocketOptionName = 3
	SocketOption_SOCKET_TCP_KEEPIDLE     SocketOption_SocketOptionName = 4
	SocketOption_SOCKET_TCP_KEEPINTVL    SocketOption_SocketOptionName = 5
	SocketOption_SOCKET_TCP_KEEPCNT      SocketOption_SocketOptionName = 6
	SocketOption_SOCKET_TCP_SYNCNT       SocketOption_SocketOptionName = 7
	SocketOption_SOCKET_TCP_LINGER2      SocketOption_SocketOptionName = 8
	SocketOption_SOCKET_TCP_DEFER_ACCEPT SocketOption_SocketOptionName = 9
	SocketOption_SOCKET_TCP_WINDOW_CLAMP SocketOption_SocketOptionName = 10
	SocketOption_SOCKET_TCP_INFO         SocketOption_SocketOptionName = 11
	SocketOption_SOCKET_TCP_QUICKACK     SocketOption_SocketOptionName = 12
)

func (SocketOption_SocketOptionName) Enum 

func (x SocketOption_SocketOptionName) Enum() *SocketOption_SocketOptionName

func (SocketOption_SocketOptionName) EnumDescriptor 

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

func (SocketOption_SocketOptionName) String 

func (x SocketOption_SocketOptionName) String() string

func (*SocketOption_SocketOptionName) UnmarshalJSON 

func (x *SocketOption_SocketOptionName) UnmarshalJSON(data []byte) 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.