internal

type BaseClient struct {
	*client.Options

	Id int64
	// contains filtered or unexported fields
}

type BaseServer struct {
	xsync.Stoppable
	*server.Options
	// contains filtered or unexported fields
}

type ConnCarrier struct {
	ID    uint64
	Conn  net.Conn
	Codec xnet.Codec
}

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

type CreateTunnelFunc func(ctx context.Context, tunnelType int32, objectId int64) (xnet.Tunnel, error)

type Dialer interface {
	// Dial establishes a connection to the target
	Dial(ctx context.Context, target string) (conns []ConnCarrier, err error)

	// Stop stops the dialer
	Stop(ctx context.Context) error

	// Target returns the target address/URL for this dialer
	Target() string
}

type Dialog struct {
	xsync.Stoppable
	// contains filtered or unexported fields
}

type Listener interface {
	// Start starts the listener and begins accepting connections
	Start(ctx context.Context) error

	// Stop stops the listener gracefully
	Stop(ctx context.Context) error

	// Accept accepts a new connection and returns it as net.Conn
	Accept(ctx context.Context) (ConnCarrier, error)

	// Endpoint returns the endpoint URL for this listener
	Endpoint() (string, error)
}

type Tunnel struct {
	xsync.Stoppable
	xnet.AppTunnel
	// contains filtered or unexported fields
}

type Worker struct {
	xsync.Stoppable
	// contains filtered or unexported fields
}

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