gameserver

type Config struct {
	HeartbeatTimeout time.Duration
	NotifyCh         chan<- bool

	LogOutput io.Writer
	LogLevel  string
}

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

type NetworkTransport struct {
	TimeoutScale int
	// contains filtered or unexported fields
}

type NetworkTransportConfig struct {
	Logger *log.Logger

	Stream StreamLayer

	MaxPool int

	Timeout time.Duration
}

type ProtocolVersion int

type RPC struct {
	Command  interface{}
	Reader   io.Reader
	RespChan chan<- RPCResponse
}

type RPCHeader struct {
	ProtocolVersion ProtocolVersion
}

type RPCRequest struct {
	RPCHeader
	Payload []byte
}

type RPCRequestRsp struct {
	RPCHeader
	Payload []byte
}

type RPCResponse struct {
	Response interface{}
	Error    error
}

type ServerAddress string

type StreamLayer interface {
	net.Listener

	// Dial is used to create a new outgoing connection
	Dial(address ServerAddress, timeout time.Duration) (net.Conn, error)
}

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

type Transport interface {
	Consumer() <-chan RPC
	SetHeartbeatHandler(cb func(rpc RPC))
}

type WithRPCHeader interface {
	GetRPCHeader() RPCHeader
}