nxproxy

type AccountFn func(delta int)

type AddrContainer interface {
	Contains(val net.IP) bool
}

type BandwidthFn func() (int, bool)

type CredentialsError struct {
	Username *string
}

type DnsProvider interface {
	Resolver() *net.Resolver
}

type Peer struct {
	PeerOptions

	BaseContext context.Context
	Dialer      net.Dialer
	HttpClient  *http.Client

	DeltaRx atomic.Uint64
	DeltaTx atomic.Uint64
	// contains filtered or unexported fields
}

type PeerBandwidth struct {

	//	total connection bandwidth for up/down streams
	Rx uint32 `json:"rx"`
	Tx uint32 `json:"tx"`

	//	respective minimal speed per connection
	MinRx uint32 `json:"min_rx"`
	MinTx uint32 `json:"min_tx"`
}

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

type PeerDelta struct {

	//	unique peer ID
	ID uuid.UUID `json:"id"`

	//	data transferred
	Rx uint64 `json:"rx"`
	Tx uint64 `json:"tx"`
}

type PeerOptions struct {

	//	unique peer ID used for accounting identification
	ID uuid.UUID `json:"id"`

	//	optional (not so) paasword auth data
	PasswordAuth *UserPassword `json:"password_auth"`

	//	maximal number of open connections
	MaxConnections uint `json:"max_connections"`

	//	connection speed limits
	Bandwidth PeerBandwidth `json:"bandwidth"`

	//	public ip to use for outbound connections, optional
	FramedIP string `json:"framed_ip,omitempty"`

	//	used to disable a peer without completely removing it
	Disabled bool `json:"disabled"`
}

type ProxyProto string

type RateLimitError struct {
	Expires time.Time
}

type RateLimiter struct {
	RateLimiterOptions
	// contains filtered or unexported fields
}

type RateLimiterOptions struct {
	Quota  int64
	Window time.Duration
}

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

type ServerToken struct {
	ID        uuid.UUID
	SecretKey []byte
}

type ServiceOptions struct {
	SlotOptions
	Peers []PeerOptions `json:"peers"`
}

type Slot struct {
	SlotOptions

	BaseContext context.Context
	Rl          *RateLimiter
	DNS         DnsProvider
	// contains filtered or unexported fields
}

type SlotInfo struct {
	Up              bool       `json:"up"`
	Proto           ProxyProto `json:"proto"`
	BindAddr        string     `json:"bind_addr"`
	RegisteredPeers int        `json:"registered_peers"`
	Error           string     `json:"error,omitempty"`
}

type SlotOptions struct {
	Proto    ProxyProto `json:"proto"`
	BindAddr string     `json:"bind_addr"`
}

type SlotService interface {
	Info() SlotInfo
	Deltas() []PeerDelta
	SetPeers(entries []PeerOptions)
	SetOptions(opts SlotOptions) error
	Close() error
}

type UserPassword struct {
	User     string `json:"user"`
	Password string `json:"password"`
}