node

Documentation

Index

• Variables
• type Config
  • func GetConfig() *Config
• type RpcNode
  • func New() (*RpcNode, error)
  • func NewWithConf(config *Config) (*RpcNode, error)
  • func (n *RpcNode) Start()

Variables

var (
	DefaultPathPrefix string = "*"
)

Types

type Config

type Config struct {
	HttpPort           int16         `mapstructure:"httpPort"`
	HttpHost           string        `mapstructure:"httpHost"`
	HttpCors           []string      `mapstructure:"httpCors"`
	HttpCompress       bool          `mapstructure:"httpCompress"`
	HttpTimeout        time.Duration `mapstructure:"httpTimeout"`
	HttpPathPrefix     string        `mapstructure:"httpPathPrefix"`
	WsPort             int16         `mapstructure:"wsPort"`
	WsHost             string        `mapstructure:"wsHost"`
	WsPathPrefix       string        `mapstructure:"wsPathPrefix"`
	WsHandshakeTimeout time.Duration `mapstructure:"wsHandshakeTimeout"`
	MaxBatchRequests   uint          `mapstructure:"maxBatchRequests"`
}

func GetConfig

func GetConfig() *Config

type RpcNode

type RpcNode struct {
	rpc.RpcServer
	Broker broker.Broker
}

func New

func New() (*RpcNode, error)

func NewWithConf

func NewWithConf(config *Config) (*RpcNode, error)

func (*RpcNode) Start

func (n *RpcNode) Start()

Start starts RPC server as a seperate go routine