router

Documentation

Index

• Variables
• type Balancer
• type RPCRequest
  • func (r *RPCRequest) IsDasRequest() bool
  • func (r *RPCRequest) RequestType() RPCRequestType
• type RPCRequestType
• type RoundRobinBalancer
  • func NewRoundRobinBalancer(servers []ServerEndpoint) (*RoundRobinBalancer, error)
  • func (b *RoundRobinBalancer) NextServer() *url.URL
• type Route
  • func (r Route) Balancer() (Balancer, error)
• type RouterHandler
  • func NewRouter(regular Route, das Route) (*RouterHandler, error)
  • func (h *RouterHandler) NextServer(rpcReq *RPCRequest) *url.URL
  • func (h *RouterHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)
• type RpcRoutes
• type ServerEndpoint
  • func ConvertToEndpoint(rawUrl string, weight uint64) (ServerEndpoint, error)
  • func MustConvertToEndpoint(rawUrl string, weight uint64) ServerEndpoint
  • func (s *ServerEndpoint) UnmarshalJSON(data []byte) error
• type WeightedRoundRobinBalancer
  • func NewWeightedRoundRobinBalancer(servers []ServerEndpoint) (*WeightedRoundRobinBalancer, error)
  • func (b *WeightedRoundRobinBalancer) NextServer() *url.URL

Variables

var DasMethods = [...]string{
	"getAsset",
	"searchAssets",
	"getAssetProof",
	"getAssetsByGroup",
	"getAssetsByOwner",
	"getAssetsByCreator",
	"getAssetsByAuthority",
}

Types

type Balancer

type Balancer interface {
	NextServer() *url.URL
}

SIMPLE Balancer interface

type RPCRequest

type RPCRequest struct {
	Method  string      `json:"method"`
	Params  interface{} `json:"params,omitempty"`
	ID      any         `json:"id"`
	JSONRPC string      `json:"jsonrpc"`
}

func (*RPCRequest) IsDasRequest

func (r *RPCRequest) IsDasRequest() bool

func (*RPCRequest) RequestType

func (r *RPCRequest) RequestType() RPCRequestType

type RPCRequestType

type RPCRequestType uint8

const (
	RegularRPCRequest RPCRequestType = 1
	DasRPCRequest     RPCRequestType = 3
)

type RoundRobinBalancer

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

Regular RoundRobin implementation

func NewRoundRobinBalancer

func NewRoundRobinBalancer(servers []ServerEndpoint) (*RoundRobinBalancer, error)

func (*RoundRobinBalancer) NextServer

func (b *RoundRobinBalancer) NextServer() *url.URL

type Route

type Route struct {
	BalancerType string           `json:"balancerType"`
	Servers      []ServerEndpoint `json:"servers"`
}

func (Route) Balancer

func (r Route) Balancer() (Balancer, error)

type RouterHandler

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

func NewRouter

func NewRouter(regular Route, das Route) (*RouterHandler, error)

func (*RouterHandler) NextServer

func (h *RouterHandler) NextServer(rpcReq *RPCRequest) *url.URL

func (*RouterHandler) ServeHTTP

func (h *RouterHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)

type RpcRoutes

type RpcRoutes map[RPCRequestType]Balancer

type ServerEndpoint

type ServerEndpoint struct {
	URL    url.URL `json:"url"`
	Weight uint64  `json:"weight,omitempty"`
}

func ConvertToEndpoint

func ConvertToEndpoint(rawUrl string, weight uint64) (ServerEndpoint, error)

func MustConvertToEndpoint

func MustConvertToEndpoint(rawUrl string, weight uint64) ServerEndpoint

func (*ServerEndpoint) UnmarshalJSON

func (s *ServerEndpoint) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface to fix url.URL

type WeightedRoundRobinBalancer

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

Weighted RoundRobin implementation

func NewWeightedRoundRobinBalancer

func NewWeightedRoundRobinBalancer(servers []ServerEndpoint) (*WeightedRoundRobinBalancer, error)

func (*WeightedRoundRobinBalancer) NextServer

func (b *WeightedRoundRobinBalancer) NextServer() *url.URL