Skip to content

package network

import "kaiju/network"

Types

ClientMessage

struct

type ClientMessage struct {
    Client *ServerClient
    // Has unexported fields.
}

ClientMessage.IsFromServer

func (c *ClientMessage) IsFromServer() bool

ClientMessage.Message

func (c *ClientMessage) Message() []byte

NetworkClient

struct

type NetworkClient struct {
    NetworkUDP
    ServerClient
    ServerMessageQueue concurrent.MessageQueue[ClientMessage]
}

NewClientUDP

func NewClientUDP() NetworkClient

NetworkClient.Connect

func (c *NetworkClient) Connect(updater *engine.Updater, address string, port uint16) error

NetworkClient.ReadMessages

func (c *NetworkClient) ReadMessages()

NetworkClient.SendMessageReliable

func (c *NetworkClient) SendMessageReliable(message []byte) error

NetworkClient.SendMessageUnreliable

func (c *NetworkClient) SendMessageUnreliable(message []byte) error

NetworkPacketUDP

struct

type NetworkPacketUDP struct {
    // Has unexported fields.
}

NetworkServer

struct

type NetworkServer struct {
    NetworkUDP
    ClientMessageQueue concurrent.MessageQueue[ClientMessage]

    // Has unexported fields.
}

NewServerUDP

func NewServerUDP() NetworkServer

NetworkServer.HolePunchClient

func (s *NetworkServer) HolePunchClient(address string, port uint16) (*ServerClient, error)

NetworkServer.SendMessageReliable

func (c *NetworkServer) SendMessageReliable(message []byte, client *ServerClient) error

NetworkServer.SendMessageUnreliable

func (c *NetworkServer) SendMessageUnreliable(message []byte, client *ServerClient) error

NetworkServer.Serve

func (s *NetworkServer) Serve(updater *engine.Updater, port uint16) error

NetworkUDP

struct

type NetworkUDP struct {
    // Has unexported fields.
}

NetworkUDP.Close

func (n *NetworkUDP) Close(updater *engine.Updater)

NetworkUDP.IsLive

func (n *NetworkUDP) IsLive() bool

PendingNetworkPacketUDP

struct

type PendingNetworkPacketUDP struct {
    // Has unexported fields.
}

ServerClient

struct

type ServerClient struct {
    // Has unexported fields.
}

ServerClient.Address

func (c *ServerClient) Address() string

ServerClient.Id

func (c *ServerClient) Id() int

ServerClient.PortlessAddress

func (c *ServerClient) PortlessAddress() string