server

Documentation

Index

• Constants
• type Config
• type Pipe
  • func (p *Pipe) Close() error
  • func (p *Pipe) Event() uint32
  • func (p *Pipe) GetPrivate() interface{}
  • func (p *Pipe) ID() uint32
  • func (p *Pipe) LocalAddr() string
  • func (p *Pipe) Pipe() mangos.Pipe
  • func (p *Pipe) RecvMsg() *mproto.Message
  • func (p *Pipe) RemoteAddr() string
  • func (p *Pipe) RemoteID() uint32
  • func (p *Pipe) SendMsg(m *mproto.Message) error
  • func (p *Pipe) SetEvent(v uint32)
  • func (p *Pipe) SetPrivate(v interface{})
  • func (p *Pipe) Stop()
• type Protocol
  • func NewProtocol(exchangeLines int) *Protocol
  • func (s *Protocol) AddPipe(pp mproto.Pipe) error
  • func (s *Protocol) Close() error
  • func (s *Protocol) Exchange()
  • func (s *Protocol) GetOption(option string) (interface{}, error)
  • func (*Protocol) Info() mproto.Info
  • func (s *Protocol) OpenContext() (mproto.Context, error)
  • func (s *Protocol) Pipe(id uint32) protocol.Pipe
  • func (s *Protocol) RangePipes(f func(uint32, protocol.Pipe) bool)
  • func (s *Protocol) RecvMsg() (*mproto.Message, error)
  • func (s *Protocol) RecvQ(hash uint32) (sizeQ chan struct{}, recvQ chan recvQEntry)
  • func (s *Protocol) RemovePipe(pp mproto.Pipe)
  • func (s *Protocol) SendMsg(m *mproto.Message) error
  • func (s *Protocol) SetOption(name string, value interface{}) error
  • func (s *Protocol) SetPipeEventHook(v protocol.PipeEventHook)
  • func (s *Protocol) String() string
• type RecvQueue
• type Server
  • func NewServer(cfg *Config) *Server
  • func (s *Server) Broadcast(data []byte) error
  • func (s *Server) Close() error
  • func (s *Server) Listen(addr string) error
  • func (s *Server) Pipe(id uint32) protocol.Pipe
  • func (s *Server) RangePipes(f func(uint32, protocol.Pipe) bool)
  • func (s *Server) Send(src, dest uint32, hash uint64, data []byte) error
  • func (s *Server) Serve()
  • func (s *Server) SetReadTimeout(v time.Duration)
  • func (s *Server) SetRecvSize(v int)
  • func (s *Server) SetSendSize(v int)
  • func (s *Server) SetTraceMessage(trace bool)
  • func (s *Server) Stop()
  • func (s *Server) String() string

Constants

const (
	Self     = protocol.ProtoEventBus
	Peer     = protocol.ProtoEvent
	SelfName = "ebus"
	PeerName = "event"
)

Protocol identity information.

Types

type Config

type Config struct {
	Address       string        `json:"address" yaml:"address" toml:"address"`
	TraceMessage  bool          `json:"trace_message,omitempty" yaml:"trace_message,omitempty" toml:"trace_message,omitempty"`
	ExchangeLines int           `json:"exchange_lines,omitempty" yaml:"exchange_lines,omitempty" toml:"exchange_lines,omitempty"`
	SendChanSize  int           `json:"send_chan_size" yaml:"send_chan_size" toml:"send_chan_size"`
	RecvChanSize  int           `json:"recv_chan_size" yaml:"recv_chan_size" toml:"recv_chan_size"`
	ReadTimeout   time.Duration `json:"read_timeout" yaml:"read_timeout" toml:"read_timeout"`
}

type Pipe

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

func (*Pipe) Close

func (p *Pipe) Close() error

func (*Pipe) Event

func (p *Pipe) Event() uint32

func (*Pipe) GetPrivate

func (p *Pipe) GetPrivate() interface{}

func (*Pipe) ID

func (p *Pipe) ID() uint32

func (*Pipe) LocalAddr

func (p *Pipe) LocalAddr() string

func (*Pipe) Pipe

func (p *Pipe) Pipe() mangos.Pipe

func (*Pipe) RecvMsg

func (p *Pipe) RecvMsg() *mproto.Message

func (*Pipe) RemoteAddr

func (p *Pipe) RemoteAddr() string

func (*Pipe) RemoteID

func (p *Pipe) RemoteID() uint32

func (*Pipe) SendMsg

func (p *Pipe) SendMsg(m *mproto.Message) error

func (*Pipe) SetEvent

func (p *Pipe) SetEvent(v uint32)

func (*Pipe) SetPrivate

func (p *Pipe) SetPrivate(v interface{})

func (*Pipe) Stop

func (p *Pipe) Stop()

type Protocol

type Protocol struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewProtocol

func NewProtocol(exchangeLines int) *Protocol

NewProtocol returns a new protocol implementation.

func (*Protocol) AddPipe

func (s *Protocol) AddPipe(pp mproto.Pipe) error

func (*Protocol) Close

func (s *Protocol) Close() error

func (*Protocol) Exchange

func (s *Protocol) Exchange()

func (*Protocol) GetOption

func (s *Protocol) GetOption(option string) (interface{}, error)

func (*Protocol) Info

func (*Protocol) Info() mproto.Info

func (*Protocol) OpenContext

func (s *Protocol) OpenContext() (mproto.Context, error)

func (*Protocol) Pipe

func (s *Protocol) Pipe(id uint32) protocol.Pipe

func (*Protocol) RangePipes

func (s *Protocol) RangePipes(f func(uint32, protocol.Pipe) bool)

func (*Protocol) RecvMsg

func (s *Protocol) RecvMsg() (*mproto.Message, error)

func (*Protocol) RecvQ

func (s *Protocol) RecvQ(hash uint32) (sizeQ chan struct{}, recvQ chan recvQEntry)

func (*Protocol) RemovePipe

func (s *Protocol) RemovePipe(pp mproto.Pipe)

func (*Protocol) SendMsg

func (s *Protocol) SendMsg(m *mproto.Message) error

func (*Protocol) SetOption

func (s *Protocol) SetOption(name string, value interface{}) error

func (*Protocol) SetPipeEventHook

func (s *Protocol) SetPipeEventHook(v protocol.PipeEventHook)

func (*Protocol) String

func (s *Protocol) String() string

type RecvQueue

type RecvQueue interface {
	RecvQ(hash uint64) (recvQ chan struct{}, sizeQ chan struct{})
}

type Server

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

func NewServer

func NewServer(cfg *Config) *Server

func (*Server) Broadcast

func (s *Server) Broadcast(data []byte) error

func (*Server) Close

func (s *Server) Close() error

func (*Server) Listen

func (s *Server) Listen(addr string) error

func (*Server) Pipe

func (s *Server) Pipe(id uint32) protocol.Pipe

func (*Server) RangePipes

func (s *Server) RangePipes(f func(uint32, protocol.Pipe) bool)

func (*Server) Send

func (s *Server) Send(src, dest uint32, hash uint64, data []byte) error

func (*Server) Serve

func (s *Server) Serve()

func (*Server) SetReadTimeout

func (s *Server) SetReadTimeout(v time.Duration)

func (*Server) SetRecvSize

func (s *Server) SetRecvSize(v int)

func (*Server) SetSendSize

func (s *Server) SetSendSize(v int)

func (*Server) SetTraceMessage

func (s *Server) SetTraceMessage(trace bool)

func (*Server) Stop

func (s *Server) Stop()

func (*Server) String

func (s *Server) String() string