rpcxserver

Documentation

Index

• Variables
• type BaseOptions
• type CustomOptions
• type RateLimitOption
• type RegistryOption
• type RpcXServer
  • func NewServer() *RpcXServer
  • func (s *RpcXServer) AddOnShutdownAction(fn func(s *server.Server))
  • func (s *RpcXServer) AddOnStartAction(fn func(s *server.Server))
  • func (s *RpcXServer) Start()
• type ServerOption

Variables

var (
	DefaultCustomOptions = &CustomOptions{}
)

Types

type BaseOptions

type BaseOptions struct {
	Server    ServerOption
	Registry  RegistryOption
	RateLimit RateLimitOption
}

type CustomOptions

type CustomOptions struct {
	Service interface{}
	Plugin  []server.Plugin
}

type RateLimitOption

type RateLimitOption struct {
	Enable       bool
	FillInterval time.Duration
	Capacity     int64
}

type RegistryOption

type RegistryOption struct {
	Addr           []string
	BasePath       string
	UpdateInterval time.Duration
	Group          string
}

type RpcXServer

type RpcXServer struct {
	ServerName string
	Server     *server.Server
	// contains filtered or unexported fields
}

func NewServer

func NewServer() *RpcXServer

func (*RpcXServer) AddOnShutdownAction

func (s *RpcXServer) AddOnShutdownAction(fn func(s *server.Server))

func (*RpcXServer) AddOnStartAction

func (s *RpcXServer) AddOnStartAction(fn func(s *server.Server))

func (*RpcXServer) Start

func (s *RpcXServer) Start()

type ServerOption

type ServerOption struct {
	Name    string
	Addr    string
	Network string
	Port    string
}