gateway

Documentation

Index

• Variables
• type AvailabilityResponse
• type Config
  • func DefaultConfig() Config
  • func (cfg *Config) Validate() error
• type Handler
  • func NewHandler(state state.Module, share share.Module, header header.Module, das *das.DASer) *Handler
  • func (h *Handler) RegisterEndpoints(rpc *Server)
  • func (h *Handler) RegisterMiddleware(rpc *Server)
• type NamespacedDataResponse
• type NamespacedSharesResponse
• type Server
  • func NewServer(cfg Config) *Server
  • func (s *Server) ListenAddr() string
  • func (s *Server) RegisterHandlerFunc(pattern string, handlerFunc http.HandlerFunc, method string)
  • func (s *Server) RegisterMiddleware(m mux.MiddlewareFunc)
  • func (s *Server) ServeHTTP(w http.ResponseWriter, r *http.Request)
  • func (s *Server) Start(context.Context) error
  • func (s *Server) Stop(context.Context) error

Variables

var (
	ErrInvalidAddressFormat = errors.New("address must be a valid account or validator address")
	ErrMissingAddress       = errors.New("address not specified")
)

Types

type AvailabilityResponse

type AvailabilityResponse struct {
	Available   bool   `json:"available"`
	Probability string `json:"probability_of_availability"`
}

AvailabilityResponse represents the response to a `/data_available` request.

type Config

type Config struct {
	Address string
	Port    string
}

func DefaultConfig

func DefaultConfig() Config

func (*Config) Validate

func (cfg *Config) Validate() error

type Handler

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

func NewHandler

func NewHandler(
	state state.Module,
	share share.Module,
	header header.Module,
	das *das.DASer,
) *Handler

func (*Handler) RegisterEndpoints

func (h *Handler) RegisterEndpoints(rpc *Server)

func (*Handler) RegisterMiddleware

func (h *Handler) RegisterMiddleware(rpc *Server)

type NamespacedDataResponse

type NamespacedDataResponse struct {
	Data   [][]byte `json:"data"`
	Height uint64   `json:"height"`
}

NamespacedDataResponse represents the response to a DataByNamespace request.

type NamespacedSharesResponse

type NamespacedSharesResponse struct {
	Shares []share.Share `json:"shares"`
	Height uint64        `json:"height"`
}

NamespacedSharesResponse represents the response to a SharesByNamespace request.

type Server

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

Server represents an RPC server on the Node. TODO @renaynay: eventually, gateway server should be able to be toggled on and off.

func NewServer

func NewServer(cfg Config) *Server

NewServer returns a new RPC Server.

func (*Server) ListenAddr

func (s *Server) ListenAddr() string

ListenAddr returns the listen address of the server.

func (*Server) RegisterHandlerFunc

func (s *Server) RegisterHandlerFunc(pattern string, handlerFunc http.HandlerFunc, method string)

RegisterHandlerFunc registers the given http.HandlerFunc on the Server's multiplexer on the given pattern.

func (*Server) RegisterMiddleware

func (s *Server) RegisterMiddleware(m mux.MiddlewareFunc)

RegisterMiddleware allows to register a custom middleware that will be called before http.Request will reach handler.

func (*Server) ServeHTTP

func (s *Server) ServeHTTP(w http.ResponseWriter, r *http.Request)

ServeHTTP serves inbound requests on the Server.

func (*Server) Start

func (s *Server) Start(context.Context) error

Start starts the RPC Server, listening on the given address.

func (*Server) Stop

func (s *Server) Stop(context.Context) error

Stop stops the RPC Server.