rpc

Documentation

Index

• Constants
• Variables
• func HookMiddlewares(provider *providers.MiddlewarableProvider, url, space string)
• func MustNewCfxClient(url string, options ...ClientOption) *sdk.Client
• func MustNewCfxClientFromViper(options ...ClientOption) *sdk.Client
• func MustNewCfxWsClientFromViper(options ...ClientOption) *sdk.Client
• func MustNewEthClient(url string, options ...ClientOption) *web3go.Client
• func MustNewEthClientFromViper(options ...ClientOption) *web3go.Client
• func NewCfxClient(url string, options ...ClientOption) (*sdk.Client, error)
• func NewEthClient(url string, options ...ClientOption) (*web3go.Client, error)
• func Url2NodeName(url string) string
• type ClientOption
  • func WithClientHookMetrics(hook bool) ClientOption
  • func WithClientMaxConnsPerHost(maxConns int) ClientOption
  • func WithClientRequestTimeout(reqTimeout time.Duration) ClientOption
  • func WithClientRetryCount(retry int) ClientOption
  • func WithClientRetryInterval(retryInterval time.Duration) ClientOption
• type ClientOptioner
• type Protocol
• type Server
  • func MustNewServer(name string, rpcs map[string]interface{}, middlewares ...handlers.Middleware) *Server
  • func (s *Server) MustServe(endpoint string, protocol Protocol)
  • func (s *Server) MustServeGraceful(ctx context.Context, wg *sync.WaitGroup, endpoint string, protocol Protocol)
  • func (s *Server) String() string

Constants

const (
	ProtocolHttp = "HTTP"
	ProtocolWS   = "WS"
)

Variables

var (
	// DefaultShutdownTimeout is default timeout to shutdown RPC server.
	DefaultShutdownTimeout = 3 * time.Second
)

Functions

func HookMiddlewares

func HookMiddlewares(provider *providers.MiddlewarableProvider, url, space string)

func MustNewCfxClient

func MustNewCfxClient(url string, options ...ClientOption) *sdk.Client

func MustNewCfxClientFromViper

func MustNewCfxClientFromViper(options ...ClientOption) *sdk.Client

func MustNewCfxWsClientFromViper

func MustNewCfxWsClientFromViper(options ...ClientOption) *sdk.Client

func MustNewEthClient

func MustNewEthClient(url string, options ...ClientOption) *web3go.Client

func MustNewEthClientFromViper

func MustNewEthClientFromViper(options ...ClientOption) *web3go.Client

func NewCfxClient

func NewCfxClient(url string, options ...ClientOption) (*sdk.Client, error)

func NewEthClient

func NewEthClient(url string, options ...ClientOption) (*web3go.Client, error)

func Url2NodeName

func Url2NodeName(url string) string

Types

type ClientOption

type ClientOption func(opt ClientOptioner)

func WithClientHookMetrics

func WithClientHookMetrics(hook bool) ClientOption

func WithClientMaxConnsPerHost

func WithClientMaxConnsPerHost(maxConns int) ClientOption

func WithClientRequestTimeout

func WithClientRequestTimeout(reqTimeout time.Duration) ClientOption

func WithClientRetryCount

func WithClientRetryCount(retry int) ClientOption

func WithClientRetryInterval

func WithClientRetryInterval(retryInterval time.Duration) ClientOption

type ClientOptioner

type ClientOptioner interface {
	SetRetryCount(retry int)
	SetRetryInterval(retryInterval time.Duration)
	SetRequestTimeout(reqTimeout time.Duration)
	SetMaxConnsPerHost(maxConns int)
	SetHookMetrics(hook bool)
}

type Protocol

type Protocol string

type Server

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

Server serves JSON RPC services.

func MustNewServer

func MustNewServer(name string, rpcs map[string]interface{}, middlewares ...handlers.Middleware) *Server

MustNewServer creates an instance of Server with specified RPC services.

func (*Server) MustServe

func (s *Server) MustServe(endpoint string, protocol Protocol)

MustServe serves RPC server in blocking way or panics if failed.

func (*Server) MustServeGraceful

func (s *Server) MustServeGraceful(
	ctx context.Context, wg *sync.WaitGroup, endpoint string, protocol Protocol,
)

MustServeGraceful serves RPC server in a goroutine until graceful shutdown.

func (*Server) String

func (s *Server) String() string