statserver

Documentation

Index

• Constants
• type City
• type Client
• type Country
• type Peer
• type Server
  • func (server *Server) ListenAndServe() error
  • func (server *Server) OnBytesReceived(ip string, bytes int64)
  • func (server *Server) OnBytesSent(ip string, bytes int64)
• type Update

Constants

const (
	GEOSERVE_URL_TEMPLATE = "http://go-geoserve.herokuapp.com/lookup/%s"
)

Types

type City

type City struct {
	City struct {
		GeoNameID uint              `maxminddb:"geoname_id"`
		Names     map[string]string `maxminddb:"names"`
	} `maxminddb:"city"`
	Continent struct {
		Code      string            `maxminddb:"code"`
		GeoNameID uint              `maxminddb:"geoname_id"`
		Names     map[string]string `maxminddb:"names"`
	} `maxminddb:"continent"`
	Country struct {
		GeoNameID uint              `maxminddb:"geoname_id"`
		IsoCode   string            `maxminddb:"iso_code"`
		Names     map[string]string `maxminddb:"names"`
	} `maxminddb:"country"`
	Location struct {
		Latitude  float64 `maxminddb:"latitude"`
		Longitude float64 `maxminddb:"longitude"`
		MetroCode uint    `maxminddb:"metro_code"`
		TimeZone  string  `maxminddb:"time_zone"`
	} `maxminddb:"location"`
	Postal struct {
		Code string `maxminddb:"code"`
	} `maxminddb:"postal"`
	RegisteredCountry struct {
		GeoNameID uint              `maxminddb:"geoname_id"`
		IsoCode   string            `maxminddb:"iso_code"`
		Names     map[string]string `maxminddb:"names"`
	} `maxminddb:"registered_country"`
	RepresentedCountry struct {
		GeoNameID uint              `maxminddb:"geoname_id"`
		IsoCode   string            `maxminddb:"iso_code"`
		Names     map[string]string `maxminddb:"names"`
		Type      string            `maxminddb:"type"`
	} `maxminddb:"represented_country"`
	Subdivisions []struct {
		GeoNameID uint              `maxminddb:"geoname_id"`
		IsoCode   string            `maxminddb:"iso_code"`
		Names     map[string]string `maxminddb:"names"`
	} `maxminddb:"subdivisions"`
	Traits struct {
		IsAnonymousProxy    bool `maxminddb:"is_anonymous_proxy"`
		IsSatelliteProvider bool `maxminddb:"is_satellite_provider"`
	} `maxminddb:"traits"`
}

The City structure corresponds to the data in the GeoIP2/GeoLite2 City databases.

type Client

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

Client represents a client connected to the Server

type Country

type Country struct {
	Continent struct {
		Code      string            `maxminddb:"code"`
		GeoNameID uint              `maxminddb:"geoname_id"`
		Names     map[string]string `maxminddb:"names"`
	} `maxminddb:"continent"`
	Country struct {
		GeoNameID uint              `maxminddb:"geoname_id"`
		IsoCode   string            `maxminddb:"iso_code"`
		Names     map[string]string `maxminddb:"names"`
	} `maxminddb:"country"`
	RegisteredCountry struct {
		GeoNameID uint              `maxminddb:"geoname_id"`
		IsoCode   string            `maxminddb:"iso_code"`
		Names     map[string]string `maxminddb:"names"`
	} `maxminddb:"registered_country"`
	RepresentedCountry struct {
		GeoNameID uint              `maxminddb:"geoname_id"`
		IsoCode   string            `maxminddb:"iso_code"`
		Names     map[string]string `maxminddb:"names"`
		Type      string            `maxminddb:"type"`
	} `maxminddb:"represented_country"`
	Traits struct {
		IsAnonymousProxy    bool `maxminddb:"is_anonymous_proxy"`
		IsSatelliteProvider bool `maxminddb:"is_satellite_provider"`
	} `maxminddb:"traits"`
}

The Country structure corresponds to the data in the GeoIP2/GeoLite2 Country databases.

type Peer

type Peer struct {
	IP            string    `json:"peerid"`
	LastConnected time.Time `json:"lastConnected"`
	BytesDn       int64     `json:"bytesDn"`
	BytesUp       int64     `json:"bytesUp"`
	BytesUpDn     int64     `json:"bytesUpDn"`
	BPSDn         int64     `json:"bpsDn"`
	BPSUp         int64     `json:"bpsUp"`
	BPSUpDn       int64     `json:"bpsUpDn"`
	Country       string    `json:"country"`
	Latitude      float64   `json:"lat"`
	Longitude     float64   `json:"lon"`
	// contains filtered or unexported fields
}

Peer represents information about a peer

type Server

type Server struct {
	Addr string
	// contains filtered or unexported fields
}

Server provides an SSE server that publishes stat updates for peers. See (http://www.html5rocks.com/en/tutorials/eventsource/basics/) for more about Server-Sent Events.

func (*Server) ListenAndServe

func (server *Server) ListenAndServe() error

func (*Server) OnBytesReceived

func (server *Server) OnBytesReceived(ip string, bytes int64)

func (*Server) OnBytesSent

func (server *Server) OnBytesSent(ip string, bytes int64)

type Update

type Update struct {
	Type string      `json:"type"`
	Data interface{} `json:"data"`
}