Help us shape the future of Go! Take the 2026 Go Developer Survey

libuv

package
v0.7.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 24, 2026 License: Apache-2.0 Imports: 4 Imported by: 0

README

LLGo wrapper of libuv

How to install

on macOS (Homebrew)
brew install libuv
on Linux (Debian/Ubuntu)
apt-get install -y libuv1-dev
on Linux (CentOS/RHEL)
yum install -y libuv-devel
on Linux (Arch Linux)
pacman -S libuv

Demos

The _demo directory contains our demos (it start with _ to prevent the go command from compiling it):

How to run demos

To run the demos in directory _demo:

cd <demo-directory>  # eg. cd _demo/sqlitedemo
llgo run .

Documentation

Index

Constants

View Source 
const (
	E2BIG           = Errno(syscall.E2BIG)
	EACCES          = Errno(syscall.EACCES)
	EADDRINUSE      = Errno(syscall.EADDRINUSE)
	EADDRNOTAVAIL   = Errno(syscall.EADDRNOTAVAIL)
	EAFNOSUPPORT    = Errno(syscall.EAFNOSUPPORT)
	EAGAIN          = Errno(syscall.EAGAIN)
	EALREADY        = Errno(syscall.EALREADY)
	EBADF           = Errno(syscall.EBADF)
	EBUSY           = Errno(syscall.EBUSY)
	ECANCELED       = Errno(syscall.ECANCELED)
	ECONNABORTED    = Errno(syscall.ECONNABORTED)
	ECONNREFUSED    = Errno(syscall.ECONNREFUSED)
	ECONNRESET      = Errno(syscall.ECONNRESET)
	EDESTADDRREQ    = Errno(syscall.EDESTADDRREQ)
	EEXIST          = Errno(syscall.EEXIST)
	EFAULT          = Errno(syscall.EFAULT)
	EFBIG           = Errno(syscall.EFBIG)
	EHOSTUNREACH    = Errno(syscall.EHOSTUNREACH)
	EINTR           = Errno(syscall.EINTR)
	EINVAL          = Errno(syscall.EINVAL)
	EIO             = Errno(syscall.EIO)
	EISCONN         = Errno(syscall.EISCONN)
	EISDIR          = Errno(syscall.EISDIR)
	ELOOP           = Errno(syscall.ELOOP)
	EMFILE          = Errno(syscall.EMFILE)
	EMSGSIZE        = Errno(syscall.EMSGSIZE)
	ENAMETOOLONG    = Errno(syscall.ENAMETOOLONG)
	ENETDOWN        = Errno(syscall.ENETDOWN)
	ENETUNREACH     = Errno(syscall.ENETUNREACH)
	ENFILE          = Errno(syscall.ENFILE)
	ENOBUFS         = Errno(syscall.ENOBUFS)
	ENODEV          = Errno(syscall.ENODEV)
	ENOENT          = Errno(syscall.ENOENT)
	ENOMEM          = Errno(syscall.ENOMEM)
	ENOPROTOOPT     = Errno(syscall.ENOPROTOOPT)
	ENOSPC          = Errno(syscall.ENOSPC)
	ENOSYS          = Errno(syscall.ENOSYS)
	ENOTCONN        = Errno(syscall.ENOTCONN)
	ENOTDIR         = Errno(syscall.ENOTDIR)
	ENOTEMPTY       = Errno(syscall.ENOTEMPTY)
	ENOTSOCK        = Errno(syscall.ENOTSOCK)
	ENOTSUP         = Errno(syscall.ENOTSUP)
	EOVERFLOW       = Errno(syscall.EOVERFLOW)
	EPERM           = Errno(syscall.EPERM)
	EPIPE           = Errno(syscall.EPIPE)
	EPROTO          = Errno(syscall.EPROTO)
	EPROTONOSUPPORT = Errno(syscall.EPROTONOSUPPORT)
	EPROTOTYPE      = Errno(syscall.EPROTOTYPE)
	ERANGE          = Errno(syscall.ERANGE)
	EROFS           = Errno(syscall.EROFS)
	ESHUTDOWN       = Errno(syscall.ESHUTDOWN)
	ESPIPE          = Errno(syscall.ESPIPE)
	ESRCH           = Errno(syscall.ESRCH)
	ETIMEDOUT       = Errno(syscall.ETIMEDOUT)
	ETXTBSY         = Errno(syscall.ETXTBSY)
	EXDEV           = Errno(syscall.EXDEV)
	ENXIO           = Errno(syscall.ENXIO)
	EMLINK          = Errno(syscall.EMLINK)
	EHOSTDOWN       = Errno(syscall.EHOSTDOWN)
	ENOTTY          = Errno(syscall.ENOTTY)
	//EFTYPE        = Errno(syscall.EFTYPE)
	EILSEQ          = Errno(syscall.EILSEQ)
	ESOCKTNOSUPPORT = Errno(syscall.ESOCKTNOSUPPORT)
)
View Source 
const (
	EAI_ADDRFAMILY = Errno(net.EAI_ADDRFAMILY)
	EAI_AGAIN      = Errno(net.EAI_AGAIN)
	EAI_BADFLAGS   = Errno(net.EAI_BADFLAGS)
	EAI_BADHINTS   = Errno(net.EAI_BADHINTS)
	EAI_FAIL       = Errno(net.EAI_FAIL)
	EAI_FAMILY     = Errno(net.EAI_FAMILY)
	EAI_MEMORY     = Errno(net.EAI_MEMORY)
	EAI_NODATA     = Errno(net.EAI_NODATA)
	EAI_NONAME     = Errno(net.EAI_NONAME)
	EAI_OVERFLOW   = Errno(net.EAI_OVERFLOW)
	EAI_PROTOCOL   = Errno(net.EAI_PROTOCOL)
	EAI_SERVICE    = Errno(net.EAI_SERVICE)
	EAI_SOCKTYPE   = Errno(net.EAI_SOCKTYPE)
)
View Source 
const (
	LLGoPackage = "link: $(pkg-config --libs libuv); -luv"
	LLGoFiles   = "$(pkg-config --cflags libuv): _wrap/libuv.c"
)

Variables

This section is empty.

Functions

func ErrName 

func ErrName(err Errno) *c.Char

func ErrNameR 

func ErrNameR(err Errno, buf *c.Char, bufLen uintptr) *c.Char

func Freeaddrinfo 

func Freeaddrinfo(addrInfo *net.AddrInfo)

func FsAccess 

func FsAccess(loop *Loop, req *Fs, path *c.Char, flags c.Int, cb FsCb) c.Int

func FsChmod 

func FsChmod(loop *Loop, req *Fs, path *c.Char, mode c.Int, cb FsCb) c.Int

func FsChown 

func FsChown(loop *Loop, req *Fs, path *c.Char, uid c.Int, gid c.Int, cb FsCb) c.Int

func FsClose 

func FsClose(loop *Loop, req *Fs, file File, cb FsCb) c.Int

func FsCloseDir 

func FsCloseDir(loop *Loop, req *Fs) c.Int

func FsCopyfile 

func FsCopyfile(loop *Loop, req *Fs, path *c.Char, newPath *c.Char, flags c.Int, cb FsCb) c.Int

func FsEventInit 

func FsEventInit(loop *Loop, handle *FsEvent) c.Int

func FsFchmod 

func FsFchmod(loop *Loop, req *Fs, file File, mode c.Int, cb FsCb) c.Int

func FsFchown 

func FsFchown(loop *Loop, req *Fs, file File, uid c.Int, gid c.Int, cb FsCb) c.Int

func FsFdatasync 

func FsFdatasync(loop *Loop, req *Fs, file File, cb FsCb) c.Int

func FsFstat 

func FsFstat(loop *Loop, req *Fs, file File, cb FsCb) c.Int

func FsFsync 

func FsFsync(loop *Loop, req *Fs, file File, cb FsCb) c.Int

func FsFtruncate 

func FsFtruncate(loop *Loop, req *Fs, file File, offset c.LongLong, cb FsCb) c.Int

func FsFutime 

func FsFutime(loop *Loop, req *Fs, file File, atime c.Int, mtime c.Int, cb FsCb) c.Int

func FsLchown 

func FsLchown(loop *Loop, req *Fs, path *c.Char, uid c.Int, gid c.Int, cb FsCb) c.Int
func FsLink(loop *Loop, req *Fs, path *c.Char, newPath *c.Char, cb FsCb) c.Int

func FsLstat 

func FsLstat(loop *Loop, req *Fs, path *c.Char, cb FsCb) c.Int

func FsLutime 

func FsLutime(loop *Loop, req *Fs, path *c.Char, atime c.Int, mtime c.Int, cb FsCb) c.Int

func FsMkStemp 

func FsMkStemp(loop *Loop, req *Fs, tpl *c.Char, cb FsCb) c.Int

func FsMkdir 

func FsMkdir(loop *Loop, req *Fs, path *c.Char, mode c.Int, cb FsCb) c.Int

func FsMkdtemp 

func FsMkdtemp(loop *Loop, req *Fs, tpl *c.Char, cb FsCb) c.Int

func FsOpen 

func FsOpen(loop *Loop, req *Fs, path *c.Char, flags c.Int, mode c.Int, cb FsCb) c.Int

func FsOpenDir 

func FsOpenDir(loop *Loop, req *Fs, path *c.Char, cb FsCb) c.Int

func FsPollInit 

func FsPollInit(loop *Loop, handle *FsPoll) c.Int

func FsRead 

func FsRead(loop *Loop, req *Fs, file File, bufs *Buf, nbufs c.Uint, offset c.LongLong, cb FsCb) c.Int

func FsReaddir 

func FsReaddir(loop *Loop, req *Fs, dir c.Int, cb FsCb) c.Int
func FsReadlink(loop *Loop, req *Fs, path *c.Char, cb FsCb) c.Int

func FsRealpath 

func FsRealpath(loop *Loop, req *Fs, path *c.Char, cb FsCb) c.Int

func FsRename 

func FsRename(loop *Loop, req *Fs, path *c.Char, newPath *c.Char, cb FsCb) c.Int

func FsRmdir 

func FsRmdir(loop *Loop, req *Fs, path *c.Char, cb FsCb) c.Int

func FsScandir 

func FsScandir(loop *Loop, req *Fs, path *c.Char, flags c.Int, cb FsCb) c.Int

func FsScandirNext 

func FsScandirNext(req *Fs, ent *Dirent) c.Int

func FsSendfile 

func FsSendfile(loop *Loop, req *Fs, outFd c.Int, inFd c.Int, inOffset c.LongLong, length c.Int, cb FsCb) c.Int

func FsStat 

func FsStat(loop *Loop, req *Fs, path *c.Char, cb FsCb) c.Int

func FsStatfs 

func FsStatfs(loop *Loop, req *Fs, path *c.Char, cb FsCb) c.Int
func FsSymlink(loop *Loop, req *Fs, path *c.Char, newPath *c.Char, flags c.Int, cb FsCb) c.Int
func FsUnlink(loop *Loop, req *Fs, path *c.Char, cb FsCb) c.Int

func FsUtime 

func FsUtime(loop *Loop, req *Fs, path *c.Char, atime c.Int, mtime c.Int, cb FsCb) c.Int

func FsWrite 

func FsWrite(loop *Loop, req *Fs, file File, bufs *Buf, nbufs c.Uint, offset c.LongLong, cb FsCb) c.Int

func Getaddrinfo 

func Getaddrinfo(loop *Loop, req *GetAddrInfo, getaddrinfoCb GetaddrinfoCb, node *c.Char, service *c.Char, hints *net.AddrInfo) c.Int

func Getnameinfo 

func Getnameinfo(loop *Loop, req *GetNameInfo, getnameinfoCb GetnameinfoCb, addr *net.SockAddr, flags c.Int) c.Int

func HandleSize 

func HandleSize(handleType HandleType) uintptr

func HandleTypeName 

func HandleTypeName(handleType HandleType) *c.Char

func InetNtop 

func InetNtop(af c.Int, src c.Pointer, dst *c.Char, size uintptr) c.Int

func InetPton 

func InetPton(af c.Int, src *c.Char, dst c.Pointer) c.Int

func InitCheck 

func InitCheck(loop *Loop, Check *Check) c.Int

func InitIdle 

func InitIdle(loop *Loop, idle *Idle) c.Int

func InitTcp 

func InitTcp(loop *Loop, tcp *Tcp) c.Int

func InitTcpEx 

func InitTcpEx(loop *Loop, tcp *Tcp, flags c.Uint) c.Int

func InitTimer 

func InitTimer(loop *Loop, timer *Timer) c.Int

func InitUdp 

func InitUdp(loop *Loop, udp *Udp) c.Int

func InitUdpEx 

func InitUdpEx(loop *Loop, udp *Udp, flags c.Uint) c.Int

func Ip4Addr 

func Ip4Addr(ip *c.Char, port c.Int, addr *net.SockaddrIn) c.Int

func Ip4Name 

func Ip4Name(src *net.SockaddrIn, dst *c.Char, size uintptr) c.Int

func Ip6Addr 

func Ip6Addr(ip *c.Char, port c.Int, addr *net.SockaddrIn6) c.Int

func Ip6Name 

func Ip6Name(src *net.SockaddrIn6, dst *c.Char, size uintptr) c.Int

func IpName 

func IpName(src *net.SockAddr, dst *c.Char, size uintptr) c.Int

func LibraryShutdown 

func LibraryShutdown()

func LoopSize 

func LoopSize() uintptr

func Pipe 

func Pipe(fds [2]File, readFlags c.Int, writeFlags c.Int) c.Int

func PollInit 

func PollInit(loop *Loop, handle *Poll, fd OsFd) c.Int

func PollInitSocket 

func PollInitSocket(loop *Loop, handle *Poll, socket c.Int) c.Int

func QueueWork 

func QueueWork(loop *Loop, req *Work, workCb WorkCb, afterWorkCb AfterWorkCb) c.Int

func ReplaceAllocator 

func ReplaceAllocator(mallocFunc MallocFunc, reallocFunc ReallocFunc, callocFunc CallocFunc, freeFunc FreeFunc) c.Int

func ReqSize 

func ReqSize(reqType ReqType) uintptr

func Send 

func Send(req *UdpSend, udp *Udp, bufs *Buf, nbufs c.Uint, addr *net.SockAddr, sendCb UdpSendCb) c.Int

func SignalInit 

func SignalInit(loop *Loop, handle *Signal) c.Int

func Socketpair 

func Socketpair(_type c.Int, protocol c.Int, socketVector [2]OsSock, flag0 c.Int, flag1 c.Int) c.Int

func StreamShutdown 

func StreamShutdown(shutdown *Shutdown, stream *Stream, shutdownCb ShutdownCb) c.Int

func Strerror 

func Strerror(err Errno) *c.Char

func StrerrorR 

func StrerrorR(err Errno, buf *c.Char, bufLen uintptr) *c.Char

func TcpConnect 

func TcpConnect(req *Connect, tcp *Tcp, addr *net.SockAddr, connectCb ConnectCb) c.Int

func ThreadEqual 

func ThreadEqual(t1 *Thread, t2 *Thread) c.Int

func ThreadGetCPU 

func ThreadGetCPU() c.Int

func TypeName 

func TypeName(reqType ReqType) *c.Char

func Version 

func Version() c.Uint

func VersionString 

func VersionString() *c.Char

Types

type AfterWorkCb 

type AfterWorkCb func(req *Work, status c.Int)

type AllocCb 

type AllocCb func(handle *Handle, suggestedSize uintptr, buf *Buf)

type Async 

type Async struct {
	Handle
	// On macOS arm64, sizeof uv_async_t is 128 bytes.
	// Handle is 92 bytes, so we need 36 bytes to fill the gap.
	// Maybe reserve more for future use.
	Unused [36]byte
}

struct uv_async_t

func (*Async) Send 

func (a *Async) Send() c.Int

int uv_async_send(uv_async_t* async);

llgo:link (*Async).Send C.uv_async_send

type AsyncCb 

type AsyncCb func(*Async)

typedef void (*uv_async_cb)(uv_async_t* handle);

type Buf 

type Buf struct {
	Base *c.Char
	Len  uintptr

} // ----------------------------------------------

func InitBuf 

func InitBuf(base *c.Char, len c.Uint) Buf

type CallocFunc 

type CallocFunc func(count uintptr, size uintptr) c.Pointer

type Check 

type Check struct {
	Unused [120]byte
}

func (*Check) Start 

func (Check *Check) Start(CheckCb CheckCb) c.Int

llgo:link (*Check).Start C.uv_check_start

func (*Check) Stop 

func (Check *Check) Stop() c.Int

llgo:link (*Check).Stop C.uv_check_stop

type CheckCb 

type CheckCb func(Check *Check)

type CloseCb 

type CloseCb func(handle *Handle)

type Connect 

type Connect struct {
	Data   c.Pointer
	Unused [88]byte
}

TODO(spongehah): Connect

type ConnectCb 

type ConnectCb func(req *Connect, status c.Int)

type ConnectionCb 

type ConnectionCb func(server *Stream, status c.Int)

type Dirent 

type Dirent struct {
	Name *c.Char
	Type DirentType
}

type DirentType 

type DirentType c.Int
const (
	DirentUnknown DirentType = iota
	DirentFile
	DirentDir
	DirentLink
	DirentFifo
	DirentSocket
	DirentChar
	DirentBlock
)

type Errno 

type Errno c.Int
const (
	EAI_CANCELED Errno = -3003
	ECHARSET     Errno = -4080
	ENONET       Errno = -4056
	UNKNOWN      Errno = -4094
	EOF          Errno = -4095
	EREMOTEIO    Errno = -4030
	ERRNO_MAX    Errno = EOF - 1
)

func TranslateSysError 

func TranslateSysError(sysErrno c.Int) Errno

type File 

type File c.Int

type FreeFunc 

type FreeFunc func(ptr c.Pointer)

type Fs 

type Fs struct {
	Unused [440]byte
}

func (*Fs) GetPath 

func (req *Fs) GetPath() *c.Char

llgo:link (*Fs).GetPath C.uv_fs_get_path

func (*Fs) GetPtr 

func (req *Fs) GetPtr() c.Pointer

llgo:link (*Fs).GetPtr C.uv_fs_get_ptr

func (*Fs) GetResult 

func (req *Fs) GetResult() c.Int

llgo:link (*Fs).GetResult C.uv_fs_get_result

func (*Fs) GetStatBuf 

func (req *Fs) GetStatBuf() *Stat

llgo:link (*Fs).GetStatBuf C.uv_fs_get_statbuf

func (*Fs) GetSystemError 

func (req *Fs) GetSystemError() c.Int

llgo:link (*Fs).GetSystemError C.uv_fs_get_system_error

func (*Fs) GetType 

func (req *Fs) GetType() FsType

llgo:link (*Fs).GetType C.uv_fs_get_type

func (*Fs) ReqCleanup 

func (req *Fs) ReqCleanup()

llgo:link (*Fs).ReqCleanup C.uv_fs_req_cleanup

type FsCb 

type FsCb func(req *Fs)

type FsEvent 

type FsEvent struct {
	Unused [0]byte
}

func (*FsEvent) Close 

func (handle *FsEvent) Close() c.Int

llgo:link (*FsEvent).Close C.uv_fs_event_close

func (*FsEvent) Getpath 

func (handle *FsEvent) Getpath() *c.Char

llgo:link (*FsEvent).Getpath C.uv_fs_event_getpath

func (*FsEvent) Start 

func (handle *FsEvent) Start(cb FsEventCb, path *c.Char, flags c.Int) c.Int

llgo:link (*FsEvent).Start C.uv_fs_event_start

func (*FsEvent) Stop 

func (handle *FsEvent) Stop() c.Int

llgo:link (*FsEvent).Stop C.uv_fs_event_stop

type FsEventCb 

type FsEventCb func(handle *FsEvent, filename *c.Char, events c.Int, status c.Int)

type FsPoll 

type FsPoll struct {
	Unused [0]byte
}

func (*FsPoll) Close 

func (handle *FsPoll) Close() c.Int

llgo:link (*FsPoll).Close C.uv_fs_poll_close

func (*FsPoll) GetPath 

func (handle *FsPoll) GetPath() *c.Char

llgo:link (*FsPoll).GetPath C.uv_fs_poll_getpath

func (*FsPoll) Start 

func (handle *FsPoll) Start(cb FsPollCb, path *c.Char, interval uint) c.Int

llgo:link (*FsPoll).Start C.uv_fs_poll_start

func (*FsPoll) Stop 

func (handle *FsPoll) Stop() c.Int

llgo:link (*FsPoll).Stop C.uv_fs_poll_stop

type FsPollCb 

type FsPollCb func(handle *FsPoll, status c.Int, events c.Int)

type FsType 

type FsType c.Int
const (
	FS_UNKNOWN   FsType = -1
	FS_CUSTOM    FsType = 0
	FS_OPEN      FsType = 1
	FS_CLOSE     FsType = 2
	FS_READ      FsType = 3
	FS_WRITE     FsType = 4
	FS_SENDFILE  FsType = 5
	FS_STAT      FsType = 6
	FS_LSTAT     FsType = 7
	FS_FSTAT     FsType = 8
	FS_FTRUNCATE FsType = 9
	FS_UTIME     FsType = 10
	FS_FUTIME    FsType = 11
	FS_ACCESS    FsType = 12
	FS_CHMOD     FsType = 13
	FS_FCHMOD    FsType = 14
	FS_FSYNC     FsType = 15
	FS_FDATASYNC FsType = 16
	FS_UNLINK    FsType = 17
	FS_RMDIR     FsType = 18
	FS_MKDIR     FsType = 19
	FS_MKDTEMP   FsType = 20
	FS_RENAME    FsType = 21
	FS_SCANDIR   FsType = 22
	FS_LINK      FsType = 23
	FS_SYMLINK   FsType = 24
	FS_READLINK  FsType = 25
	FS_CHOWN     FsType = 26
	FS_FCHOWN    FsType = 27
	FS_REALPATH  FsType = 28
	FS_COPYFILE  FsType = 29
	FS_LCHOWN    FsType = 30
	FS_OPENDIR   FsType = 31
	FS_READDIR   FsType = 32
	FS_CLOSEDIR  FsType = 33
	FS_STATFS    FsType = 34
	FS_MKSTEMP   FsType = 35
	FS_LUTIME    FsType = 36
)

type GetAddrInfo 

type GetAddrInfo struct {
	Unused [160]byte
}

TODO(spongehah): GetAddrInfo

type GetNameInfo 

type GetNameInfo struct {
	Unused [1320]byte
}

TODO(spongehah): GetNameInfo

type GetaddrinfoCb 

type GetaddrinfoCb func(req *GetAddrInfo, status c.Int, res *net.AddrInfo)

type GetnameinfoCb 

type GetnameinfoCb func(req *GetNameInfo, status c.Int, hostname *c.Char, service *c.Char)

type Handle 

type Handle struct {
	Data   c.Pointer
	Unused [88]byte
}

TODO(spongehah): Handle

func (*Handle) Close 

func (handle *Handle) Close(closeCb CloseCb)

llgo:link (*Handle).Close C.uv_close

func (*Handle) Fileno 

func (handle *Handle) Fileno(fd *OsFd) c.Int

llgo:link (*Handle).Fileno C.uv_fileno

func (*Handle) GetData 

func (handle *Handle) GetData() c.Pointer

llgo:link (*Handle).GetData C.uv_handle_get_data

func (*Handle) GetLoop 

func (handle *Handle) GetLoop() *Loop

llgo:link (*Handle).GetLoop C.uv_handle_get_loop

func (*Handle) GetType 

func (handle *Handle) GetType() HandleType

llgo:link (*Handle).GetType C.uv_handle_get_type

func (*Handle) HasRef 

func (handle *Handle) HasRef() c.Int

llgo:link (*Handle).HasRef C.uv_has_ref

func (*Handle) IsActive 

func (handle *Handle) IsActive() c.Int

llgo:link (*Handle).IsActive C.uv_is_active

func (*Handle) IsClosing 

func (handle *Handle) IsClosing() c.Int

llgo:link (*Handle).IsClosing C.uv_is_closing

func (*Handle) IsReadable 

func (handle *Handle) IsReadable() c.Int

llgo:link (*Handle).IsReadable C.uv_is_readable

func (*Handle) IsWritable 

func (handle *Handle) IsWritable() c.Int

llgo:link (*Handle).IsWritable C.uv_is_writable

func (*Handle) RecvBufferSize 

func (handle *Handle) RecvBufferSize(value *c.Int) c.Int

llgo:link (*Handle).RecvBufferSize C.uv_recv_buffer_size

func (*Handle) Ref 

func (handle *Handle) Ref()

llgo:link (*Handle).Ref C.uv_ref

func (*Handle) SendBufferSize 

func (handle *Handle) SendBufferSize(value *c.Int) c.Int

llgo:link (*Handle).SendBufferSize C.uv_send_buffer_size

func (*Handle) SetData 

func (handle *Handle) SetData(data c.Pointer)

llgo:link (*Handle).SetData C.uv_handle_set_data

func (*Handle) Unref 

func (handle *Handle) Unref()

llgo:link (*Handle).Unref C.uv_unref

type HandleType 

type HandleType c.Int
const (
	UNKNOWN_HANDLE HandleType = iota
	ASYNC
	CHECK
	FS_EVENT
	FS_POLL
	HANDLE
	IDLE
	NAMED_PIPE
	POLL
	PREPARE
	PROCESS
	STREAM
	TCP
	TIMER
	TTY
	UDP
	SIGNAL
	FILE
	HANDLE_TYPE_MAX
)

type Idle 

type Idle struct {
	Unused [120]byte
}

func (*Idle) Start 

func (idle *Idle) Start(idleCb IdleCb) c.Int

llgo:link (*Idle).Start C.uv_idle_start

func (*Idle) Stop 

func (idle *Idle) Stop() c.Int

llgo:link (*Idle).Stop C.uv_idle_stop

type IdleCb 

type IdleCb func(idle *Idle)

type Loop 

type Loop struct {
	Unused [0]byte
}

func DefaultLoop 

func DefaultLoop() *Loop

func LoopDefault 

func LoopDefault() *Loop

llgo:link LoopDefault C.uv_default_loop

func LoopNew 

func LoopNew() *Loop

llgo:link LoopNew C.uv_loop_new

func (*Loop) Alive 

func (loop *Loop) Alive() c.Int

llgo:link (*Loop).Alive C.uv_loop_alive

func (*Loop) Async 

func (loop *Loop) Async(a *Async, cb AsyncCb) c.Int

int uv_async_init(uv_loop_t*, uv_async_t* async, uv_async_cb async_cb);

llgo:link (*Loop).Async C.uv_async_init

func (*Loop) BackendFd 

func (loop *Loop) BackendFd() c.Int

llgo:link (*Loop).BackendFd C.uv_backend_fd

func (*Loop) BackendTimeout 

func (loop *Loop) BackendTimeout() c.Int

llgo:link (*Loop).BackendTimeout C.uv_backend_timeout

func (*Loop) Close 

func (loop *Loop) Close() c.Int

llgo:link (*Loop).Close C.uv_loop_close

func (*Loop) Configure 

func (loop *Loop) Configure(option LoopOption, arg c.Int) c.Int

llgo:link (*Loop).Configure C.uv_loop_configure

func (*Loop) Delete 

func (loop *Loop) Delete() c.Int

llgo:link (*Loop).Delete C.uv_loop_delete

func (*Loop) Fork 

func (loop *Loop) Fork() c.Int

llgo:link (*Loop).Fork C.uv_loop_fork

func (*Loop) GetData 

func (loop *Loop) GetData() c.Pointer

llgo:link (*Loop).GetData C.uv_loop_get_data

func (*Loop) Init 

func (loop *Loop) Init() c.Int

llgo:link (*Loop).Init C.uv_loop_init

func (*Loop) Now 

func (loop *Loop) Now() c.UlongLong

llgo:link (*Loop).Now C.uv_now

func (*Loop) Run 

func (loop *Loop) Run(mode RunMode) c.Int

llgo:link (*Loop).Run C.uv_run

func (*Loop) SetData 

func (loop *Loop) SetData(data c.Pointer)

llgo:link (*Loop).SetData C.uv_loop_set_data

func (*Loop) Stop 

func (loop *Loop) Stop()

void uv_stop(uv_loop_t *loop)

llgo:link (*Loop).Stop C.uv_stop

func (*Loop) UpdateTime 

func (loop *Loop) UpdateTime()

llgo:link (*Loop).UpdateTime C.uv_update_time

func (*Loop) Walk 

func (loop *Loop) Walk(walkCb WalkCb, arg c.Pointer)

llgo:link (*Loop).Walk C.uv_walk

type LoopOption 

type LoopOption c.Int
const (
	LOOP_BLOCK_SIGNAL LoopOption = iota
	METRICS_IDLE_TIME
)

type MallocFunc 

type MallocFunc func(size uintptr) c.Pointer

type Membership 

type Membership c.Int
const (
	UV_LEAVE_GROUP Membership = iota
	UV_JOIN_GROUP
)

type OsFd 

type OsFd c.Int

type OsSock 

type OsSock c.Int

type Poll 

type Poll struct {
	Data   c.Pointer
	Unused [160]byte
}

func (*Poll) Start 

func (handle *Poll) Start(events c.Int, cb PollCb) c.Int

llgo:link (*Poll).Start C.uv_poll_start

func (*Poll) Stop 

func (handle *Poll) Stop() c.Int

llgo:link (*Poll).Stop C.uv_poll_stop

type PollCb 

type PollCb func(handle *Poll, status c.Int, events c.Int)

type PollEvent 

type PollEvent c.Int
const (
	READABLE PollEvent = 1 << iota
	WRITABLE
	DISCONNECT
	PRIPRIORITIZED
)

type ReadCb 

type ReadCb func(stream *Stream, nread c.Long, buf *Buf)

type ReallocFunc 

type ReallocFunc func(ptr c.Pointer, size uintptr) c.Pointer

type Req 

type Req struct {
	Unused [64]byte
}

TODO(spongehah): Req

func (*Req) Cancel 

func (req *Req) Cancel() c.Int

llgo:link (*Req).Cancel C.uv_cancel

func (*Req) GetData 

func (req *Req) GetData() c.Pointer

llgo:link (*Req).GetData C.uv_req_get_data

func (*Req) GetType 

func (req *Req) GetType() ReqType

llgo:link (*Req).GetType C.uv_req_get_type

func (*Req) SetData 

func (req *Req) SetData(data c.Pointer)

llgo:link (*Req).SetData C.uv_req_set_data

type ReqType 

type ReqType c.Int
const (
	UNKNOWN_REQ ReqType = iota
	REQ
	CONNECT
	WRITE
	SHUTDOWN
	UDP_SEND
	FS
	WORK
	GETADDRINFO
	GETNAMEINFO
	RANDOM
	REQ_TYPE_PRIVATE
	REQ_TYPE_MAX
)

type RunMode 

type RunMode c.Int
const (
	RUN_DEFAULT RunMode = iota
	RUN_ONCE
	RUN_NOWAIT
)

----------------------------------------------

type Shutdown 

type Shutdown struct {
	Unused [80]byte
}

TODO(spongehah): Shutdown

type ShutdownCb 

type ShutdownCb func(req *Shutdown, status c.Int)

type Signal 

type Signal struct {
	Unused [152]byte
}

func (*Signal) Start 

func (handle *Signal) Start(cb SignalCb, signum c.Int) c.Int

llgo:link (*Signal).Start C.uv_signal_start

func (*Signal) StartOneshot 

func (handle *Signal) StartOneshot(cb SignalCb, signum c.Int) c.Int

llgo:link (*Signal).StartOneshot C.uv_signal_start_oneshot

func (*Signal) Stop 

func (handle *Signal) Stop() c.Int

llgo:link (*Signal).Stop C.uv_signal_stop

type SignalCb 

type SignalCb func(handle *Signal, sigNum c.Int)

type Stat 

type Stat struct {
	Unused [0]byte
}

type Stream 

type Stream struct {
	Data   c.Pointer
	Unused [256]byte
}

TODO(spongehah): Stream

func (*Stream) Accept 

func (server *Stream) Accept(client *Stream) c.Int

llgo:link (*Stream).Accept C.uv_accept

func (*Stream) GetWriteQueueSize 

func (stream *Stream) GetWriteQueueSize() uintptr

llgo:link (*Stream).GetWriteQueueSize C.uv_stream_get_write_queue_size

func (*Stream) IsReadable 

func (stream *Stream) IsReadable() c.Int

llgo:link (*Stream).IsReadable C.uv_is_readable

func (*Stream) IsWritable 

func (stream *Stream) IsWritable() c.Int

llgo:link (*Stream).IsWritable C.uv_is_writable

func (*Stream) Listen 

func (stream *Stream) Listen(backlog c.Int, connectionCb ConnectionCb) c.Int

llgo:link (*Stream).Listen C.uv_listen

func (*Stream) SetBlocking 

func (stream *Stream) SetBlocking(blocking c.Int) c.Int

llgo:link (*Stream).SetBlocking C.uv_stream_set_blocking

func (*Stream) StartRead 

func (stream *Stream) StartRead(allocCb AllocCb, readCb ReadCb) c.Int

llgo:link (*Stream).StartRead C.uv_read_start

func (*Stream) StopRead 

func (stream *Stream) StopRead() c.Int

llgo:link (*Stream).StopRead C.uv_read_stop

func (*Stream) TryWrite 

func (stream *Stream) TryWrite(bufs *Buf, nbufs c.Uint) c.Int

llgo:link (*Stream).TryWrite C.uv_try_write

func (*Stream) TryWrite2 

func (stream *Stream) TryWrite2(bufs *Buf, nbufs c.Uint, sendStream *Stream) c.Int

llgo:link (*Stream).TryWrite2 C.uv_try_write2

type Tcp 

type Tcp struct {
	Data   c.Pointer
	Unused [256]byte
}

TODO(spongehah): Tcp

func (*Tcp) Bind 

func (tcp *Tcp) Bind(addr *net.SockAddr, flags c.Uint) c.Int

llgo:link (*Tcp).Bind C.uv_tcp_bind

func (*Tcp) CloseReset 

func (tcp *Tcp) CloseReset(closeCb CloseCb) c.Int

llgo:link (*Tcp).CloseReset C.uv_tcp_close_reset

func (*Tcp) GetIoWatcherFd 

func (tcp *Tcp) GetIoWatcherFd() c.Int

llgo:link (*Tcp).GetIoWatcherFd C.uv_tcp_get_io_watcher_fd

func (*Tcp) Getpeername 

func (tcp *Tcp) Getpeername(name *net.SockAddr, nameLen *c.Int) c.Int

llgo:link (*Tcp).Getpeername C.uv_tcp_getpeername

func (*Tcp) Getsockname 

func (tcp *Tcp) Getsockname(name *net.SockAddr, nameLen *c.Int) c.Int

llgo:link (*Tcp).Getsockname C.uv_tcp_getsockname

func (*Tcp) KeepAlive 

func (tcp *Tcp) KeepAlive(enable c.Int, delay c.Uint) c.Int

llgo:link (*Tcp).KeepAlive C.uv_tcp_keepalive

func (*Tcp) Nodelay 

func (tcp *Tcp) Nodelay(enable c.Int) c.Int

llgo:link (*Tcp).Nodelay C.uv_tcp_nodelay

func (*Tcp) Open 

func (tcp *Tcp) Open(sock OsSock) c.Int

llgo:link (*Tcp).Open C.uv_tcp_open

func (*Tcp) SimultaneousAccepts 

func (tcp *Tcp) SimultaneousAccepts(enable c.Int) c.Int

llgo:link (*Tcp).SimultaneousAccepts C.uv_tcp_simultaneous_accepts

type TcpFlags 

type TcpFlags c.Int
const (
	/* Used with uv_tcp_bind, when an IPv6 address is used. */
	TCP_IPV6ONLY TcpFlags = 1
)

type Thread 

type Thread struct {
	Unused [8]byte
}

func ThreadSelf 

func ThreadSelf() Thread

func (*Thread) Create 

func (t *Thread) Create(entry ThreadCb, arg c.Pointer) c.Int

llgo:link (*Thread).Create C.uv_thread_create

func (*Thread) CreateEx 

func (t *Thread) CreateEx(entry ThreadCb, params *ThreadOptions, arg c.Pointer) c.Int

llgo:link (*Thread).CreateEx C.uv_thread_create_ex

func (*Thread) GetAffinity 

func (t *Thread) GetAffinity(cpuMask *c.Char, maskSize uintptr) c.Int

llgo:link (*Thread).GetAffinity C.uv_thread_get_affinity

func (*Thread) Join 

func (t *Thread) Join() c.Int

llgo:link (*Thread).Join C.uv_thread_join

func (*Thread) SetAffinity 

func (t *Thread) SetAffinity(cpuMask *c.Char, oldMask *c.Char, maskSize uintptr) c.Int

llgo:link (*Thread).SetAffinity C.uv_thread_set_affinity

type ThreadCb 

type ThreadCb func(arg c.Pointer)

type ThreadOptions 

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

type Timer 

type Timer struct {
	Unused [152]byte
}

TODO(spongehah): Timer

func (*Timer) Again 

func (timer *Timer) Again() c.Int

llgo:link (*Timer).Again C.uv_timer_again

func (*Timer) GetDueIn 

func (timer *Timer) GetDueIn() uint64

llgo:link (*Timer).GetDueIn C.uv_timer_get_due_in

func (*Timer) GetRepeat 

func (timer *Timer) GetRepeat() uint64

llgo:link (*Timer).GetRepeat C.uv_timer_get_repeat

func (*Timer) SetRepeat 

func (timer *Timer) SetRepeat(repeat uint64)

llgo:link (*Timer).SetRepeat C.uv_timer_set_repeat

func (*Timer) Start 

func (timer *Timer) Start(cb TimerCb, timeoutMs uint64, repeat uint64) c.Int

llgo:link (*Timer).Start C.uv_timer_start

func (*Timer) Stop 

func (timer *Timer) Stop() c.Int

llgo:link (*Timer).Stop C.uv_timer_stop

type TimerCb 

type TimerCb func(timer *Timer)

type Udp 

type Udp struct {
	Unused [224]byte
}

TODO(spongehah): Udp

func (*Udp) Bind 

func (udp *Udp) Bind(addr *net.SockAddr, flags c.Uint) c.Int

llgo:link (*Udp).Bind C.uv_udp_bind

func (*Udp) Connect 

func (udp *Udp) Connect(addr *net.SockAddr) c.Int

llgo:link (*Udp).Connect C.uv_udp_connect

func (*Udp) GetSendQueueCount 

func (udp *Udp) GetSendQueueCount() uintptr

llgo:link (*Udp).GetSendQueueCount C.uv_udp_get_send_queue_count

func (*Udp) GetSendQueueSize 

func (udp *Udp) GetSendQueueSize() uintptr

llgo:link (*Udp).GetSendQueueSize C.uv_udp_get_send_queue_size

func (*Udp) Getpeername 

func (udp *Udp) Getpeername(name *net.SockAddr, nameLen *c.Int) c.Int

llgo:link (*Udp).Getpeername C.uv_udp_getpeername

func (*Udp) Getsockname 

func (udp *Udp) Getsockname(name *net.SockAddr, nameLen *c.Int) c.Int

llgo:link (*Udp).Getsockname C.uv_udp_getsockname

func (*Udp) Open 

func (udp *Udp) Open(sock OsSock) c.Int

llgo:link (*Udp).Open C.uv_udp_open

func (*Udp) SetBroadcast 

func (udp *Udp) SetBroadcast(on c.Int) c.Int

llgo:link (*Udp).SetBroadcast C.uv_udp_set_broadcast

func (*Udp) SetMembership 

func (udp *Udp) SetMembership(multicastAddr *c.Char, interfaceAddr *c.Char, membership Membership) c.Int

llgo:link (*Udp).SetMembership C.uv_udp_set_membership

func (*Udp) SetMulticastInterface 

func (udp *Udp) SetMulticastInterface(interfaceAddr *c.Char) c.Int

llgo:link (*Udp).SetMulticastInterface C.uv_udp_set_multicast_interface

func (*Udp) SetMulticastLoop 

func (udp *Udp) SetMulticastLoop(on c.Int) c.Int

llgo:link (*Udp).SetMulticastLoop C.uv_udp_set_multicast_loop

func (*Udp) SetMulticastTTL 

func (udp *Udp) SetMulticastTTL(ttl c.Int) c.Int

llgo:link (*Udp).SetMulticastTTL C.uv_udp_set_multicast_ttl

func (*Udp) SetTTL 

func (udp *Udp) SetTTL(ttl c.Int) c.Int

llgo:link (*Udp).SetTTL C.uv_udp_set_ttl

func (*Udp) SourceMembership 

func (udp *Udp) SourceMembership(multicastAddr *c.Char, interfaceAddr *c.Char, sourceAddr *c.Char, membership Membership) c.Int

llgo:link (*Udp).SourceMembership C.uv_udp_set_source_membership

func (*Udp) StartRecv 

func (udp *Udp) StartRecv(allocCb AllocCb, recvCb UdpRecvCb) c.Int

llgo:link (*Udp).StartRecv C.uv_udp_recv_start

func (*Udp) StopRecv 

func (udp *Udp) StopRecv() c.Int

llgo:link (*Udp).StopRecv C.uv_udp_recv_stop

func (*Udp) TrySend 

func (udp *Udp) TrySend(bufs *Buf, nbufs c.Uint, addr *net.SockAddr) c.Int

llgo:link (*Udp).TrySend C.uv_udp_try_send

func (*Udp) UsingRecvmmsg 

func (udp *Udp) UsingRecvmmsg() c.Int

llgo:link (*Udp).UsingRecvmmsg C.uv_udp_using_recvmmsg

type UdpFlags 

type UdpFlags c.Int
const (
	/* Disables dual stack mode. */
	UDP_IPV6ONLY UdpFlags = 1
	/*
	 * Indicates message was truncated because read buffer was too small. The
	 * remainder was discarded by the OS. Used in uv_udp_recv_cb.
	 */
	UDP_PARTIAL UdpFlags = 2
	/*
	 * Indicates if SO_REUSEADDR will be set when binding the handle.
	 * This sets the SO_REUSEPORT socket flag on the BSDs and OS X. On other
	 * Unix platforms, it sets the SO_REUSEADDR flag.  What that means is that
	 * multiple threads or processes can bind to the same address without error
	 * (provided they all set the flag) but only the last one to bind will receive
	 * any traffic, in effect "stealing" the port from the previous listener.
	 */
	UDP_REUSEADDR UdpFlags = 4
	/*
	 * Indicates that the message was received by recvmmsg, so the buffer provided
	 * must not be freed by the recv_cb callback.
	 */
	UDP_MMSG_CHUNK UdpFlags = 8
	/*
	 * Indicates that the buffer provided has been fully utilized by recvmmsg and
	 * that it should now be freed by the recv_cb callback. When this flag is set
	 * in uv_udp_recv_cb, nread will always be 0 and addr will always be NULL.
	 */
	UDP_MMSG_FREE UdpFlags = 16
	/*
	 * Indicates if IP_RECVERR/IPV6_RECVERR will be set when binding the handle.
	 * This sets IP_RECVERR for IPv4 and IPV6_RECVERR for IPv6 UDP sockets on
	 * Linux. This stops the Linux kernel from suppressing some ICMP error
	 * messages and enables full ICMP error reporting for faster failover.
	 * This flag is no-op on platforms other than Linux.
	 */
	UDP_LINUX_RECVERR UdpFlags = 32
	/*
	 * Indicates that recvmmsg should be used, if available.
	 */
	UDP_RECVMMSG UdpFlags = 256
)

* UDP support.

type UdpRecvCb 

type UdpRecvCb func(handle *Udp, nread c.Long, buf *Buf, addr *net.SockAddr, flags c.Uint)

type UdpSend 

type UdpSend struct {
	Unused [320]byte
}

TODO(spongehah): UdpSend

type UdpSendCb 

type UdpSendCb func(req *UdpSend, status c.Int)

type WalkCb 

type WalkCb func(handle *Handle, arg c.Pointer)

type Work 

type Work struct {
	Unused [128]byte
}

type WorkCb 

type WorkCb func(req *Work)

type Write 

type Write struct {
	Data   c.Pointer
	Unused [184]byte
}

TODO(spongehah): Write

func (*Write) Write 

func (req *Write) Write(stream *Stream, bufs *Buf, nbufs c.Uint, writeCb WriteCb) c.Int

llgo:link (*Write).Write C.uv_write

func (*Write) Write2 

func (req *Write) Write2(stream *Stream, bufs *Buf, nbufs c.Uint, sendStream *Stream, writeCb WriteCb) c.Int

llgo:link (*Write).Write2 C.uv_write2

type WriteCb 

type WriteCb func(req *Write, status c.Int)

Source Files

View all Source files

Directories

Path Synopsis
_demo
async command
async_fs command
echo_server command

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.