gather

type GatherMessage ¶

type GatherMessage struct {
	Type  GatherMessageType
	Addrs []peer.AddrInfo
}

GatherMessage represents a set of all different messages possible to be sent in the gather protocol. This kind of all-in-one message is only possible because of the simplicity of the protocol bus is potentially inefficient. If any of the message types were to have additional fields, the messages of all other types would have to have these additional fields, even though they don't need them. (TODO: consider protobuf).

type GatherMessageType ¶

type GatherMessageType int

type GatherPointBeacon ¶

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

func NewGatherPointBeacon(topic *pubsub.Topic, self peer.AddrInfo, n int, TTL time.Duration) *GatherPointBeacon

func (b *GatherPointBeacon) Close()

type GatherPointMessage ¶

type GatherPointMessage struct {
	ConnectTo          peer.AddrInfo
	TTL                time.Duration
	DesiredPlayerCount uint
	CurrentPlayerCount uint
}

type GatherService ¶

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

func NewGatherService(h host.Host, topic *pubsub.Topic, game *game.GameService, ping *ping.PingService, n int, TTL time.Duration, gameCh chan<- game.GameEstablished) (*GatherService, error)

func (gs *GatherService) Close()

func (gs *GatherService) GatherHandler(stream network.Stream)

type JoinService ¶

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

func NewJoinService(ctx context.Context, h host.Host, game *game.GameService, ping *ping.PingService, pID peer.ID, gameCh chan<- game.GameEstablished) (*JoinService, error)

func (js *JoinService) Close()