rpc

Apr 25, 2024

Changes in this version

type Client

+ IsDebug bool

Apr 12, 2024

Changes in this version

+ const EngineApi

+ const MetadataApi

+ var ErrNotificationsUnsupported = notificationsUnsupportedError

+ var ErrSubscriptionNotFound = errors.New("subscription not found")

+ type BatchElem struct

+ Args []interface{}

+ Error error

+ Method string

+ Result interface{}

type Client

+ func DialHTTP(endpoint string) (*Client, error)

+ func DialHTTPWithClient(endpoint string, client *http.Client) (*Client, error)

+ func DialWebsocket(ctx context.Context, endpoint, origin string) (*Client, error)

+ func DialWebsocketWithDialer(ctx context.Context, endpoint, origin string, dialer websocket.Dialer) (*Client, error)

+ func (c *Client) BatchCall(b []BatchElem) error

+ func (c *Client) BatchCallContext(ctx context.Context, b []BatchElem) error

+ func (c *Client) Notify(ctx context.Context, method string, args ...interface{}) error

+ func (c *Client) RegisterName(name string, receiver interface{}) error

+ func (c *Client) Subscribe(ctx context.Context, namespace string, channel interface{}, ...) (*ClientSubscription, error)

+ func (c *Client) SupportedModules() (map[string]string, error)

+ func (c *Client) SupportsSubscriptions() bool

+ type ClientSubscription struct

+ func (sub *ClientSubscription) Err() <-chan error

+ func (sub *ClientSubscription) Unsubscribe()

+ type CodecOption int

+ const OptionMethodInvocation

+ const OptionSubscriptions

+ type ID string

+ func NewID() ID

+ type Notifier struct

+ func NotifierFromContext(ctx context.Context) (*Notifier, bool)

+ func (n *Notifier) Closed() <-chan interface{}

+ func (n *Notifier) CreateSubscription() *Subscription

+ func (n *Notifier) Notify(id ID, data any) error

+ type PeerInfo struct

+ HTTP struct{ ... }

+ RemoteAddr string

+ Transport string

+ func PeerInfoFromContext(ctx context.Context) PeerInfo

+ type RPCService struct

+ func (s *RPCService) Modules() map[string]string

+ type Server struct

+ func NewServer() *Server

+ func (s *Server) RegisterName(name string, receiver interface{}) error

+ func (s *Server) ServeCodec(codec ServerCodec, options CodecOption)

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

+ func (s *Server) SetBatchLimits(itemLimit, maxResponseSize int)

+ func (s *Server) SetHTTPBodyLimit(limit int)

+ func (s *Server) Stop()

+ func (s *Server) WebsocketHandler(allowedOrigins []string) http.Handler

+ type Subscription struct

+ ID ID

+ func (s *Subscription) Err() <-chan error

+ func (s *Subscription) MarshalJSON() ([]byte, error)

Apr 4, 2024

Changes in this version

+ const DevnetRPCEndpoint

+ const LocalnetRPCEndpoint

+ const MainnetRPCEndpoint

+ const TestnetRPCEndpoint

+ var DefaultHTTPTimeouts = HTTPTimeouts

+ var ErrBadResult = errors.New("bad result in JSON-RPC response")

+ var ErrClientQuit = errors.New("client is closed")

+ var ErrMissingBatchResponse = errors.New("response batch did not contain a response to this call")

+ var ErrNoResult = errors.New("JSON-RPC response has no result")

+ var ErrSubscriptionQueueOverflow = errors.New("subscription queue overflow")

+ func ContextRequestTimeout(ctx context.Context) (time.Duration, bool)

+ func NewContextWithHeaders(ctx context.Context, h http.Header) context.Context

+ type Client struct

+ func ClientFromContext(ctx context.Context) (*Client, bool)

+ func Dial(rawurl string) (*Client, error)

+ func DialContext(ctx context.Context, rawurl string) (*Client, error)

+ func DialOptions(ctx context.Context, rawurl string, options ...ClientOption) (*Client, error)

+ func (c *Client) Call(result interface{}, method string, args ...interface{}) error

+ func (c *Client) CallContext(ctx context.Context, result interface{}, method string, args ...interface{}) error

+ func (c *Client) Close()

+ func (c *Client) SetHeader(key, value string)

+ type ClientOption interface

+ func WithBatchItemLimit(limit int) ClientOption

+ func WithBatchResponseSizeLimit(sizeLimit int) ClientOption

+ func WithHTTPAuth(a HTTPAuth) ClientOption

+ func WithHTTPClient(c *http.Client) ClientOption

+ func WithHeader(key, value string) ClientOption

+ func WithHeaders(headers http.Header) ClientOption

+ type Conn interface

+ SetWriteDeadline func(time.Time) error

+ type ConnRemoteAddr interface

+ RemoteAddr func() string

+ type DataError interface

+ Error func() string

+ ErrorData func() interface{}

+ type Error interface

+ Error func() string

+ ErrorCode func() int

+ type HTTPAuth func(h http.Header) error

+ type HTTPError struct

+ Body []byte

+ Status string

+ StatusCode int

+ func (err HTTPError) Error() string

+ type HTTPTimeouts struct

+ IdleTimeout time.Duration

+ ReadHeaderTimeout time.Duration

+ ReadTimeout time.Duration

+ WriteTimeout time.Duration

+ type ServerCodec interface

+ func NewCodec(conn Conn) ServerCodec

+ func NewFuncCodec(conn deadlineCloser, encode encodeFunc, decode decodeFunc) ServerCodec