server

package
v0.0.0-...-2f74b22 Latest Latest
Warning

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

 Go to latest Published: Dec 28, 2019 License: MIT Imports: 13 Imported by: 1

Documentation

Index

Constants

View Source 
const EmptyString string = ""

EmptyString a empty string

View Source 
const ReadBufferSize int = 1024

Variables

View Source 
var CacheOptions_name = map[int32]string{
	0: "AddToRoomCache",
	1: "RemoveFromRoomCache",
}
View Source 
var CacheOptions_value = map[string]int32{
	"AddToRoomCache":      0,
	"RemoveFromRoomCache": 1,
}
View Source 
var MessageType_name = map[int32]string{
	0:  "JoinLobby",
	1:  "LeaveLobby",
	2:  "CreateRoom",
	3:  "JoinRoom",
	4:  "JoinOrCreateRoom",
	5:  "LeaveRoom",
	6:  "RPC",
	7:  "Instantiation",
	8:  "ViewSync",
	9:  "CustomEvent",
	10: "SubscribeMsgChannels",
	11: "UnSubscribeMsgChannels",
}
View Source 
var MessageType_value = map[string]int32{
	"JoinLobby":              0,
	"LeaveLobby":             1,
	"CreateRoom":             2,
	"JoinRoom":               3,
	"JoinOrCreateRoom":       4,
	"LeaveRoom":              5,
	"RPC":                    6,
	"Instantiation":          7,
	"ViewSync":               8,
	"CustomEvent":            9,
	"SubscribeMsgChannels":   10,
	"UnSubscribeMsgChannels": 11,
}
View Source 
var RPCTarget_name = map[int32]string{
	0: "All",
	1: "Others",
}
View Source 
var RPCTarget_value = map[string]int32{
	"All":    0,
	"Others": 1,
}
View Source 
var ReceiveMessageType_name = map[int32]string{
	0: "ResponseSocketStatus",
	1: "ResponseOperation",
	2: "Forward",
}
View Source 
var ReceiveMessageType_value = map[string]int32{
	"ResponseSocketStatus": 0,
	"ResponseOperation":    1,
	"Forward":              2,
}
View Source 
var SocketStatus_name = map[int32]string{
	0: "Disconnected",
	1: "Connected",
}
View Source 
var SocketStatus_value = map[string]int32{
	"Disconnected": 0,
	"Connected":    1,
}

Functions

func Listen 

func Listen(network, address string)

func ListenU 

func ListenU(network, address string)

Types

type CacheOptions 

type CacheOptions int32
const (
	CacheOptions_AddToRoomCache      CacheOptions = 0
	CacheOptions_RemoveFromRoomCache CacheOptions = 1
)

func (CacheOptions) EnumDescriptor 

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

func (CacheOptions) String 

func (x CacheOptions) String() string

type CommonOptions 

type CommonOptions struct {
	SendToChannelIds     []uint32     `protobuf:"varint,1,rep,packed,name=sendToChannelIds,proto3" json:"sendToChannelIds,omitempty"`
	CacheOptions         CacheOptions `protobuf:"varint,2,opt,name=cacheOptions,proto3,enum=server.CacheOptions" json:"cacheOptions,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*CommonOptions) Descriptor 

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

func (*CommonOptions) GetCacheOptions 

func (m *CommonOptions) GetCacheOptions() CacheOptions

func (*CommonOptions) GetSendToChannelIds 

func (m *CommonOptions) GetSendToChannelIds() []uint32

func (*CommonOptions) ProtoMessage 

func (*CommonOptions) ProtoMessage()

func (*CommonOptions) Reset 

func (m *CommonOptions) Reset()

func (*CommonOptions) String 

func (m *CommonOptions) String() string

func (*CommonOptions) XXX_DiscardUnknown 

func (m *CommonOptions) XXX_DiscardUnknown()

func (*CommonOptions) XXX_Marshal 

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

func (*CommonOptions) XXX_Merge 

func (m *CommonOptions) XXX_Merge(src proto.Message)

func (*CommonOptions) XXX_Size 

func (m *CommonOptions) XXX_Size() int

func (*CommonOptions) XXX_Unmarshal 

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

type CreateRoomParams 

type CreateRoomParams struct {
	RoomId               string   `protobuf:"bytes,1,opt,name=roomId,proto3" json:"roomId,omitempty"`
	MaxNumber            uint32   `protobuf:"varint,2,opt,name=maxNumber,proto3" json:"maxNumber,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateRoomParams) Descriptor 

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

func (*CreateRoomParams) GetMaxNumber 

func (m *CreateRoomParams) GetMaxNumber() uint32

func (*CreateRoomParams) GetRoomId 

func (m *CreateRoomParams) GetRoomId() string

func (*CreateRoomParams) ProtoMessage 

func (*CreateRoomParams) ProtoMessage()

func (*CreateRoomParams) Reset 

func (m *CreateRoomParams) Reset()

func (*CreateRoomParams) String 

func (m *CreateRoomParams) String() string

func (*CreateRoomParams) XXX_DiscardUnknown 

func (m *CreateRoomParams) XXX_DiscardUnknown()

func (*CreateRoomParams) XXX_Marshal 

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

func (*CreateRoomParams) XXX_Merge 

func (m *CreateRoomParams) XXX_Merge(src proto.Message)

func (*CreateRoomParams) XXX_Size 

func (m *CreateRoomParams) XXX_Size() int

func (*CreateRoomParams) XXX_Unmarshal 

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

type CreateRoomResponseParams 

type CreateRoomResponseParams struct {
	ReturnValue          uint32   `protobuf:"varint,1,opt,name=returnValue,proto3" json:"returnValue,omitempty"`
	Message              string   `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	PeerId               uint32   `protobuf:"varint,3,opt,name=peerId,proto3" json:"peerId,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateRoomResponseParams) Descriptor 

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

func (*CreateRoomResponseParams) GetMessage 

func (m *CreateRoomResponseParams) GetMessage() string

func (*CreateRoomResponseParams) GetPeerId 

func (m *CreateRoomResponseParams) GetPeerId() uint32

func (*CreateRoomResponseParams) GetReturnValue 

func (m *CreateRoomResponseParams) GetReturnValue() uint32

func (*CreateRoomResponseParams) ProtoMessage 

func (*CreateRoomResponseParams) ProtoMessage()

func (*CreateRoomResponseParams) Reset 

func (m *CreateRoomResponseParams) Reset()

func (*CreateRoomResponseParams) String 

func (m *CreateRoomResponseParams) String() string

func (*CreateRoomResponseParams) XXX_DiscardUnknown 

func (m *CreateRoomResponseParams) XXX_DiscardUnknown()

func (*CreateRoomResponseParams) XXX_Marshal 

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

func (*CreateRoomResponseParams) XXX_Merge 

func (m *CreateRoomResponseParams) XXX_Merge(src proto.Message)

func (*CreateRoomResponseParams) XXX_Size 

func (m *CreateRoomResponseParams) XXX_Size() int

func (*CreateRoomResponseParams) XXX_Unmarshal 

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

type CustomEventForwardParams 

type CustomEventForwardParams struct {
	EventID              uint32   `protobuf:"varint,1,opt,name=eventID,proto3" json:"eventID,omitempty"`
	CustomData           []*NGAny `protobuf:"bytes,2,rep,name=customData,proto3" json:"customData,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Launch Event only has Forward params

func (*CustomEventForwardParams) Descriptor 

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

func (*CustomEventForwardParams) GetCustomData 

func (m *CustomEventForwardParams) GetCustomData() []*NGAny

func (*CustomEventForwardParams) GetEventID 

func (m *CustomEventForwardParams) GetEventID() uint32

func (*CustomEventForwardParams) ProtoMessage 

func (*CustomEventForwardParams) ProtoMessage()

func (*CustomEventForwardParams) Reset 

func (m *CustomEventForwardParams) Reset()

func (*CustomEventForwardParams) String 

func (m *CustomEventForwardParams) String() string

func (*CustomEventForwardParams) XXX_DiscardUnknown 

func (m *CustomEventForwardParams) XXX_DiscardUnknown()

func (*CustomEventForwardParams) XXX_Marshal 

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

func (*CustomEventForwardParams) XXX_Merge 

func (m *CustomEventForwardParams) XXX_Merge(src proto.Message)

func (*CustomEventForwardParams) XXX_Size 

func (m *CustomEventForwardParams) XXX_Size() int

func (*CustomEventForwardParams) XXX_Unmarshal 

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

type CustomEventParams 

type CustomEventParams struct {
	Options              *CommonOptions `protobuf:"bytes,1,opt,name=options,proto3" json:"options,omitempty"`
	EventID              uint32         `protobuf:"varint,2,opt,name=eventID,proto3" json:"eventID,omitempty"`
	TargetPeerIds        []uint32       `protobuf:"varint,3,rep,packed,name=targetPeerIds,proto3" json:"targetPeerIds,omitempty"`
	CustomData           []*NGAny       `protobuf:"bytes,4,rep,name=customData,proto3" json:"customData,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*CustomEventParams) Descriptor 

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

func (*CustomEventParams) GetCustomData 

func (m *CustomEventParams) GetCustomData() []*NGAny

func (*CustomEventParams) GetEventID 

func (m *CustomEventParams) GetEventID() uint32

func (*CustomEventParams) GetOptions 

func (m *CustomEventParams) GetOptions() *CommonOptions

func (*CustomEventParams) GetTargetPeerIds 

func (m *CustomEventParams) GetTargetPeerIds() []uint32

func (*CustomEventParams) ProtoMessage 

func (*CustomEventParams) ProtoMessage()

func (*CustomEventParams) Reset 

func (m *CustomEventParams) Reset()

func (*CustomEventParams) String 

func (m *CustomEventParams) String() string

func (*CustomEventParams) XXX_DiscardUnknown 

func (m *CustomEventParams) XXX_DiscardUnknown()

func (*CustomEventParams) XXX_Marshal 

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

func (*CustomEventParams) XXX_Merge 

func (m *CustomEventParams) XXX_Merge(src proto.Message)

func (*CustomEventParams) XXX_Size 

func (m *CustomEventParams) XXX_Size() int

func (*CustomEventParams) XXX_Unmarshal 

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

type ForwardMessage 

type ForwardMessage struct {
	MsgType              MessageType                    `protobuf:"varint,1,opt,name=msgType,proto3,enum=server.MessageType" json:"msgType,omitempty"`
	PeerId               uint32                         `protobuf:"varint,2,opt,name=peerId,proto3" json:"peerId,omitempty"`
	JrfParams            *JoinRoomForwardParams         `protobuf:"bytes,3,opt,name=jrfParams,proto3" json:"jrfParams,omitempty"`
	JocrfParams          *JoinOrCreateRoomForwardParams `protobuf:"bytes,4,opt,name=jocrfParams,proto3" json:"jocrfParams,omitempty"`
	LrfParams            *LeaveRoomForwardParams        `protobuf:"bytes,5,opt,name=lrfParams,proto3" json:"lrfParams,omitempty"`
	RfParams             *RPCForwardParams              `protobuf:"bytes,6,opt,name=rfParams,proto3" json:"rfParams,omitempty"`
	IfParams             *InstantiationForwardParams    `protobuf:"bytes,7,opt,name=ifParams,proto3" json:"ifParams,omitempty"`
	VsfParams            *ViewSyncForwardParams         `protobuf:"bytes,8,opt,name=vsfParams,proto3" json:"vsfParams,omitempty"`
	CeParams             *CustomEventForwardParams      `protobuf:"bytes,9,opt,name=ceParams,proto3" json:"ceParams,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                       `json:"-"`
	XXX_unrecognized     []byte                         `json:"-"`
	XXX_sizecache        int32                          `json:"-"`
}

need to notifiy others in the room.

func (*ForwardMessage) Descriptor 

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

func (*ForwardMessage) GetCeParams 

func (m *ForwardMessage) GetCeParams() *CustomEventForwardParams

func (*ForwardMessage) GetIfParams 

func (m *ForwardMessage) GetIfParams() *InstantiationForwardParams

func (*ForwardMessage) GetJocrfParams 

func (m *ForwardMessage) GetJocrfParams() *JoinOrCreateRoomForwardParams

func (*ForwardMessage) GetJrfParams 

func (m *ForwardMessage) GetJrfParams() *JoinRoomForwardParams

func (*ForwardMessage) GetLrfParams 

func (m *ForwardMessage) GetLrfParams() *LeaveRoomForwardParams

func (*ForwardMessage) GetMsgType 

func (m *ForwardMessage) GetMsgType() MessageType

func (*ForwardMessage) GetPeerId 

func (m *ForwardMessage) GetPeerId() uint32

func (*ForwardMessage) GetRfParams 

func (m *ForwardMessage) GetRfParams() *RPCForwardParams

func (*ForwardMessage) GetVsfParams 

func (m *ForwardMessage) GetVsfParams() *ViewSyncForwardParams

func (*ForwardMessage) ProtoMessage 

func (*ForwardMessage) ProtoMessage()

func (*ForwardMessage) Reset 

func (m *ForwardMessage) Reset()

func (*ForwardMessage) String 

func (m *ForwardMessage) String() string

func (*ForwardMessage) XXX_DiscardUnknown 

func (m *ForwardMessage) XXX_DiscardUnknown()

func (*ForwardMessage) XXX_Marshal 

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

func (*ForwardMessage) XXX_Merge 

func (m *ForwardMessage) XXX_Merge(src proto.Message)

func (*ForwardMessage) XXX_Size 

func (m *ForwardMessage) XXX_Size() int

func (*ForwardMessage) XXX_Unmarshal 

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

type GameServer 

type GameServer struct {
	ID        string
	PeerCount int
	//A map from Room Id to Room
	ID2Room map[string]*Room
	//add mux for server
	RoomIDMux sync.RWMutex
}

GameServer struct

func (*GameServer) AddRoom 

func (server *GameServer) AddRoom(room *Room)

func (*GameServer) DeleteRoom 

func (server *GameServer) DeleteRoom(roomid string)

func (*GameServer) GetPeer 

func (server *GameServer) GetPeer(roomid string, peerid uint32) (error, *Peer)

func (*GameServer) GetPeerWorldID 

func (game *GameServer) GetPeerWorldID(peer Peer) string

GetPeerWorldID Peer world id equals gameid + Peerid,used for communication between rooms from different game servers

func (*GameServer) GetRoom 

func (server *GameServer) GetRoom(roomid string) (*Room, error)

GetRoom get room from server

func (*GameServer) IsRoomExist 

func (server *GameServer) IsRoomExist(roomid string) bool

type InstantiationForwardParams 

type InstantiationForwardParams struct {
	PrefabName           string        `protobuf:"bytes,1,opt,name=prefabName,proto3" json:"prefabName,omitempty"`
	Position             *NGVector3    `protobuf:"bytes,2,opt,name=position,proto3" json:"position,omitempty"`
	Rotation             *NGQuaternion `protobuf:"bytes,3,opt,name=rotation,proto3" json:"rotation,omitempty"`
	ViewIDs              []uint32      `protobuf:"varint,4,rep,packed,name=viewIDs,proto3" json:"viewIDs,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*InstantiationForwardParams) Descriptor 

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

func (*InstantiationForwardParams) GetPosition 

func (m *InstantiationForwardParams) GetPosition() *NGVector3

func (*InstantiationForwardParams) GetPrefabName 

func (m *InstantiationForwardParams) GetPrefabName() string

func (*InstantiationForwardParams) GetRotation 

func (m *InstantiationForwardParams) GetRotation() *NGQuaternion

func (*InstantiationForwardParams) GetViewIDs 

func (m *InstantiationForwardParams) GetViewIDs() []uint32

func (*InstantiationForwardParams) ProtoMessage 

func (*InstantiationForwardParams) ProtoMessage()

func (*InstantiationForwardParams) Reset 

func (m *InstantiationForwardParams) Reset()

func (*InstantiationForwardParams) String 

func (m *InstantiationForwardParams) String() string

func (*InstantiationForwardParams) XXX_DiscardUnknown 

func (m *InstantiationForwardParams) XXX_DiscardUnknown()

func (*InstantiationForwardParams) XXX_Marshal 

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

func (*InstantiationForwardParams) XXX_Merge 

func (m *InstantiationForwardParams) XXX_Merge(src proto.Message)

func (*InstantiationForwardParams) XXX_Size 

func (m *InstantiationForwardParams) XXX_Size() int

func (*InstantiationForwardParams) XXX_Unmarshal 

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

type InstantiationParams 

type InstantiationParams struct {
	Options              *CommonOptions `protobuf:"bytes,1,opt,name=options,proto3" json:"options,omitempty"`
	PrefabName           string         `protobuf:"bytes,2,opt,name=prefabName,proto3" json:"prefabName,omitempty"`
	Position             *NGVector3     `protobuf:"bytes,3,opt,name=position,proto3" json:"position,omitempty"`
	Rotation             *NGQuaternion  `protobuf:"bytes,4,opt,name=rotation,proto3" json:"rotation,omitempty"`
	ViewIDs              []uint32       `protobuf:"varint,5,rep,packed,name=viewIDs,proto3" json:"viewIDs,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

LaunchEventParams and LaunchEventForwardParams all use this message body

func (*InstantiationParams) Descriptor 

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

func (*InstantiationParams) GetOptions 

func (m *InstantiationParams) GetOptions() *CommonOptions

func (*InstantiationParams) GetPosition 

func (m *InstantiationParams) GetPosition() *NGVector3

func (*InstantiationParams) GetPrefabName 

func (m *InstantiationParams) GetPrefabName() string

func (*InstantiationParams) GetRotation 

func (m *InstantiationParams) GetRotation() *NGQuaternion

func (*InstantiationParams) GetViewIDs 

func (m *InstantiationParams) GetViewIDs() []uint32

func (*InstantiationParams) ProtoMessage 

func (*InstantiationParams) ProtoMessage()

func (*InstantiationParams) Reset 

func (m *InstantiationParams) Reset()

func (*InstantiationParams) String 

func (m *InstantiationParams) String() string

func (*InstantiationParams) XXX_DiscardUnknown 

func (m *InstantiationParams) XXX_DiscardUnknown()

func (*InstantiationParams) XXX_Marshal 

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

func (*InstantiationParams) XXX_Merge 

func (m *InstantiationParams) XXX_Merge(src proto.Message)

func (*InstantiationParams) XXX_Size 

func (m *InstantiationParams) XXX_Size() int

func (*InstantiationParams) XXX_Unmarshal 

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

type JoinOrCreateRoomForwardParams 

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

func (*JoinOrCreateRoomForwardParams) Descriptor 

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

func (*JoinOrCreateRoomForwardParams) ProtoMessage 

func (*JoinOrCreateRoomForwardParams) ProtoMessage()

func (*JoinOrCreateRoomForwardParams) Reset 

func (m *JoinOrCreateRoomForwardParams) Reset()

func (*JoinOrCreateRoomForwardParams) String 

func (m *JoinOrCreateRoomForwardParams) String() string

func (*JoinOrCreateRoomForwardParams) XXX_DiscardUnknown 

func (m *JoinOrCreateRoomForwardParams) XXX_DiscardUnknown()

func (*JoinOrCreateRoomForwardParams) XXX_Marshal 

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

func (*JoinOrCreateRoomForwardParams) XXX_Merge 

func (m *JoinOrCreateRoomForwardParams) XXX_Merge(src proto.Message)

func (*JoinOrCreateRoomForwardParams) XXX_Size 

func (m *JoinOrCreateRoomForwardParams) XXX_Size() int

func (*JoinOrCreateRoomForwardParams) XXX_Unmarshal 

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

type JoinOrCreateRoomParams 

type JoinOrCreateRoomParams struct {
	RoomId               string   `protobuf:"bytes,1,opt,name=roomId,proto3" json:"roomId,omitempty"`
	MaxNumber            uint32   `protobuf:"varint,2,opt,name=maxNumber,proto3" json:"maxNumber,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*JoinOrCreateRoomParams) Descriptor 

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

func (*JoinOrCreateRoomParams) GetMaxNumber 

func (m *JoinOrCreateRoomParams) GetMaxNumber() uint32

func (*JoinOrCreateRoomParams) GetRoomId 

func (m *JoinOrCreateRoomParams) GetRoomId() string

func (*JoinOrCreateRoomParams) ProtoMessage 

func (*JoinOrCreateRoomParams) ProtoMessage()

func (*JoinOrCreateRoomParams) Reset 

func (m *JoinOrCreateRoomParams) Reset()

func (*JoinOrCreateRoomParams) String 

func (m *JoinOrCreateRoomParams) String() string

func (*JoinOrCreateRoomParams) XXX_DiscardUnknown 

func (m *JoinOrCreateRoomParams) XXX_DiscardUnknown()

func (*JoinOrCreateRoomParams) XXX_Marshal 

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

func (*JoinOrCreateRoomParams) XXX_Merge 

func (m *JoinOrCreateRoomParams) XXX_Merge(src proto.Message)

func (*JoinOrCreateRoomParams) XXX_Size 

func (m *JoinOrCreateRoomParams) XXX_Size() int

func (*JoinOrCreateRoomParams) XXX_Unmarshal 

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

type JoinOrCreateRoomResponseParams 

type JoinOrCreateRoomResponseParams struct {
	ReturnValue          uint32   `protobuf:"varint,1,opt,name=returnValue,proto3" json:"returnValue,omitempty"`
	Message              string   `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	PeerId               uint32   `protobuf:"varint,3,opt,name=peerId,proto3" json:"peerId,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*JoinOrCreateRoomResponseParams) Descriptor 

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

func (*JoinOrCreateRoomResponseParams) GetMessage 

func (m *JoinOrCreateRoomResponseParams) GetMessage() string

func (*JoinOrCreateRoomResponseParams) GetPeerId 

func (m *JoinOrCreateRoomResponseParams) GetPeerId() uint32

func (*JoinOrCreateRoomResponseParams) GetReturnValue 

func (m *JoinOrCreateRoomResponseParams) GetReturnValue() uint32

func (*JoinOrCreateRoomResponseParams) ProtoMessage 

func (*JoinOrCreateRoomResponseParams) ProtoMessage()

func (*JoinOrCreateRoomResponseParams) Reset 

func (m *JoinOrCreateRoomResponseParams) Reset()

func (*JoinOrCreateRoomResponseParams) String 

func (m *JoinOrCreateRoomResponseParams) String() string

func (*JoinOrCreateRoomResponseParams) XXX_DiscardUnknown 

func (m *JoinOrCreateRoomResponseParams) XXX_DiscardUnknown()

func (*JoinOrCreateRoomResponseParams) XXX_Marshal 

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

func (*JoinOrCreateRoomResponseParams) XXX_Merge 

func (m *JoinOrCreateRoomResponseParams) XXX_Merge(src proto.Message)

func (*JoinOrCreateRoomResponseParams) XXX_Size 

func (m *JoinOrCreateRoomResponseParams) XXX_Size() int

func (*JoinOrCreateRoomResponseParams) XXX_Unmarshal 

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

type JoinRoomForwardParams 

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

func (*JoinRoomForwardParams) Descriptor 

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

func (*JoinRoomForwardParams) ProtoMessage 

func (*JoinRoomForwardParams) ProtoMessage()

func (*JoinRoomForwardParams) Reset 

func (m *JoinRoomForwardParams) Reset()

func (*JoinRoomForwardParams) String 

func (m *JoinRoomForwardParams) String() string

func (*JoinRoomForwardParams) XXX_DiscardUnknown 

func (m *JoinRoomForwardParams) XXX_DiscardUnknown()

func (*JoinRoomForwardParams) XXX_Marshal 

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

func (*JoinRoomForwardParams) XXX_Merge 

func (m *JoinRoomForwardParams) XXX_Merge(src proto.Message)

func (*JoinRoomForwardParams) XXX_Size 

func (m *JoinRoomForwardParams) XXX_Size() int

func (*JoinRoomForwardParams) XXX_Unmarshal 

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

type JoinRoomParams 

type JoinRoomParams struct {
	RoomId               string   `protobuf:"bytes,1,opt,name=roomId,proto3" json:"roomId,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*JoinRoomParams) Descriptor 

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

func (*JoinRoomParams) GetRoomId 

func (m *JoinRoomParams) GetRoomId() string

func (*JoinRoomParams) ProtoMessage 

func (*JoinRoomParams) ProtoMessage()

func (*JoinRoomParams) Reset 

func (m *JoinRoomParams) Reset()

func (*JoinRoomParams) String 

func (m *JoinRoomParams) String() string

func (*JoinRoomParams) XXX_DiscardUnknown 

func (m *JoinRoomParams) XXX_DiscardUnknown()

func (*JoinRoomParams) XXX_Marshal 

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

func (*JoinRoomParams) XXX_Merge 

func (m *JoinRoomParams) XXX_Merge(src proto.Message)

func (*JoinRoomParams) XXX_Size 

func (m *JoinRoomParams) XXX_Size() int

func (*JoinRoomParams) XXX_Unmarshal 

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

type JoinRoomResponseParams 

type JoinRoomResponseParams struct {
	ReturnValue          uint32   `protobuf:"varint,1,opt,name=returnValue,proto3" json:"returnValue,omitempty"`
	Message              string   `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	PeerId               uint32   `protobuf:"varint,3,opt,name=peerId,proto3" json:"peerId,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*JoinRoomResponseParams) Descriptor 

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

func (*JoinRoomResponseParams) GetMessage 

func (m *JoinRoomResponseParams) GetMessage() string

func (*JoinRoomResponseParams) GetPeerId 

func (m *JoinRoomResponseParams) GetPeerId() uint32

func (*JoinRoomResponseParams) GetReturnValue 

func (m *JoinRoomResponseParams) GetReturnValue() uint32

func (*JoinRoomResponseParams) ProtoMessage 

func (*JoinRoomResponseParams) ProtoMessage()

func (*JoinRoomResponseParams) Reset 

func (m *JoinRoomResponseParams) Reset()

func (*JoinRoomResponseParams) String 

func (m *JoinRoomResponseParams) String() string

func (*JoinRoomResponseParams) XXX_DiscardUnknown 

func (m *JoinRoomResponseParams) XXX_DiscardUnknown()

func (*JoinRoomResponseParams) XXX_Marshal 

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

func (*JoinRoomResponseParams) XXX_Merge 

func (m *JoinRoomResponseParams) XXX_Merge(src proto.Message)

func (*JoinRoomResponseParams) XXX_Size 

func (m *JoinRoomResponseParams) XXX_Size() int

func (*JoinRoomResponseParams) XXX_Unmarshal 

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

type LeaveRoomForwardParams 

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

func (*LeaveRoomForwardParams) Descriptor 

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

func (*LeaveRoomForwardParams) ProtoMessage 

func (*LeaveRoomForwardParams) ProtoMessage()

func (*LeaveRoomForwardParams) Reset 

func (m *LeaveRoomForwardParams) Reset()

func (*LeaveRoomForwardParams) String 

func (m *LeaveRoomForwardParams) String() string

func (*LeaveRoomForwardParams) XXX_DiscardUnknown 

func (m *LeaveRoomForwardParams) XXX_DiscardUnknown()

func (*LeaveRoomForwardParams) XXX_Marshal 

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

func (*LeaveRoomForwardParams) XXX_Merge 

func (m *LeaveRoomForwardParams) XXX_Merge(src proto.Message)

func (*LeaveRoomForwardParams) XXX_Size 

func (m *LeaveRoomForwardParams) XXX_Size() int

func (*LeaveRoomForwardParams) XXX_Unmarshal 

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

type LeaveRoomParams 

type LeaveRoomParams struct {
	RoomId               string   `protobuf:"bytes,1,opt,name=roomId,proto3" json:"roomId,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*LeaveRoomParams) Descriptor 

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

func (*LeaveRoomParams) GetRoomId 

func (m *LeaveRoomParams) GetRoomId() string

func (*LeaveRoomParams) ProtoMessage 

func (*LeaveRoomParams) ProtoMessage()

func (*LeaveRoomParams) Reset 

func (m *LeaveRoomParams) Reset()

func (*LeaveRoomParams) String 

func (m *LeaveRoomParams) String() string

func (*LeaveRoomParams) XXX_DiscardUnknown 

func (m *LeaveRoomParams) XXX_DiscardUnknown()

func (*LeaveRoomParams) XXX_Marshal 

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

func (*LeaveRoomParams) XXX_Merge 

func (m *LeaveRoomParams) XXX_Merge(src proto.Message)

func (*LeaveRoomParams) XXX_Size 

func (m *LeaveRoomParams) XXX_Size() int

func (*LeaveRoomParams) XXX_Unmarshal 

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

type LeaveRoomResponseParams 

type LeaveRoomResponseParams struct {
	ReturnValue          uint32   `protobuf:"varint,1,opt,name=returnValue,proto3" json:"returnValue,omitempty"`
	Message              string   `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	PeerId               uint32   `protobuf:"varint,3,opt,name=peerId,proto3" json:"peerId,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*LeaveRoomResponseParams) Descriptor 

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

func (*LeaveRoomResponseParams) GetMessage 

func (m *LeaveRoomResponseParams) GetMessage() string

func (*LeaveRoomResponseParams) GetPeerId 

func (m *LeaveRoomResponseParams) GetPeerId() uint32

func (*LeaveRoomResponseParams) GetReturnValue 

func (m *LeaveRoomResponseParams) GetReturnValue() uint32

func (*LeaveRoomResponseParams) ProtoMessage 

func (*LeaveRoomResponseParams) ProtoMessage()

func (*LeaveRoomResponseParams) Reset 

func (m *LeaveRoomResponseParams) Reset()

func (*LeaveRoomResponseParams) String 

func (m *LeaveRoomResponseParams) String() string

func (*LeaveRoomResponseParams) XXX_DiscardUnknown 

func (m *LeaveRoomResponseParams) XXX_DiscardUnknown()

func (*LeaveRoomResponseParams) XXX_Marshal 

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

func (*LeaveRoomResponseParams) XXX_Merge 

func (m *LeaveRoomResponseParams) XXX_Merge(src proto.Message)

func (*LeaveRoomResponseParams) XXX_Size 

func (m *LeaveRoomResponseParams) XXX_Size() int

func (*LeaveRoomResponseParams) XXX_Unmarshal 

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

type Lobby 

type Lobby struct {
	Lobbyname string
	Gamelist  []GameServer
}

func (*Lobby) GetGameServers 

func (lobby *Lobby) GetGameServers() []GameServer

func (*Lobby) JoinLobby 

func (lobby *Lobby) JoinLobby()

join a lobby

type LobbyOperations 

type LobbyOperations interface {
	JoinLobby()
	GetGameServers() []GameServer
}

type MessageType 

type MessageType int32
const (
	MessageType_JoinLobby              MessageType = 0
	MessageType_LeaveLobby             MessageType = 1
	MessageType_CreateRoom             MessageType = 2
	MessageType_JoinRoom               MessageType = 3
	MessageType_JoinOrCreateRoom       MessageType = 4
	MessageType_LeaveRoom              MessageType = 5
	MessageType_RPC                    MessageType = 6
	MessageType_Instantiation          MessageType = 7
	MessageType_ViewSync               MessageType = 8
	MessageType_CustomEvent            MessageType = 9
	MessageType_SubscribeMsgChannels   MessageType = 10
	MessageType_UnSubscribeMsgChannels MessageType = 11
)

func (MessageType) EnumDescriptor 

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

func (MessageType) String 

func (x MessageType) String() string

type MsgChannel 

type MsgChannel struct {
	ID uint32
	//peer ids that the current channel is subscribed
	PeerIds map[uint32]struct{}
}

MsgChannel message channels

func NewMsgChannel 

func NewMsgChannel(id uint32) *MsgChannel

NewMsgChannel new a MsgChannel

type NGAny 

type NGAny struct {
	// Types that are valid to be assigned to NgType:
	//	*NGAny_NgDouble
	//	*NGAny_NgFloat
	//	*NGAny_NgInt32
	//	*NGAny_NgInt64
	//	*NGAny_NgUint32
	//	*NGAny_NgUint64
	//	*NGAny_NgSint32
	//	*NGAny_NgSint64
	//	*NGAny_NgFixed32
	//	*NGAny_NgFixed64
	//	*NGAny_NgSfixed32
	//	*NGAny_NgSfixed64
	//	*NGAny_NgBool
	//	*NGAny_NgString
	//	*NGAny_NgBytes
	//	*NGAny_NgVector3
	//	*NGAny_NgQuaternion
	//	*NGAny_NgColor
	NgType               isNGAny_NgType `protobuf_oneof:"ngType"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

the NGAny is a union,only one type is set

func (*NGAny) Descriptor 

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

func (*NGAny) GetNgBool 

func (m *NGAny) GetNgBool() bool

func (*NGAny) GetNgBytes 

func (m *NGAny) GetNgBytes() []byte

func (*NGAny) GetNgColor 

func (m *NGAny) GetNgColor() *NGColor

func (*NGAny) GetNgDouble 

func (m *NGAny) GetNgDouble() float64

func (*NGAny) GetNgFixed32 

func (m *NGAny) GetNgFixed32() uint32

func (*NGAny) GetNgFixed64 

func (m *NGAny) GetNgFixed64() uint64

func (*NGAny) GetNgFloat 

func (m *NGAny) GetNgFloat() float32

func (*NGAny) GetNgInt32 

func (m *NGAny) GetNgInt32() int32

func (*NGAny) GetNgInt64 

func (m *NGAny) GetNgInt64() int64

func (*NGAny) GetNgQuaternion 

func (m *NGAny) GetNgQuaternion() *NGQuaternion

func (*NGAny) GetNgSfixed32 

func (m *NGAny) GetNgSfixed32() int32

func (*NGAny) GetNgSfixed64 

func (m *NGAny) GetNgSfixed64() int64

func (*NGAny) GetNgSint32 

func (m *NGAny) GetNgSint32() int32

func (*NGAny) GetNgSint64 

func (m *NGAny) GetNgSint64() int64

func (*NGAny) GetNgString 

func (m *NGAny) GetNgString() string

func (*NGAny) GetNgType 

func (m *NGAny) GetNgType() isNGAny_NgType

func (*NGAny) GetNgUint32 

func (m *NGAny) GetNgUint32() uint32

func (*NGAny) GetNgUint64 

func (m *NGAny) GetNgUint64() uint64

func (*NGAny) GetNgVector3 

func (m *NGAny) GetNgVector3() *NGVector3

func (*NGAny) ProtoMessage 

func (*NGAny) ProtoMessage()

func (*NGAny) Reset 

func (m *NGAny) Reset()

func (*NGAny) String 

func (m *NGAny) String() string

func (*NGAny) XXX_DiscardUnknown 

func (m *NGAny) XXX_DiscardUnknown()

func (*NGAny) XXX_Marshal 

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

func (*NGAny) XXX_Merge 

func (m *NGAny) XXX_Merge(src proto.Message)

func (*NGAny) XXX_OneofWrappers 

func (*NGAny) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*NGAny) XXX_Size 

func (m *NGAny) XXX_Size() int

func (*NGAny) XXX_Unmarshal 

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

type NGAny_NgBool 

type NGAny_NgBool struct {
	NgBool bool `protobuf:"varint,23,opt,name=ngBool,proto3,oneof"`
}

type NGAny_NgBytes 

type NGAny_NgBytes struct {
	NgBytes []byte `protobuf:"bytes,25,opt,name=ngBytes,proto3,oneof"`
}

type NGAny_NgColor 

type NGAny_NgColor struct {
	NgColor *NGColor `protobuf:"bytes,33,opt,name=ngColor,proto3,oneof"`
}

type NGAny_NgDouble 

type NGAny_NgDouble struct {
	NgDouble float64 `protobuf:"fixed64,11,opt,name=ngDouble,proto3,oneof"`
}

type NGAny_NgFixed32 

type NGAny_NgFixed32 struct {
	NgFixed32 uint32 `protobuf:"fixed32,19,opt,name=ngFixed32,proto3,oneof"`
}

type NGAny_NgFixed64 

type NGAny_NgFixed64 struct {
	NgFixed64 uint64 `protobuf:"fixed64,20,opt,name=ngFixed64,proto3,oneof"`
}

type NGAny_NgFloat 

type NGAny_NgFloat struct {
	NgFloat float32 `protobuf:"fixed32,12,opt,name=ngFloat,proto3,oneof"`
}

type NGAny_NgInt32 

type NGAny_NgInt32 struct {
	NgInt32 int32 `protobuf:"varint,13,opt,name=ngInt32,proto3,oneof"`
}

type NGAny_NgInt64 

type NGAny_NgInt64 struct {
	NgInt64 int64 `protobuf:"varint,14,opt,name=ngInt64,proto3,oneof"`
}

type NGAny_NgQuaternion 

type NGAny_NgQuaternion struct {
	NgQuaternion *NGQuaternion `protobuf:"bytes,32,opt,name=ngQuaternion,proto3,oneof"`
}

type NGAny_NgSfixed32 

type NGAny_NgSfixed32 struct {
	NgSfixed32 int32 `protobuf:"fixed32,21,opt,name=ngSfixed32,proto3,oneof"`
}

type NGAny_NgSfixed64 

type NGAny_NgSfixed64 struct {
	NgSfixed64 int64 `protobuf:"fixed64,22,opt,name=ngSfixed64,proto3,oneof"`
}

type NGAny_NgSint32 

type NGAny_NgSint32 struct {
	NgSint32 int32 `protobuf:"zigzag32,17,opt,name=ngSint32,proto3,oneof"`
}

type NGAny_NgSint64 

type NGAny_NgSint64 struct {
	NgSint64 int64 `protobuf:"zigzag64,18,opt,name=ngSint64,proto3,oneof"`
}

type NGAny_NgString 

type NGAny_NgString struct {
	NgString string `protobuf:"bytes,24,opt,name=ngString,proto3,oneof"`
}

type NGAny_NgUint32 

type NGAny_NgUint32 struct {
	NgUint32 uint32 `protobuf:"varint,15,opt,name=ngUint32,proto3,oneof"`
}

type NGAny_NgUint64 

type NGAny_NgUint64 struct {
	NgUint64 uint64 `protobuf:"varint,16,opt,name=ngUint64,proto3,oneof"`
}

type NGAny_NgVector3 

type NGAny_NgVector3 struct {
	NgVector3 *NGVector3 `protobuf:"bytes,31,opt,name=ngVector3,proto3,oneof"`
}

type NGColor 

type NGColor struct {
	R                    float32  `protobuf:"fixed32,1,opt,name=r,proto3" json:"r,omitempty"`
	G                    float32  `protobuf:"fixed32,2,opt,name=g,proto3" json:"g,omitempty"`
	B                    float32  `protobuf:"fixed32,3,opt,name=b,proto3" json:"b,omitempty"`
	A                    float32  `protobuf:"fixed32,4,opt,name=a,proto3" json:"a,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NGColor) Descriptor 

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

func (*NGColor) GetA 

func (m *NGColor) GetA() float32

func (*NGColor) GetB 

func (m *NGColor) GetB() float32

func (*NGColor) GetG 

func (m *NGColor) GetG() float32

func (*NGColor) GetR 

func (m *NGColor) GetR() float32

func (*NGColor) ProtoMessage 

func (*NGColor) ProtoMessage()

func (*NGColor) Reset 

func (m *NGColor) Reset()

func (*NGColor) String 

func (m *NGColor) String() string

func (*NGColor) XXX_DiscardUnknown 

func (m *NGColor) XXX_DiscardUnknown()

func (*NGColor) XXX_Marshal 

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

func (*NGColor) XXX_Merge 

func (m *NGColor) XXX_Merge(src proto.Message)

func (*NGColor) XXX_Size 

func (m *NGColor) XXX_Size() int

func (*NGColor) XXX_Unmarshal 

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

type NGQuaternion 

type NGQuaternion struct {
	X                    float32  `protobuf:"fixed32,1,opt,name=x,proto3" json:"x,omitempty"`
	Y                    float32  `protobuf:"fixed32,2,opt,name=y,proto3" json:"y,omitempty"`
	Z                    float32  `protobuf:"fixed32,3,opt,name=z,proto3" json:"z,omitempty"`
	W                    float32  `protobuf:"fixed32,4,opt,name=w,proto3" json:"w,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NGQuaternion) Descriptor 

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

func (*NGQuaternion) GetW 

func (m *NGQuaternion) GetW() float32

func (*NGQuaternion) GetX 

func (m *NGQuaternion) GetX() float32

func (*NGQuaternion) GetY 

func (m *NGQuaternion) GetY() float32

func (*NGQuaternion) GetZ 

func (m *NGQuaternion) GetZ() float32

func (*NGQuaternion) ProtoMessage 

func (*NGQuaternion) ProtoMessage()

func (*NGQuaternion) Reset 

func (m *NGQuaternion) Reset()

func (*NGQuaternion) String 

func (m *NGQuaternion) String() string

func (*NGQuaternion) XXX_DiscardUnknown 

func (m *NGQuaternion) XXX_DiscardUnknown()

func (*NGQuaternion) XXX_Marshal 

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

func (*NGQuaternion) XXX_Merge 

func (m *NGQuaternion) XXX_Merge(src proto.Message)

func (*NGQuaternion) XXX_Size 

func (m *NGQuaternion) XXX_Size() int

func (*NGQuaternion) XXX_Unmarshal 

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

type NGVector3 

type NGVector3 struct {
	X                    float32  `protobuf:"fixed32,1,opt,name=x,proto3" json:"x,omitempty"`
	Y                    float32  `protobuf:"fixed32,2,opt,name=y,proto3" json:"y,omitempty"`
	Z                    float32  `protobuf:"fixed32,3,opt,name=z,proto3" json:"z,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NGVector3) Descriptor 

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

func (*NGVector3) GetX 

func (m *NGVector3) GetX() float32

func (*NGVector3) GetY 

func (m *NGVector3) GetY() float32

func (*NGVector3) GetZ 

func (m *NGVector3) GetZ() float32

func (*NGVector3) ProtoMessage 

func (*NGVector3) ProtoMessage()

func (*NGVector3) Reset 

func (m *NGVector3) Reset()

func (*NGVector3) String 

func (m *NGVector3) String() string

func (*NGVector3) XXX_DiscardUnknown 

func (m *NGVector3) XXX_DiscardUnknown()

func (*NGVector3) XXX_Marshal 

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

func (*NGVector3) XXX_Merge 

func (m *NGVector3) XXX_Merge(src proto.Message)

func (*NGVector3) XXX_Size 

func (m *NGVector3) XXX_Size() int

func (*NGVector3) XXX_Unmarshal 

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

type NetgoCallback 

type NetgoCallback struct {
}

NetgoCallback struct

func (*NetgoCallback) OnClose 

func (callback *NetgoCallback) OnClose(c *lib.Conn)

OnClose on close

func (*NetgoCallback) OnConnect 

func (callback *NetgoCallback) OnConnect(c *lib.Conn) bool

OnConnect connect

func (*NetgoCallback) OnMessage 

func (callback *NetgoCallback) OnMessage(c *lib.Conn, p lib.Packet) bool

OnMessage on message

type NetgoPacket 

type NetgoPacket struct {
	// contains filtered or unexported fields
}

func NewNetgoPacket 

func NewNetgoPacket(len uint32, buff []byte) *NetgoPacket

func (*NetgoPacket) GetBody 

func (this *NetgoPacket) GetBody() []byte

func (*NetgoPacket) Serialize 

func (this *NetgoPacket) Serialize() []byte

type NetgoProtocol 

type NetgoProtocol struct {
}

func (*NetgoProtocol) ReadPacket 

func (protocol *NetgoProtocol) ReadPacket(conn *net.TCPConn) (lib.Packet, error)

ReadPacket read the packet from network

type Peer 

type Peer struct {
	//peer name
	Name string
	//peer ID ,it must be unique in a room
	ID uint32
	//the id of room in which current peer is
	RoomID string

	// //store the channel ids to which current peer send msg to .
	// //If it has no items,means that all the channels will receice
	// //it's messages.If the size is bigger than 0,only the channels in
	// //SendToMsgChannelsIds can receive the messages.All the channel ids
	// //in SendToMsgChannelsIds should be bigger than 0.
	// SendToMsgChannelsIds map[uint32]struct{}
	Conn *lib.Conn

	CachedInstantiationParams *InstantiationForwardParams
	CachedJoinRoomParams      *JoinRoomForwardParams
	//Map from unitID_methodname to *RPCForwardParams
	CachedRPCsMap map[string]*RPCForwardParams
}

Peer struct

func (*Peer) AsyncWriteMessage 

func (peer *Peer) AsyncWriteMessage(msg proto.Message) error

AsyncWriteMessage write message

func (*Peer) CreateRoom 

func (peer *Peer) CreateRoom(roomid string, maxnumber uint32) PeerStatus

CreateRoom create a game room

func (*Peer) CustomEvent 

func (peer *Peer) CustomEvent(params *CustomEventParams) PeerStatus

CustomEvent issue custom event

func (*Peer) GetAllSubscribePeers 

func (peer *Peer) GetAllSubscribePeers(commonoptions *CommonOptions) []*Peer

GetAllSubscribePeers get all the subscribe peers

func (*Peer) HandMessage 

func (peer *Peer) HandMessage(packet lib.Packet) PeerStatus

HandMessage hand a message from client

func (*Peer) HandRequest 

func (peer *Peer) HandRequest()

HandRequest hand a request

func (*Peer) Instantiation 

func (peer *Peer) Instantiation(params *InstantiationParams) PeerStatus

Instantiation Instantiation a prefab

func (*Peer) JoinOrCreateRoom 

func (peer *Peer) JoinOrCreateRoom(roomid string, maxnumber uint32) PeerStatus

JoinOrCreateRoom if exist join else create room

func (*Peer) JoinRoom 

func (peer *Peer) JoinRoom(roomid string) PeerStatus

JoinRoom join a game room

func (*Peer) LeaveRoom 

func (peer *Peer) LeaveRoom() PeerStatus

LeaveRoom leave a game room

func (*Peer) RPC 

func (peer *Peer) RPC(params *RPCParams) PeerStatus

RPC rpc method

func (*Peer) SubscribeMsgChannels 

func (peer *Peer) SubscribeMsgChannels(channelids []uint32) PeerStatus

SubscribeMsgChannels subscribe msg channels

func (*Peer) UnSubscribeMsgChannels 

func (peer *Peer) UnSubscribeMsgChannels(channelids []uint32) PeerStatus

UnSubscribeMsgChannels unsubscribe msg channels

func (*Peer) ViewSync 

func (peer *Peer) ViewSync(params *ViewSyncParams) PeerStatus

ViewSync Instantiation a prefab

type PeerStatus 

type PeerStatus uint32

PeerStatus status of Peer 

const (

	//Success status 1
	Success PeerStatus
	//CreateRoomSuccess status 2
	CreateRoomSuccess
	//CreateRoomAlreadyExist the room is exist already. 3
	CreateRoomAlreadyExist
	//JoinRoomSuccess status 4
	JoinRoomSuccess
	//JoinRoomNotExist the room is not exist. 5
	JoinRoomNotExist
	//JoinRoomAlreadyInRoom already in the room. 6
	JoinRoomAlreadyInRoom
	//JoinRoomFull the room is full already. 7
	JoinRoomFull
	//LeaveRoomSuccess leave a room success. 8
	LeaveRoomSuccess
)

type RPCForwardParams 

type RPCForwardParams struct {
	ViewID               uint32   `protobuf:"varint,1,opt,name=viewID,proto3" json:"viewID,omitempty"`
	MethodName           string   `protobuf:"bytes,2,opt,name=methodName,proto3" json:"methodName,omitempty"`
	Parameters           []*NGAny `protobuf:"bytes,3,rep,name=parameters,proto3" json:"parameters,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RPCForwardParams) Descriptor 

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

func (*RPCForwardParams) GetMethodName 

func (m *RPCForwardParams) GetMethodName() string

func (*RPCForwardParams) GetParameters 

func (m *RPCForwardParams) GetParameters() []*NGAny

func (*RPCForwardParams) GetViewID 

func (m *RPCForwardParams) GetViewID() uint32

func (*RPCForwardParams) ProtoMessage 

func (*RPCForwardParams) ProtoMessage()

func (*RPCForwardParams) Reset 

func (m *RPCForwardParams) Reset()

func (*RPCForwardParams) String 

func (m *RPCForwardParams) String() string

func (*RPCForwardParams) XXX_DiscardUnknown 

func (m *RPCForwardParams) XXX_DiscardUnknown()

func (*RPCForwardParams) XXX_Marshal 

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

func (*RPCForwardParams) XXX_Merge 

func (m *RPCForwardParams) XXX_Merge(src proto.Message)

func (*RPCForwardParams) XXX_Size 

func (m *RPCForwardParams) XXX_Size() int

func (*RPCForwardParams) XXX_Unmarshal 

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

type RPCParams 

type RPCParams struct {
	Options              *CommonOptions `protobuf:"bytes,1,opt,name=options,proto3" json:"options,omitempty"`
	Target               RPCTarget      `protobuf:"varint,2,opt,name=target,proto3,enum=server.RPCTarget" json:"target,omitempty"`
	ViewID               uint32         `protobuf:"varint,3,opt,name=viewID,proto3" json:"viewID,omitempty"`
	MethodName           string         `protobuf:"bytes,4,opt,name=methodName,proto3" json:"methodName,omitempty"`
	Parameters           []*NGAny       `protobuf:"bytes,5,rep,name=parameters,proto3" json:"parameters,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

RPC parameters send from client to server

func (*RPCParams) Descriptor 

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

func (*RPCParams) GetMethodName 

func (m *RPCParams) GetMethodName() string

func (*RPCParams) GetOptions 

func (m *RPCParams) GetOptions() *CommonOptions

func (*RPCParams) GetParameters 

func (m *RPCParams) GetParameters() []*NGAny

func (*RPCParams) GetTarget 

func (m *RPCParams) GetTarget() RPCTarget

func (*RPCParams) GetViewID 

func (m *RPCParams) GetViewID() uint32

func (*RPCParams) ProtoMessage 

func (*RPCParams) ProtoMessage()

func (*RPCParams) Reset 

func (m *RPCParams) Reset()

func (*RPCParams) String 

func (m *RPCParams) String() string

func (*RPCParams) XXX_DiscardUnknown 

func (m *RPCParams) XXX_DiscardUnknown()

func (*RPCParams) XXX_Marshal 

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

func (*RPCParams) XXX_Merge 

func (m *RPCParams) XXX_Merge(src proto.Message)

func (*RPCParams) XXX_Size 

func (m *RPCParams) XXX_Size() int

func (*RPCParams) XXX_Unmarshal 

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

type RPCTarget 

type RPCTarget int32

event relvelant structs 

const (
	RPCTarget_All    RPCTarget = 0
	RPCTarget_Others RPCTarget = 1
)

func (RPCTarget) EnumDescriptor 

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

func (RPCTarget) String 

func (x RPCTarget) String() string

type ReceiveMessage 

type ReceiveMessage struct {
	ReceiveMsgType       ReceiveMessageType           `protobuf:"varint,1,opt,name=receiveMsgType,proto3,enum=server.ReceiveMessageType" json:"receiveMsgType,omitempty"`
	RssMsg               *ResponseSocketStatusMessage `protobuf:"bytes,2,opt,name=rssMsg,proto3" json:"rssMsg,omitempty"`
	RoMsg                *ResponseOperationMessage    `protobuf:"bytes,3,opt,name=roMsg,proto3" json:"roMsg,omitempty"`
	FMsg                 *ForwardMessage              `protobuf:"bytes,4,opt,name=fMsg,proto3" json:"fMsg,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                     `json:"-"`
	XXX_unrecognized     []byte                       `json:"-"`
	XXX_sizecache        int32                        `json:"-"`
}

send from server to client

func (*ReceiveMessage) Descriptor 

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

func (*ReceiveMessage) GetFMsg 

func (m *ReceiveMessage) GetFMsg() *ForwardMessage

func (*ReceiveMessage) GetReceiveMsgType 

func (m *ReceiveMessage) GetReceiveMsgType() ReceiveMessageType

func (*ReceiveMessage) GetRoMsg 

func (m *ReceiveMessage) GetRoMsg() *ResponseOperationMessage

func (*ReceiveMessage) GetRssMsg 

func (m *ReceiveMessage) GetRssMsg() *ResponseSocketStatusMessage

func (*ReceiveMessage) ProtoMessage 

func (*ReceiveMessage) ProtoMessage()

func (*ReceiveMessage) Reset 

func (m *ReceiveMessage) Reset()

func (*ReceiveMessage) String 

func (m *ReceiveMessage) String() string

func (*ReceiveMessage) XXX_DiscardUnknown 

func (m *ReceiveMessage) XXX_DiscardUnknown()

func (*ReceiveMessage) XXX_Marshal 

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

func (*ReceiveMessage) XXX_Merge 

func (m *ReceiveMessage) XXX_Merge(src proto.Message)

func (*ReceiveMessage) XXX_Size 

func (m *ReceiveMessage) XXX_Size() int

func (*ReceiveMessage) XXX_Unmarshal 

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

type ReceiveMessageType 

type ReceiveMessageType int32
const (
	ReceiveMessageType_ResponseSocketStatus ReceiveMessageType = 0
	ReceiveMessageType_ResponseOperation    ReceiveMessageType = 1
	ReceiveMessageType_Forward              ReceiveMessageType = 2
)

func (ReceiveMessageType) EnumDescriptor 

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

func (ReceiveMessageType) String 

func (x ReceiveMessageType) String() string

type ResponseOperationMessage 

type ResponseOperationMessage struct {
	MsgType              MessageType                     `protobuf:"varint,1,opt,name=msgType,proto3,enum=server.MessageType" json:"msgType,omitempty"`
	CrrParams            *CreateRoomResponseParams       `protobuf:"bytes,2,opt,name=crrParams,proto3" json:"crrParams,omitempty"`
	JrrParams            *JoinRoomResponseParams         `protobuf:"bytes,3,opt,name=jrrParams,proto3" json:"jrrParams,omitempty"`
	JocrrParams          *JoinOrCreateRoomResponseParams `protobuf:"bytes,4,opt,name=jocrrParams,proto3" json:"jocrrParams,omitempty"`
	LrrParams            *LeaveRoomResponseParams        `protobuf:"bytes,5,opt,name=lrrParams,proto3" json:"lrrParams,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                        `json:"-"`
	XXX_unrecognized     []byte                          `json:"-"`
	XXX_sizecache        int32                           `json:"-"`
}

send from server to client

func (*ResponseOperationMessage) Descriptor 

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

func (*ResponseOperationMessage) GetCrrParams 

func (m *ResponseOperationMessage) GetCrrParams() *CreateRoomResponseParams

func (*ResponseOperationMessage) GetJocrrParams 

func (m *ResponseOperationMessage) GetJocrrParams() *JoinOrCreateRoomResponseParams

func (*ResponseOperationMessage) GetJrrParams 

func (m *ResponseOperationMessage) GetJrrParams() *JoinRoomResponseParams

func (*ResponseOperationMessage) GetLrrParams 

func (m *ResponseOperationMessage) GetLrrParams() *LeaveRoomResponseParams

func (*ResponseOperationMessage) GetMsgType 

func (m *ResponseOperationMessage) GetMsgType() MessageType

func (*ResponseOperationMessage) ProtoMessage 

func (*ResponseOperationMessage) ProtoMessage()

func (*ResponseOperationMessage) Reset 

func (m *ResponseOperationMessage) Reset()

func (*ResponseOperationMessage) String 

func (m *ResponseOperationMessage) String() string

func (*ResponseOperationMessage) XXX_DiscardUnknown 

func (m *ResponseOperationMessage) XXX_DiscardUnknown()

func (*ResponseOperationMessage) XXX_Marshal 

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

func (*ResponseOperationMessage) XXX_Merge 

func (m *ResponseOperationMessage) XXX_Merge(src proto.Message)

func (*ResponseOperationMessage) XXX_Size 

func (m *ResponseOperationMessage) XXX_Size() int

func (*ResponseOperationMessage) XXX_Unmarshal 

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

type ResponseSocketStatusMessage 

type ResponseSocketStatusMessage struct {
	SStatus              SocketStatus `protobuf:"varint,1,opt,name=sStatus,proto3,enum=server.SocketStatus" json:"sStatus,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*ResponseSocketStatusMessage) Descriptor 

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

func (*ResponseSocketStatusMessage) GetSStatus 

func (m *ResponseSocketStatusMessage) GetSStatus() SocketStatus

func (*ResponseSocketStatusMessage) ProtoMessage 

func (*ResponseSocketStatusMessage) ProtoMessage()

func (*ResponseSocketStatusMessage) Reset 

func (m *ResponseSocketStatusMessage) Reset()

func (*ResponseSocketStatusMessage) String 

func (m *ResponseSocketStatusMessage) String() string

func (*ResponseSocketStatusMessage) XXX_DiscardUnknown 

func (m *ResponseSocketStatusMessage) XXX_DiscardUnknown()

func (*ResponseSocketStatusMessage) XXX_Marshal 

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

func (*ResponseSocketStatusMessage) XXX_Merge 

func (m *ResponseSocketStatusMessage) XXX_Merge(src proto.Message)

func (*ResponseSocketStatusMessage) XXX_Size 

func (m *ResponseSocketStatusMessage) XXX_Size() int

func (*ResponseSocketStatusMessage) XXX_Unmarshal 

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

type Room 

type Room struct {
	ID        string
	MaxNumber uint32
	// A room can contain serval channels,and a client can listen to these channels,then it will
	// receive messages from these listened channels,channel 0 is a default channel which all the clients will
	// listen to.
	ID2MsgChannel map[uint32]*MsgChannel
	//Protect MsgChannel
	MsgChannelMux sync.RWMutex
	//A map from Peer Id to Peer
	ID2Peer map[uint32]*Peer
	//PeerMux protect the PeerIDPool
	PeerMux sync.RWMutex
	//PeerIDPool here we use a heap to store all the peer ids for a room,
	//we can get the smallest peer id when a new peer joins the room by
	//calling the func GetPeerID.
	PeerIDPool *lib.IntHeap
}

Room Struct

func NewRoom 

func NewRoom(id string, maxnumber uint32) *Room

NewRoom instantiation a room

func (*Room) AddPeer 

func (room *Room) AddPeer(peer *Peer)

AddPeer return the smallest peer id from the heap and then re-establish the heap.

func (*Room) DeletePeer 

func (room *Room) DeletePeer(peer *Peer)

DeletePeer release the peer ID when someone leaves the room. push the peerid back to the heap.

func (*Room) GetAllPeers 

func (room *Room) GetAllPeers() []*Peer

GetAllPeers get all the peers from the specified room

func (*Room) GetAllSubscribePeers 

func (room *Room) GetAllSubscribePeers(sendToChannelsIds []uint32) []*Peer

GetAllSubscribePeers get all the subscribe peers

func (*Room) GetPeer 

func (room *Room) GetPeer(peerid uint32) (error, *Peer)

GetPeer get a specified peer

func (*Room) GetPeersCount 

func (room *Room) GetPeersCount() int

GetPeersCount get the peer count in the room

func (*Room) SubscribeChannel 

func (room *Room) SubscribeChannel(channelid uint32, peerid uint32)

SubscribeChannel a peer subscribe a channel

func (*Room) UnSubscribeAllChannels 

func (room *Room) UnSubscribeAllChannels(peerid uint32)

UnSubscribeAllChannels when a peer left room,this operation will be called

func (*Room) UnSubscribeChannel 

func (room *Room) UnSubscribeChannel(channelid uint32, peerid uint32)

UnSubscribeChannel a peer unsubscribe a channel

type SendMessage 

type SendMessage struct {
	MsgType              MessageType                   `protobuf:"varint,1,opt,name=msgType,proto3,enum=server.MessageType" json:"msgType,omitempty"`
	CrParams             *CreateRoomParams             `protobuf:"bytes,2,opt,name=crParams,proto3" json:"crParams,omitempty"`
	JrParams             *JoinRoomParams               `protobuf:"bytes,3,opt,name=jrParams,proto3" json:"jrParams,omitempty"`
	JocrParams           *JoinOrCreateRoomParams       `protobuf:"bytes,4,opt,name=jocrParams,proto3" json:"jocrParams,omitempty"`
	LrParams             *LeaveRoomParams              `protobuf:"bytes,5,opt,name=lrParams,proto3" json:"lrParams,omitempty"`
	RpcParams            *RPCParams                    `protobuf:"bytes,6,opt,name=rpcParams,proto3" json:"rpcParams,omitempty"`
	IParams              *InstantiationParams          `protobuf:"bytes,7,opt,name=iParams,proto3" json:"iParams,omitempty"`
	VsParams             *ViewSyncParams               `protobuf:"bytes,8,opt,name=vsParams,proto3" json:"vsParams,omitempty"`
	CeParams             *CustomEventParams            `protobuf:"bytes,9,opt,name=ceParams,proto3" json:"ceParams,omitempty"`
	SmcParams            *SubscribeMsgChannelsParams   `protobuf:"bytes,10,opt,name=smcParams,proto3" json:"smcParams,omitempty"`
	UsmcParams           *UnSubscribeMsgChannelsParams `protobuf:"bytes,11,opt,name=usmcParams,proto3" json:"usmcParams,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                      `json:"-"`
	XXX_unrecognized     []byte                        `json:"-"`
	XXX_sizecache        int32                         `json:"-"`
}

send from client to server

func (*SendMessage) Descriptor 

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

func (*SendMessage) GetCeParams 

func (m *SendMessage) GetCeParams() *CustomEventParams

func (*SendMessage) GetCrParams 

func (m *SendMessage) GetCrParams() *CreateRoomParams

func (*SendMessage) GetIParams 

func (m *SendMessage) GetIParams() *InstantiationParams

func (*SendMessage) GetJocrParams 

func (m *SendMessage) GetJocrParams() *JoinOrCreateRoomParams

func (*SendMessage) GetJrParams 

func (m *SendMessage) GetJrParams() *JoinRoomParams

func (*SendMessage) GetLrParams 

func (m *SendMessage) GetLrParams() *LeaveRoomParams

func (*SendMessage) GetMsgType 

func (m *SendMessage) GetMsgType() MessageType

func (*SendMessage) GetRpcParams 

func (m *SendMessage) GetRpcParams() *RPCParams

func (*SendMessage) GetSmcParams 

func (m *SendMessage) GetSmcParams() *SubscribeMsgChannelsParams

func (*SendMessage) GetUsmcParams 

func (m *SendMessage) GetUsmcParams() *UnSubscribeMsgChannelsParams

func (*SendMessage) GetVsParams 

func (m *SendMessage) GetVsParams() *ViewSyncParams

func (*SendMessage) ProtoMessage 

func (*SendMessage) ProtoMessage()

func (*SendMessage) Reset 

func (m *SendMessage) Reset()

func (*SendMessage) String 

func (m *SendMessage) String() string

func (*SendMessage) XXX_DiscardUnknown 

func (m *SendMessage) XXX_DiscardUnknown()

func (*SendMessage) XXX_Marshal 

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

func (*SendMessage) XXX_Merge 

func (m *SendMessage) XXX_Merge(src proto.Message)

func (*SendMessage) XXX_Size 

func (m *SendMessage) XXX_Size() int

func (*SendMessage) XXX_Unmarshal 

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

type SocketStatus 

type SocketStatus int32
const (
	SocketStatus_Disconnected SocketStatus = 0
	SocketStatus_Connected    SocketStatus = 1
)

func (SocketStatus) EnumDescriptor 

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

func (SocketStatus) String 

func (x SocketStatus) String() string

type SubscribeMsgChannelsParams 

type SubscribeMsgChannelsParams struct {
	Channelids           []uint32 `protobuf:"varint,1,rep,packed,name=channelids,proto3" json:"channelids,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SubscribeMsgChannelsParams) Descriptor 

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

func (*SubscribeMsgChannelsParams) GetChannelids 

func (m *SubscribeMsgChannelsParams) GetChannelids() []uint32

func (*SubscribeMsgChannelsParams) ProtoMessage 

func (*SubscribeMsgChannelsParams) ProtoMessage()

func (*SubscribeMsgChannelsParams) Reset 

func (m *SubscribeMsgChannelsParams) Reset()

func (*SubscribeMsgChannelsParams) String 

func (m *SubscribeMsgChannelsParams) String() string

func (*SubscribeMsgChannelsParams) XXX_DiscardUnknown 

func (m *SubscribeMsgChannelsParams) XXX_DiscardUnknown()

func (*SubscribeMsgChannelsParams) XXX_Marshal 

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

func (*SubscribeMsgChannelsParams) XXX_Merge 

func (m *SubscribeMsgChannelsParams) XXX_Merge(src proto.Message)

func (*SubscribeMsgChannelsParams) XXX_Size 

func (m *SubscribeMsgChannelsParams) XXX_Size() int

func (*SubscribeMsgChannelsParams) XXX_Unmarshal 

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

type UnSubscribeMsgChannelsParams 

type UnSubscribeMsgChannelsParams struct {
	Channelids           []uint32 `protobuf:"varint,1,rep,packed,name=channelids,proto3" json:"channelids,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UnSubscribeMsgChannelsParams) Descriptor 

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

func (*UnSubscribeMsgChannelsParams) GetChannelids 

func (m *UnSubscribeMsgChannelsParams) GetChannelids() []uint32

func (*UnSubscribeMsgChannelsParams) ProtoMessage 

func (*UnSubscribeMsgChannelsParams) ProtoMessage()

func (*UnSubscribeMsgChannelsParams) Reset 

func (m *UnSubscribeMsgChannelsParams) Reset()

func (*UnSubscribeMsgChannelsParams) String 

func (m *UnSubscribeMsgChannelsParams) String() string

func (*UnSubscribeMsgChannelsParams) XXX_DiscardUnknown 

func (m *UnSubscribeMsgChannelsParams) XXX_DiscardUnknown()

func (*UnSubscribeMsgChannelsParams) XXX_Marshal 

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

func (*UnSubscribeMsgChannelsParams) XXX_Merge 

func (m *UnSubscribeMsgChannelsParams) XXX_Merge(src proto.Message)

func (*UnSubscribeMsgChannelsParams) XXX_Size 

func (m *UnSubscribeMsgChannelsParams) XXX_Size() int

func (*UnSubscribeMsgChannelsParams) XXX_Unmarshal 

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

type ViewSyncDataParams 

type ViewSyncDataParams struct {
	ViewID               uint32   `protobuf:"varint,1,opt,name=viewID,proto3" json:"viewID,omitempty"`
	ViewSyncData         []*NGAny `protobuf:"bytes,2,rep,name=viewSyncData,proto3" json:"viewSyncData,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

LaunchEventParams and LaunchEventForwardParams all use this message body

func (*ViewSyncDataParams) Descriptor 

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

func (*ViewSyncDataParams) GetViewID 

func (m *ViewSyncDataParams) GetViewID() uint32

func (*ViewSyncDataParams) GetViewSyncData 

func (m *ViewSyncDataParams) GetViewSyncData() []*NGAny

func (*ViewSyncDataParams) ProtoMessage 

func (*ViewSyncDataParams) ProtoMessage()

func (*ViewSyncDataParams) Reset 

func (m *ViewSyncDataParams) Reset()

func (*ViewSyncDataParams) String 

func (m *ViewSyncDataParams) String() string

func (*ViewSyncDataParams) XXX_DiscardUnknown 

func (m *ViewSyncDataParams) XXX_DiscardUnknown()

func (*ViewSyncDataParams) XXX_Marshal 

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

func (*ViewSyncDataParams) XXX_Merge 

func (m *ViewSyncDataParams) XXX_Merge(src proto.Message)

func (*ViewSyncDataParams) XXX_Size 

func (m *ViewSyncDataParams) XXX_Size() int

func (*ViewSyncDataParams) XXX_Unmarshal 

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

type ViewSyncForwardParams 

type ViewSyncForwardParams struct {
	VsdParams            []*ViewSyncDataParams `protobuf:"bytes,1,rep,name=vsdParams,proto3" json:"vsdParams,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*ViewSyncForwardParams) Descriptor 

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

func (*ViewSyncForwardParams) GetVsdParams 

func (m *ViewSyncForwardParams) GetVsdParams() []*ViewSyncDataParams

func (*ViewSyncForwardParams) ProtoMessage 

func (*ViewSyncForwardParams) ProtoMessage()

func (*ViewSyncForwardParams) Reset 

func (m *ViewSyncForwardParams) Reset()

func (*ViewSyncForwardParams) String 

func (m *ViewSyncForwardParams) String() string

func (*ViewSyncForwardParams) XXX_DiscardUnknown 

func (m *ViewSyncForwardParams) XXX_DiscardUnknown()

func (*ViewSyncForwardParams) XXX_Marshal 

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

func (*ViewSyncForwardParams) XXX_Merge 

func (m *ViewSyncForwardParams) XXX_Merge(src proto.Message)

func (*ViewSyncForwardParams) XXX_Size 

func (m *ViewSyncForwardParams) XXX_Size() int

func (*ViewSyncForwardParams) XXX_Unmarshal 

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

type ViewSyncParams 

type ViewSyncParams struct {
	Options              *CommonOptions        `protobuf:"bytes,1,opt,name=options,proto3" json:"options,omitempty"`
	VsdParams            []*ViewSyncDataParams `protobuf:"bytes,2,rep,name=vsdParams,proto3" json:"vsdParams,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*ViewSyncParams) Descriptor 

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

func (*ViewSyncParams) GetOptions 

func (m *ViewSyncParams) GetOptions() *CommonOptions

func (*ViewSyncParams) GetVsdParams 

func (m *ViewSyncParams) GetVsdParams() []*ViewSyncDataParams

func (*ViewSyncParams) ProtoMessage 

func (*ViewSyncParams) ProtoMessage()

func (*ViewSyncParams) Reset 

func (m *ViewSyncParams) Reset()

func (*ViewSyncParams) String 

func (m *ViewSyncParams) String() string

func (*ViewSyncParams) XXX_DiscardUnknown 

func (m *ViewSyncParams) XXX_DiscardUnknown()

func (*ViewSyncParams) XXX_Marshal 

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

func (*ViewSyncParams) XXX_Merge 

func (m *ViewSyncParams) XXX_Merge(src proto.Message)

func (*ViewSyncParams) XXX_Size 

func (m *ViewSyncParams) XXX_Size() int

func (*ViewSyncParams) XXX_Unmarshal 

func (m *ViewSyncParams) XXX_Unmarshal(b []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.