server

Documentation

Index

• func NewEndWithConn(conn net.Conn, opts ...*EndOptions) (geminio.End, error)
• type EndOptions
  • func MergeEndOptions(opts ...*EndOptions) *EndOptions
  • func NewEndOptions() *EndOptions
  • func (eo *EndOptions) SetAcceptStreamFunc(fn func(geminio.Stream))
  • func (eo *EndOptions) SetClientID(clientID uint64)
  • func (eo *EndOptions) SetClosedStreamFunc(fn func(geminio.Stream))
  • func (eo *EndOptions) SetDelegate(delegate delegate.ServerDelegate)
  • func (eo *EndOptions) SetLog(log log.Logger)
  • func (eo *EndOptions) SetPacketFactory(packetFactory packet.PacketFactory)
  • func (eo *EndOptions) SetRegisterLocalRPCs(methodRPCs ...*geminio.MethodRPC)
  • func (eo *EndOptions) SetRemoteRPCCheck()
  • func (eo *EndOptions) SetTimer(timer timer.Timer)
  • func (eo *EndOptions) SetWaitRemoteRPCs(methods ...string)
• type Listener
  • func Listen(network, address string, opts ...*EndOptions) (Listener, error)
• type ServerEnd
  • func (se *ServerEnd) Close() error

Functions

func NewEndWithConn

func NewEndWithConn(conn net.Conn, opts ...*EndOptions) (geminio.End, error)

Types

type EndOptions

type EndOptions struct {
	Timer             timer.Timer
	TimerOwner        interface{}
	PacketFactory     packet.PacketFactory
	Log               log.Logger
	Delegate          delegate.ServerDelegate
	ClientID          *uint64
	RemoteMethods     []string
	RemoteMethodCheck bool
	LocalMethods      []*geminio.MethodRPC
	// If set AcceptStreamFunc, the AcceptStream should never be called
	AcceptStreamFunc func(geminio.Stream)
	ClosedStreamFunc func(geminio.Stream)
}

func MergeEndOptions

func MergeEndOptions(opts ...*EndOptions) *EndOptions

func NewEndOptions

func NewEndOptions() *EndOptions

func (*EndOptions) SetAcceptStreamFunc

func (eo *EndOptions) SetAcceptStreamFunc(fn func(geminio.Stream))

func (*EndOptions) SetClientID

func (eo *EndOptions) SetClientID(clientID uint64)

func (*EndOptions) SetClosedStreamFunc

func (eo *EndOptions) SetClosedStreamFunc(fn func(geminio.Stream))

func (*EndOptions) SetDelegate

func (eo *EndOptions) SetDelegate(delegate delegate.ServerDelegate)

func (*EndOptions) SetLog

func (eo *EndOptions) SetLog(log log.Logger)

func (*EndOptions) SetPacketFactory

func (eo *EndOptions) SetPacketFactory(packetFactory packet.PacketFactory)

func (*EndOptions) SetRegisterLocalRPCs

func (eo *EndOptions) SetRegisterLocalRPCs(methodRPCs ...*geminio.MethodRPC)

func (*EndOptions) SetRemoteRPCCheck

func (eo *EndOptions) SetRemoteRPCCheck()

func (*EndOptions) SetTimer

func (eo *EndOptions) SetTimer(timer timer.Timer)

func (*EndOptions) SetWaitRemoteRPCs

func (eo *EndOptions) SetWaitRemoteRPCs(methods ...string)

type Listener

type Listener interface {
	// Accept waits for and returns the next end to the listener.
	AcceptEnd() (geminio.End, error)

	// Accept waits for and returns the next connection to the listener.
	// the returned Conn is actually a End
	Accept() (net.Conn, error)

	// Close closes the listener.
	// Any blocked Accept operations will be unblocked and return errors.
	Close() error

	// Addr returns the listener's network address.
	Addr() net.Addr
}

func Listen

func Listen(network, address string, opts ...*EndOptions) (Listener, error)

type ServerEnd

type ServerEnd struct {
	geminio.End
	// contains filtered or unexported fields
}

func (*ServerEnd) Close

func (se *ServerEnd) Close() error