transport

Documentation

Index

• type Channel
  • func Accept(server *Server) (*Channel, error)
  • func NewChannel(conn net.Conn) (*Channel, error)
  • func (ch *Channel) Recv(slot *MessageSlot) error
  • func (ch *Channel) Send(slot *MessageSlot) error
• type MessageSlot
  • func NewMessageSlot(message interface{}) *MessageSlot
  • func (m *MessageSlot) Destroy()
  • func (m *MessageSlot) TakeUnixFd(fd int)
• type Server
  • func NewServer(listener net.Listener) *Server
• type UnixFd
  • func (ufd *UnixFd) Close()
  • func (ufd UnixFd) IsEmpty() bool
  • func (ufd UnixFd) PeekFd() int
  • func (ufd *UnixFd) TakeFd() int

Types

type Channel

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

func Accept

func Accept(server *Server) (*Channel, error)

func NewChannel

func NewChannel(conn net.Conn) (*Channel, error)

func (*Channel) Recv

func (ch *Channel) Recv(slot *MessageSlot) error

func (*Channel) Send

func (ch *Channel) Send(slot *MessageSlot) error

type MessageSlot

type MessageSlot struct {
	Message interface{}
	// contains filtered or unexported fields
}

func NewMessageSlot

func NewMessageSlot(message interface{}) *MessageSlot

func (*MessageSlot) Destroy

func (m *MessageSlot) Destroy()

func (*MessageSlot) TakeUnixFd

func (m *MessageSlot) TakeUnixFd(fd int)

type Server

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

func NewServer

func NewServer(listener net.Listener) *Server

type UnixFd

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

func (*UnixFd) Close

func (ufd *UnixFd) Close()

func (UnixFd) IsEmpty

func (ufd UnixFd) IsEmpty() bool

func (UnixFd) PeekFd

func (ufd UnixFd) PeekFd() int

func (*UnixFd) TakeFd

func (ufd *UnixFd) TakeFd() int