peertracker

Nov 16, 2024

Changes in this version

+ var ErrInvalidConnection = errors.New("invalid connection")

+ var ErrUnsupportedPlatform = errors.New("unsupported platform")

+ var ErrUnsupportedTransport = errors.New("unsupported transport")

+ func CID2PID(cid int) int — linux/amd64

+ func NewCredentials() credentials.TransportCredentials

+ type AuthInfo struct

+ Caller CallerInfo

+ Watcher Watcher

+ func AuthInfoFromContext(ctx context.Context) (AuthInfo, bool)

+ func (AuthInfo) AuthType() string

+ type CallerInfo struct

+ Addr net.Addr

+ GID uint32

+ PID int32

+ UID uint32

+ func CallerFromContext(ctx context.Context) (CallerInfo, bool)

+ func CallerFromNamedPipeConn(conn net.Conn) (CallerInfo, error)

+ func CallerFromUDSConn(conn net.Conn) (CallerInfo, error)

+ func CallerFromVSockConn(conn net.Conn) (CallerInfo, error)

+ type Conn struct

+ Info AuthInfo

+ func (c *Conn) Close() error

+ type Listener struct

+ Tracker PeerTracker

+ func (l *Listener) Accept() (net.Conn, error)

+ func (l *Listener) Addr() net.Addr

+ func (l *Listener) Close() error

+ type ListenerFactory struct

+ Log logrus.FieldLogger

+ NewTracker func(log logrus.FieldLogger) (PeerTracker, error)

+ func (lf *ListenerFactory) ListenPipe(pipe string, pipeConfig *winio.PipeConfig) (*Listener, error)

+ func (lf *ListenerFactory) ListenUnix(network string, laddr *net.UnixAddr) (*Listener, error)

+ func (lf *ListenerFactory) ListenVSock(port uint32) (*Listener, error)

+ type ListenerFactoryOS struct

+ NewPipeListener func(pipe string, pipeConfig *winio.PipeConfig) (net.Listener, error)

+ NewUnixListener func(network string, laddr *net.UnixAddr) (*net.UnixListener, error)

+ NewVSockListener func(port uint32, cfg *vsock.Config) (*vsock.Listener, error)

+ type PeerTracker interface

+ Close func()

+ NewWatcher func(CallerInfo) (Watcher, error)

+ func NewTracker(log logrus.FieldLogger) (PeerTracker, error)

+ type Watcher interface

+ Close func()

+ IsAlive func() error

+ PID func() int32

+ func WatcherFromContext(ctx context.Context) (Watcher, bool)