tilerouter

Documentation

Index

• Constants
• Variables
• type RenderSelector
  • func NewRenderSelector(renders []string, pingPeriod time.Duration, timeout time.Duration) (*RenderSelector, error)
  • func (self *RenderSelector) FreeConnection(conn *thriftConn)
  • func (self *RenderSelector) SelectRender(coord gopnik.TileCoord) (*thriftConn, error)
  • func (self *RenderSelector) SetStatus(addr string, status int)
  • func (self *RenderSelector) Stop()
• type RouterServer
  • func NewRouterServer(cl gopnik.ClusterPluginInterface, cp gopnik.CachePluginInterface, ...) (*RouterServer, error)
  • func (srv *RouterServer) ServeHTTP(w http.ResponseWriter, r *http.Request)
• type TileRouter
  • func NewTileRouter(renders []string, timeout time.Duration, pingPeriod time.Duration) (*TileRouter, error)
  • func (self *TileRouter) Tile(coord gopnik.TileCoord) (img []byte, err error)
  • func (self *TileRouter) UpdateRenders(renders []string)

Constants

const (
	Offline = iota
	Online
)

Variables

var ATTEMPTS = 2

Types

type RenderSelector

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

func NewRenderSelector

func NewRenderSelector(renders []string, pingPeriod time.Duration, timeout time.Duration) (*RenderSelector, error)

func (*RenderSelector) FreeConnection

func (self *RenderSelector) FreeConnection(conn *thriftConn)

func (*RenderSelector) SelectRender

func (self *RenderSelector) SelectRender(coord gopnik.TileCoord) (*thriftConn, error)

func (*RenderSelector) SetStatus

func (self *RenderSelector) SetStatus(addr string, status int)

func (*RenderSelector) Stop

func (self *RenderSelector) Stop()

type RouterServer

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

func NewRouterServer

func NewRouterServer(cl gopnik.ClusterPluginInterface,
	cp gopnik.CachePluginInterface, filter gopnik.FilterPluginInterface,
	renderTimeout time.Duration, pingPeriod time.Duration) (*RouterServer, error)

func (*RouterServer) ServeHTTP

func (srv *RouterServer) ServeHTTP(w http.ResponseWriter, r *http.Request)

type TileRouter

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

func NewTileRouter

func NewTileRouter(renders []string, timeout time.Duration, pingPeriod time.Duration) (*TileRouter, error)

func (*TileRouter) Tile

func (self *TileRouter) Tile(coord gopnik.TileCoord) (img []byte, err error)

func (*TileRouter) UpdateRenders

func (self *TileRouter) UpdateRenders(renders []string)