com

type Client ¶

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

This struct handles socket connection to the hub

func Connect(host string) *Client

func (client *Client) Close()

func (client *Client) Receive() map[string]interface{}

func (client *Client) Send(message string)

type CollectHandler ¶

type CollectHandler func(message string) string

Collect member infos and return nil until the amount of members is reached

type CompleteHandler ¶

type CompleteHandler func()

Complete the hub and end the listening

type GenerateHandler ¶

type GenerateHandler func() map[string][]byte

Generate genesis if the amount of members is reached

type Hub ¶

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

This struct handles multiple members socket to collect their infos and then send them back the output of the gathering (aka a genesis)

func NewHub(collect CollectHandler, generate GenerateHandler, complete CompleteHandler) *Hub

func (hub *Hub) HandleConnection(resp http.ResponseWriter, req *http.Request)

func (hub *Hub) Listen()

type Member ¶

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

This struct handles socket connection in the Hub

type Message ¶

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

type WebsocketHandler ¶

type WebsocketHandler func(resp http.ResponseWriter, req *http.Request)