gamecoordinator

Documentation

Index

• type GCMsg
  • func NewGCMsg(appId, msgType uint32, body protocol.Serializer) *GCMsg
  • func (g *GCMsg) GetAppId() uint32
  • func (g *GCMsg) GetMsgType() uint32
  • func (g *GCMsg) GetSourceJobId() protocol.JobId
  • func (g *GCMsg) GetTargetJobId() protocol.JobId
  • func (g *GCMsg) IsProto() bool
  • func (g *GCMsg) Serialize(w io.Writer) error
  • func (g *GCMsg) SetSourceJobId(job protocol.JobId)
  • func (g *GCMsg) SetTargetJobId(job protocol.JobId)
• type GCMsgProtobuf
  • func NewGCMsgProtobuf(appId, msgType uint32, body proto.Message) *GCMsgProtobuf
  • func (g *GCMsgProtobuf) GetAppId() uint32
  • func (g *GCMsgProtobuf) GetMsgType() uint32
  • func (g *GCMsgProtobuf) GetSourceJobId() protocol.JobId
  • func (g *GCMsgProtobuf) GetTargetJobId() protocol.JobId
  • func (g *GCMsgProtobuf) IsProto() bool
  • func (g *GCMsgProtobuf) Serialize(w io.Writer) error
  • func (g *GCMsgProtobuf) SetSourceJobId(job protocol.JobId)
  • func (g *GCMsgProtobuf) SetTargetJobId(job protocol.JobId)
• type GCPacket
  • func NewGCPacket(wrapper *protobuf.CMsgGCClient) (*GCPacket, error)
  • func (g *GCPacket) ReadMsg(body protocol.MessageBody)
  • func (g *GCPacket) ReadProtoMsg(body proto.Message)
• type IGCMsg

Types

type GCMsg

type GCMsg struct {
	AppId   uint32
	MsgType uint32
	Header  *steamlang.MsgGCHdr
	Body    protocol.Serializer
}

func NewGCMsg

func NewGCMsg(appId, msgType uint32, body protocol.Serializer) *GCMsg

func (*GCMsg) GetAppId

func (g *GCMsg) GetAppId() uint32

func (*GCMsg) GetMsgType

func (g *GCMsg) GetMsgType() uint32

func (*GCMsg) GetSourceJobId

func (g *GCMsg) GetSourceJobId() protocol.JobId

func (*GCMsg) GetTargetJobId

func (g *GCMsg) GetTargetJobId() protocol.JobId

func (*GCMsg) IsProto

func (g *GCMsg) IsProto() bool

func (*GCMsg) Serialize

func (g *GCMsg) Serialize(w io.Writer) error

func (*GCMsg) SetSourceJobId

func (g *GCMsg) SetSourceJobId(job protocol.JobId)

func (*GCMsg) SetTargetJobId

func (g *GCMsg) SetTargetJobId(job protocol.JobId)

type GCMsgProtobuf

type GCMsgProtobuf struct {
	AppId  uint32
	Header *steamlang.MsgGCHdrProtoBuf
	Body   proto.Message
}

func NewGCMsgProtobuf

func NewGCMsgProtobuf(appId, msgType uint32, body proto.Message) *GCMsgProtobuf

func (*GCMsgProtobuf) GetAppId

func (g *GCMsgProtobuf) GetAppId() uint32

func (*GCMsgProtobuf) GetMsgType

func (g *GCMsgProtobuf) GetMsgType() uint32

func (*GCMsgProtobuf) GetSourceJobId

func (g *GCMsgProtobuf) GetSourceJobId() protocol.JobId

func (*GCMsgProtobuf) GetTargetJobId

func (g *GCMsgProtobuf) GetTargetJobId() protocol.JobId

func (*GCMsgProtobuf) IsProto

func (g *GCMsgProtobuf) IsProto() bool

func (*GCMsgProtobuf) Serialize

func (g *GCMsgProtobuf) Serialize(w io.Writer) error

func (*GCMsgProtobuf) SetSourceJobId

func (g *GCMsgProtobuf) SetSourceJobId(job protocol.JobId)

func (*GCMsgProtobuf) SetTargetJobId

func (g *GCMsgProtobuf) SetTargetJobId(job protocol.JobId)

type GCPacket

type GCPacket struct {
	AppId       uint32
	MsgType     uint32
	IsProto     bool
	GCName      string
	Body        []byte
	TargetJobId protocol.JobId
}

An incoming, partially unread message from the Game Coordinator.

func NewGCPacket

func NewGCPacket(wrapper *protobuf.CMsgGCClient) (*GCPacket, error)

func (*GCPacket) ReadMsg

func (g *GCPacket) ReadMsg(body protocol.MessageBody)

func (*GCPacket) ReadProtoMsg

func (g *GCPacket) ReadProtoMsg(body proto.Message)

type IGCMsg

type IGCMsg interface {
	protocol.Serializer
	IsProto() bool
	GetAppId() uint32
	GetMsgType() uint32

	GetTargetJobId() protocol.JobId
	SetTargetJobId(protocol.JobId)
	GetSourceJobId() protocol.JobId
	SetSourceJobId(protocol.JobId)
}

An outgoing message to the Game Coordinator.