asio

Documentation

Index

• Constants
• type DeadlineTimer
  • func NewDeadlineTimer(ctx *IoContext) *DeadlineTimer
  • func (d *DeadlineTimer) AsyncWait(op func(err error))
  • func (d *DeadlineTimer) Cancel()
  • func (d *DeadlineTimer) ExpiresAt(t time.Time)
  • func (d *DeadlineTimer) ExpiresFromNow(duration time.Duration)
• type GoroutineReactor
  • func NewGoroutineReactor() *GoroutineReactor
• type IoContext
  • func NewIoContext() *IoContext
  • func (i *IoContext) GetService() ReactorService
  • func (i *IoContext) Post(op func(err error))
  • func (i *IoContext) Run()
  • func (i *IoContext) Stop()
• type Path
• type ReactiveSocket
  • func NewReactiveSocket(ctx *IoContext) *ReactiveSocket
  • func (r *ReactiveSocket) AsyncAccept(listen net.Listener, op func(conn net.Conn, err error))
  • func (r *ReactiveSocket) AsyncConnect(network, address string, op func(conn net.Conn, err error))
  • func (r *ReactiveSocket) AsyncRead(reader io.Reader, b []byte, op func(n int, err error))
  • func (r *ReactiveSocket) AsyncReadFull(reader io.Reader, b []byte, op func(n int, err error))
  • func (r *ReactiveSocket) AsyncResolve(ctx context.Context, host string, port string, ...)
  • func (r *ReactiveSocket) AsyncWrite(writer io.Writer, b []byte, op func(n int, ec error))
• type ReactorService
• type SignalSet
  • func NewSignalSet(ctx *IoContext, sig ...os.Signal) *SignalSet
  • func (s *SignalSet) AsyncWait(op func(err error))
  • func (s *SignalSet) Cancel()

Constants

const Infinity = false

Types

type DeadlineTimer

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

func NewDeadlineTimer

func NewDeadlineTimer(ctx *IoContext) *DeadlineTimer

func (*DeadlineTimer) AsyncWait

func (d *DeadlineTimer) AsyncWait(op func(err error))

func (*DeadlineTimer) Cancel

func (d *DeadlineTimer) Cancel()

func (*DeadlineTimer) ExpiresAt

func (d *DeadlineTimer) ExpiresAt(t time.Time)

func (*DeadlineTimer) ExpiresFromNow

func (d *DeadlineTimer) ExpiresFromNow(duration time.Duration)

type GoroutineReactor

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

func NewGoroutineReactor

func NewGoroutineReactor() *GoroutineReactor

type IoContext

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

func NewIoContext

func NewIoContext() *IoContext

func (*IoContext) GetService

func (i *IoContext) GetService() ReactorService

func (*IoContext) Post

func (i *IoContext) Post(op func(err error))

func (*IoContext) Run

func (i *IoContext) Run()

func (*IoContext) Stop

func (i *IoContext) Stop()

type Path

type Path = string

type ReactiveSocket

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

func NewReactiveSocket

func NewReactiveSocket(ctx *IoContext) *ReactiveSocket

func (*ReactiveSocket) AsyncAccept

func (r *ReactiveSocket) AsyncAccept(listen net.Listener, op func(conn net.Conn, err error))

func (*ReactiveSocket) AsyncConnect

func (r *ReactiveSocket) AsyncConnect(network, address string, op func(conn net.Conn, err error))

func (*ReactiveSocket) AsyncRead

func (r *ReactiveSocket) AsyncRead(reader io.Reader, b []byte, op func(n int, err error))

func (*ReactiveSocket) AsyncReadFull

func (r *ReactiveSocket) AsyncReadFull(reader io.Reader, b []byte, op func(n int, err error))

func (*ReactiveSocket) AsyncResolve

func (r *ReactiveSocket) AsyncResolve(ctx context.Context, host string, port string, op func(address string, err error))

func (*ReactiveSocket) AsyncWrite

func (r *ReactiveSocket) AsyncWrite(writer io.Writer, b []byte, op func(n int, ec error))

type ReactorService

type ReactorService interface {
	// contains filtered or unexported methods
}

type SignalSet

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

func NewSignalSet

func NewSignalSet(ctx *IoContext, sig ...os.Signal) *SignalSet

func (*SignalSet) AsyncWait

func (s *SignalSet) AsyncWait(op func(err error))

func (*SignalSet) Cancel

func (s *SignalSet) Cancel()