proxy

May 19, 2020

Changes in this version

+ func GetAuthError(user *models.User, err error) error

Apr 22, 2020

Changes in this version

+ func EnsureAuthenticated(ar auth.Result, w http.ResponseWriter) bool

+ func Handle(w http.ResponseWriter, r *http.Request)

+ func HandleCORS(w http.ResponseWriter, r *http.Request)

+ func MethodNeedsAuth(method string) bool

type Caller

+ Preprocessor func(q *Query)

+ func NewCaller(endpoint string, userID int) *Caller

+ func (c *Caller) CallRaw(rawQuery []byte) []byte

type Query

+ WalletID string

+ type RPCError struct

+ func NewAuthRequiredError(e error) RPCError

+ func NewForbiddenError(e error) RPCError

+ func NewInvalidParamsError(e error) RPCError

+ func NewJSONParseError(e error) RPCError

+ func NewMethodNotAllowedError(e error) RPCError

+ func NewSDKError(e error) RPCError

+ func (e RPCError) Code() int

+ func (e RPCError) Error() string

+ func (e RPCError) JSON() []byte

+ func (e RPCError) Unwrap() error

Apr 10, 2020

Changes in this version

type ProxyService

+ SDKRouter *sdkrouter.Router

Feb 7, 2020

Changes in this version

+ type InputError struct

+ func NewInputError(e error) InputError

+ func (e InputError) Code() int

Feb 4, 2020

Changes in this version

+ var ClientLogger = monitor.NewModuleLogger("proxy_client")

+ var Logger = monitor.NewProxyLogger()

+ type Client struct

+ func (c Client) Call(q *Query) (*jsonrpc.RPCResponse, error)

+ type LbrynetClient interface

+ Call func(q *Query) (*jsonrpc.RPCResponse, error)

+ func NewClient(endpoint string, wallet string, timeout time.Duration) LbrynetClient

Jan 21, 2020

Changes in this version

+ type Opts struct

+ RPCTimeout time.Duration

+ SDKRouter router.SDKRouter

Jan 20, 2020

Changes in this version

+ var CacheLogger = monitor.NewModuleLogger("proxy_cache")

Nov 15, 2019

Changes in this version

+ type ProxyService struct

+ Router router.SDKRouter

+ func (ps *ProxyService) NewCaller(walletID string) *Caller

Oct 1, 2019

Changes in this version

type Caller

+ func (c *Caller) SetWalletID(id string)

+ func (c *Caller) WalletID() string

type GenericError

+ func (e GenericError) Unwrap() error

type Query

+ func (q *Query) SetWalletID(id string)

Sep 19, 2019

Changes in this version

type RequestHandler

+ func NewRequestHandler(svc *Service) *RequestHandler

+ func (rh *RequestHandler) HandleOptions(w http.ResponseWriter, r *http.Request)

Sep 5, 2019

Changes in this version

+ const MethodAccountBalance

+ const MethodAccountList

+ const MethodClaimSearch

+ const MethodCommentList

+ const MethodFileList

+ const MethodGet

+ const MethodResolve

+ const MethodStatus

type Caller

+ func (c *Caller) SetPreprocessor(p Preprocessor)

+ type Preprocessor func(q *Query)

type Query

+ func (q *Query) ParamsToStruct(targetStruct interface{}) error

+ type RequestServer struct

+ func NewRequestServer(svc *Service) *RequestServer

+ func (rh *RequestServer) Handle(w http.ResponseWriter, r *http.Request)

Aug 15, 2019

Changes in this version

+ const ErrAuthFailed

+ const ErrInvalidRequest

+ const ErrJSONParse

+ const ErrMethodUnavailable

+ var ResolveTime float64

+ type AuthFailed struct

+ func (e AuthFailed) Code() int

+ func (e AuthFailed) Error() string

+ type CallError interface

+ AsRPCResponse func() *jsonrpc.RPCResponse

+ Code func() int

+ Error func() string

+ type Caller struct

+ func (c *Caller) AccountID() string

+ func (c *Caller) Call(rawQuery []byte) []byte

+ func (c *Caller) SetAccountID(id string)

+ type GenericError struct

+ func NewError(e error) GenericError

+ func NewInternalError(e error) GenericError

+ func NewMethodError(e error) GenericError

+ func NewParamsError(e error) GenericError

+ func NewParseError(e error) GenericError

+ func (e GenericError) AsRPCResponse() *jsonrpc.RPCResponse

+ func (e GenericError) Code() int

+ func (e GenericError) Error() string

+ type Query struct

+ Request *jsonrpc.RPCRequest

+ func NewQuery(r []byte) (*Query, error)

+ func (q *Query) Method() string

+ func (q *Query) Params() interface{}

+ func (q *Query) ParamsAsMap() map[string]interface{}

+ type RequestHandler struct

+ func (rh *RequestHandler) Handle(w http.ResponseWriter, r *http.Request)

+ type Service struct

+ TargetEndpoint string

+ func NewService(targetEndpoint string) *Service

+ func (ps *Service) NewCaller() *Caller

Jul 2, 2019

Changes in this version

+ const ErrInternal

+ const ErrInvalidParams

+ const ErrMethodNotFound

+ const ErrProxy

+ const ErrProxyAuthFailed

+ func ForwardCall(request jsonrpc.RPCRequest) ([]byte, error)

+ func InitResponseCache(c ResponseCache)

+ func MarshalResponse(r *jsonrpc.RPCResponse) ([]byte, error)

+ func MethodRequiresAccountID(method string) bool

+ func NewErrorResponse(message string, code int) *jsonrpc.RPCResponse

+ func NewRequest(method string, params ...interface{}) jsonrpc.RPCRequest

+ func Proxy(r *jsonrpc.RPCRequest, accountID string) ([]byte, error)

+ func RawCall(request jsonrpc.RPCRequest) (*jsonrpc.RPCResponse, error)

+ func UnmarshalRequest(r []byte) (*jsonrpc.RPCRequest, error)

+ type ResponseCache interface

+ Count func() int

+ Retrieve func(method string, params interface{}) interface{}

+ Save func(method string, params interface{}, r interface{})