server

Documentation

Index

• Constants
• func NewServer(addr string)
• type CatMux
  • func (c *CatMux) ServeHTTP(w http.ResponseWriter, r *http.Request)
• type Cluster
  • func (c *Cluster) Broadcast(msg *Message)
  • func (c *Cluster) Send(entrypoint string, msg *Message) error
• type Message
• type MessageType

Constants

const (
	MessageTypeNodeJoin = 1000 + iota
)

Functions

func NewServer

func NewServer(addr string)

Types

type CatMux

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

func (*CatMux) ServeHTTP

func (c *CatMux) ServeHTTP(w http.ResponseWriter, r *http.Request)

type Cluster

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

func (*Cluster) Broadcast

func (c *Cluster) Broadcast(msg *Message)

func (*Cluster) Send

func (c *Cluster) Send(entrypoint string, msg *Message) error

type Message

type Message struct {
	Type    MessageType
	Message []byte
}

type MessageType

type MessageType int