server

Documentation

Index

• Constants
• func GetHostname() (string, error)
• type Http
  • func (p *Http) NewServer() Server
• type HttpOptions
• type HttpServer
  • func (s *HttpServer) DiscoveryRegister(key, value interface{}) bool
  • func (s *HttpServer) GetEvent() <-chan int
  • func (s *HttpServer) Register(m any)
  • func (s *HttpServer) RegisterWithName(m any, name string)
  • func (s *HttpServer) SetAfterFunc(afterFunc func(id any, method string, result any) error)
  • func (s *HttpServer) SetBeforeFunc(beforeFunc func(id any, method string, params any) error)
  • func (s *HttpServer) SetDiscovery(d discovery.Driver, hostname string)
  • func (s *HttpServer) SetOptions(httpOptions any)
  • func (s *HttpServer) SetRateLimit(r rate.Limit, b int)
  • func (s *HttpServer) Start() error
• type Protocol
• type Server
  • func NewServer[T Protocol](p T) Server
• type Tcp
  • func (p *Tcp) NewServer() Server
• type TcpOptions
• type TcpServer
  • func (s *TcpServer) DiscoveryRegister(key, value interface{}) bool
  • func (s *TcpServer) GetEvent() <-chan int
  • func (s *TcpServer) Register(m any)
  • func (s *TcpServer) RegisterWithName(m any, name string)
  • func (s *TcpServer) SetAfterFunc(afterFunc func(id any, method string, result any) error)
  • func (s *TcpServer) SetBeforeFunc(beforeFunc func(id any, method string, params any) error)
  • func (s *TcpServer) SetDiscovery(d discovery.Driver, hostname string)
  • func (s *TcpServer) SetOptions(tcpOptions any)
  • func (s *TcpServer) SetRateLimit(r rate.Limit, b int)
  • func (s *TcpServer) Start() error

Constants

const REGISTRY_RETRY_INTERVAL = 3000

Functions

func GetHostname

func GetHostname() (string, error)

Types

type Http

type Http struct {
	Hostname string
	Port     int
}

func (*Http) NewServer

func (p *Http) NewServer() Server

type HttpOptions

type HttpOptions struct {
}

type HttpServer

type HttpServer struct {
	Hostname  string
	Port      int
	Server    common.Server
	Options   HttpOptions
	Event     chan int
	Discovery discovery.Driver
}

func (*HttpServer) DiscoveryRegister

func (s *HttpServer) DiscoveryRegister(key, value interface{}) bool

func (*HttpServer) GetEvent

func (s *HttpServer) GetEvent() <-chan int

func (*HttpServer) Register

func (s *HttpServer) Register(m any)

func (*HttpServer) RegisterWithName

func (s *HttpServer) RegisterWithName(m any, name string)

func (*HttpServer) SetAfterFunc

func (s *HttpServer) SetAfterFunc(afterFunc func(id any, method string, result any) error)

func (*HttpServer) SetBeforeFunc

func (s *HttpServer) SetBeforeFunc(beforeFunc func(id any, method string, params any) error)

func (*HttpServer) SetDiscovery

func (s *HttpServer) SetDiscovery(d discovery.Driver, hostname string)

func (*HttpServer) SetOptions

func (s *HttpServer) SetOptions(httpOptions any)

func (*HttpServer) SetRateLimit

func (s *HttpServer) SetRateLimit(r rate.Limit, b int)

func (*HttpServer) Start

func (s *HttpServer) Start() error

type Protocol

type Protocol interface {
	NewServer() Server
}

type Server

type Server interface {
	SetBeforeFunc(func(id any, method string, params any) error)
	SetAfterFunc(func(id any, method string, result any) error)
	SetOptions(any)
	SetDiscovery(d discovery.Driver, hostname string)
	SetRateLimit(rate.Limit, int)
	Start() error
	Register(s any)
	RegisterWithName(s any, name string)
	DiscoveryRegister(key, value interface{}) bool
	GetEvent() <-chan int
}

func NewServer

func NewServer[T Protocol](p T) Server

type Tcp

type Tcp struct {
	Hostname string
	Port     int
}

func (*Tcp) NewServer

func (p *Tcp) NewServer() Server

type TcpOptions

type TcpOptions struct {
	ReqCheckEof  string
	RespAddEof   string
	ReqMaxLength int64
}

type TcpServer

type TcpServer struct {
	Hostname  string
	Port      int
	Server    common.Server
	Options   TcpOptions
	Event     chan int
	Discovery discovery.Driver
}

func (*TcpServer) DiscoveryRegister

func (s *TcpServer) DiscoveryRegister(key, value interface{}) bool

func (*TcpServer) GetEvent

func (s *TcpServer) GetEvent() <-chan int

func (*TcpServer) Register

func (s *TcpServer) Register(m any)

func (*TcpServer) RegisterWithName

func (s *TcpServer) RegisterWithName(m any, name string)

func (*TcpServer) SetAfterFunc

func (s *TcpServer) SetAfterFunc(afterFunc func(id any, method string, result any) error)

func (*TcpServer) SetBeforeFunc

func (s *TcpServer) SetBeforeFunc(beforeFunc func(id any, method string, params any) error)

func (*TcpServer) SetDiscovery

func (s *TcpServer) SetDiscovery(d discovery.Driver, hostname string)

func (*TcpServer) SetOptions

func (s *TcpServer) SetOptions(tcpOptions any)

func (*TcpServer) SetRateLimit

func (s *TcpServer) SetRateLimit(r rate.Limit, b int)

func (*TcpServer) Start

func (s *TcpServer) Start() error