node

Documentation

Index

• Constants
• func NewAnnouncePacket(n *NodeInfo) (string, error)
• func Serve(conf *config.Config)
• type Announcer
  • func (a *Announcer) Start(nodeList *list.List)
• type FileServerResponseInterceptor
  • func (f *FileServerResponseInterceptor) Header() http.Header
  • func (f *FileServerResponseInterceptor) Write(content []byte) (int, error)
  • func (f *FileServerResponseInterceptor) WriteHeader(status int)
• type NodeInfo
  • func ParseAnnouncePacket(size int, addr *net.UDPAddr, packet []byte) (*NodeInfo, error)

Constants

const (
	HTML_BODY = `` /* 1016-byte string literal not displayed */

	HTML_END = `` /* 237-byte string literal not displayed */

)

const (
	MULTICAST_ADDRESS     = "239.6.6.6:1337"
	MULTICAST_BUFFER_SIZE = 4096

	NODE_ANNOUNCE_COMMAND = "\x01"
	HEADER                = "\x60\x0D\xF0\x0D"
	MIN_PACKET_SIZE       = 6

	EXPIRE_TIMEOUT_SEC    = 50
	ANNOUNCE_INTERVAL_SEC = 10
)

Functions

func NewAnnouncePacket

func NewAnnouncePacket(n *NodeInfo) (string, error)

func Serve

func Serve(conf *config.Config)

Types

type Announcer

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

func (*Announcer) Start

func (a *Announcer) Start(nodeList *list.List)

type FileServerResponseInterceptor

type FileServerResponseInterceptor struct {
	OriginalWriter http.ResponseWriter
	IndexBuffer    *bytes.Buffer
}

func (*FileServerResponseInterceptor) Header

func (f *FileServerResponseInterceptor) Header() http.Header

func (*FileServerResponseInterceptor) Write

func (f *FileServerResponseInterceptor) Write(content []byte) (int, error)

func (*FileServerResponseInterceptor) WriteHeader

func (f *FileServerResponseInterceptor) WriteHeader(status int)

type NodeInfo

type NodeInfo struct {
	Id            string `json:"nodeId"`
	Address       string `json:"ipAddress"`
	WebPort       string `json:"webPort"`
	LastMulticast int64  `json:"-"`
}

func ParseAnnouncePacket

func ParseAnnouncePacket(size int, addr *net.UDPAddr, packet []byte) (*NodeInfo, error)