sdkrouter

Documentation

Index

• Constants
• func AddToRequest(rt *Router, fn http.HandlerFunc) http.HandlerFunc
• func DisableLogger()
• func GetLbrynetServer(u *models.User) *models.LbrynetServer
• func GetSDKAddress(u *models.User) string
• func Middleware(rt *Router) mux.MiddlewareFunc
• func WalletID(userID int) string
• type Router
  • func FromRequest(r *http.Request) *Router
  • func New(servers map[string]string) *Router
  • func NewWithServers(servers ...*models.LbrynetServer) *Router
  • func (r *Router) GetAll() []*models.LbrynetServer
  • func (r *Router) LeastLoaded() *models.LbrynetServer
  • func (r *Router) RandomServer() *models.LbrynetServer
  • func (r *Router) WatchLoad()

Constants

const RPCTimeout = 300 * time.Second

Functions

func AddToRequest

func AddToRequest(rt *Router, fn http.HandlerFunc) http.HandlerFunc

func DisableLogger

func DisableLogger()

func GetLbrynetServer

func GetLbrynetServer(u *models.User) *models.LbrynetServer

func GetSDKAddress

func GetSDKAddress(u *models.User) string

func Middleware

func Middleware(rt *Router) mux.MiddlewareFunc

func WalletID

func WalletID(userID int) string

WalletID formats user ID to use as an LbrynetServer wallet ID.

Types

type Router

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

func FromRequest

func FromRequest(r *http.Request) *Router

func New

func New(servers map[string]string) *Router

func NewWithServers

func NewWithServers(servers ...*models.LbrynetServer) *Router

func (*Router) GetAll

func (r *Router) GetAll() []*models.LbrynetServer

func (*Router) LeastLoaded

func (r *Router) LeastLoaded() *models.LbrynetServer

LeastLoaded returns the least-loaded wallet

func (*Router) RandomServer

func (r *Router) RandomServer() *models.LbrynetServer

func (*Router) WatchLoad

func (r *Router) WatchLoad()

WatchLoad keeps updating the metrics on the number of wallets loaded for each instance