socket

May 5, 2026

Changes in this version

type Server

+ func (s *Server) Authenticate(token string) bool

type ServerConfig

+ AuthToken string

type SocketServer

+ Authenticate func(token string) bool

May 3, 2026

Changes in this version

+ const ErrCodeInternalError

+ const ErrCodeInvalidParams

+ const ErrCodeInvalidRequest

+ const ErrCodeMethodNotFound

+ const ErrCodeParseError

+ const WindowsPipeName — windows/amd64

+ func IsWindowsNamedPipe(path string) bool — windows/amd64

+ func ValidateUnixSocketPerms(path string) error

+ type ConfigGetter interface

+ Get func(ctx context.Context, key string) (interface{}, error)

+ type ConfigSetter interface

+ Set func(ctx context.Context, key string, value interface{}) error

+ type Handler struct

+ func NewHandler(tokenResolver TokenResolver, proxyStatus ProxyStatusProvider, ...) *Handler

+ func (h *Handler) RegisterMethods(server *Server)

+ type MethodHandler func(ctx context.Context, params json.RawMessage) (interface{}, error)

+ type ProxyStatusProvider interface

+ Status func(ctx context.Context) (interface{}, error)

+ type Server struct

+ func NewServer(config ServerConfig, logger *slog.Logger) (*Server, error)

+ func (s *Server) ActiveConnections() int64

+ func (s *Server) Addr() net.Addr

+ func (s *Server) RegisterMethod(name string, handler MethodHandler)

+ func (s *Server) Serve(ctx context.Context) error

+ func (s *Server) Shutdown(ctx context.Context) error

+ type ServerConfig struct

+ MaxMsgSize int64

+ Path string

+ Perm uint32

+ RateLimit int

+ func DefaultConfig() ServerConfig

+ type SocketServer interface

+ Addr func() net.Addr

+ Serve func(ctx context.Context) error

+ Shutdown func(ctx context.Context) error

+ type TokenResolver interface

+ Resolve func(ctx context.Context, uri string) (interface{}, error)

+ type UnixTransport struct

+ func NewUnixTransport(path string, perm uint32) *UnixTransport

+ func (t *UnixTransport) Listen() (net.Listener, error)

+ func (t *UnixTransport) Path() string

+ type WindowsTransport struct — windows/amd64

+ func NewWindowsTransport(pipeName string) *WindowsTransport

+ func (t *WindowsTransport) Listen() (net.Listener, error)

+ func (t *WindowsTransport) Path() string