ccb

type ConnHandler func(conn net.Conn)

type DialOptions struct {
	// Security is the credential/config used to authenticate to the CCB
	// broker. Its Command is overridden with CCB_REQUEST. Required.
	Security *security.SecurityConfig

	// MyAddress, if set, is the reverse-connect address advertised to the
	// target (HTCondor sinful, e.g. "<1.2.3.4:5678>"). If empty, the address
	// of the local reverse-connect listener is used. Ignored in proxy mode.
	MyAddress string

	// ProxyReturnAddr, if set, switches the dial to streaming/proxy mode: the
	// requester is itself private, so instead of listening it asks the broker
	// to proxy. The value is the requester's own CCB sinful (carrying a ccbid),
	// sent as MyAddress so the broker recognizes proxy mode.
	ProxyReturnAddr string

	// RequireStreaming makes proxy mode mandatory: if the broker does not
	// support streaming, the dial fails fast rather than falling back.
	RequireStreaming bool

	// TargetDesc is a human-readable description of the target (debugging).
	TargetDesc string

	// ListenAddr is the bind address for the reverse-connect listener in
	// standard mode (default ":0"). Ignored when SharedPortEndpoint is set.
	ListenAddr string

	// SharedPortEndpoint, if set, makes a standard-mode requester accept the
	// target's reverse connection through a shared-port endpoint (a Unix socket
	// that a condor_shared_port daemon forwards connections to) instead of
	// opening its own TCP listen socket. This lets a requester whose only
	// inbound path is a shared port still be reached by the reverse connection.
	// Ignored in proxy mode (ProxyReturnAddr set).
	SharedPortEndpoint *SharedPortEndpointConfig

	// Timeout bounds the whole dial (default 30s).
	Timeout time.Duration

	// Stagger is the Happy-Eyeballs delay between starting attempts to
	// successive brokers (default 250ms). A new broker attempt is also started
	// immediately whenever an outstanding attempt fails. Set to a negative
	// value to force fully-sequential dialing (one broker at a time).
	Stagger time.Duration
}

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

type ListenerConfig struct {
	// BrokerAddrs are the CCB broker addresses ("host:port", brackets
	// optional) to register with. A daemon in a pool with multiple CCB
	// servers registers with all of them, and the union of the assigned
	// contacts (see Contacts) forms the ccbid list in the daemon's sinful.
	BrokerAddrs []string

	// BrokerAddr is a convenience for the single-broker case. If set, it is
	// appended to BrokerAddrs.
	BrokerAddr string

	// Security authenticates registration to the broker. Its Command is
	// overridden with CCB_REGISTER. Required.
	Security *security.SecurityConfig

	// Handler receives each reverse-connected inbound connection. Required.
	Handler ConnHandler

	// Name identifies this daemon to the broker (debugging only).
	Name string

	// HeartbeatInterval is how often to send ALIVE (default 1200s, min 30s).
	HeartbeatInterval time.Duration

	// ReconnectInterval is how long to wait before re-registering after a
	// broker connection drops (default 60s).
	ReconnectInterval time.Duration

	// DialTimeout bounds reverse-connect dials to requesters (default 30s).
	DialTimeout time.Duration
}

type SharedPortEndpointConfig struct {
	// SharedPortAddr is the "host:port" of the shared_port daemon that fronts
	// this endpoint. It is used to build the advertised return address
	// "<host:port?sock=NAME>" so the target reverse-connects through the shared
	// port. Required.
	SharedPortAddr string

	// SocketDir is the directory the shared_port daemon watches for endpoint
	// sockets (its DAEMON_SOCKET_DIR). The endpoint socket is created here so
	// the daemon can forward connections to it. If empty, the socket is created
	// in a temporary directory -- only useful when the shared_port daemon shares
	// that filesystem location, so prefer setting it explicitly.
	SocketDir string

	// SocketName is the shared-port id (the sock= value) to register. If empty,
	// a random ("anonymous") name is generated.
	SocketName string
}

type StreamingUnsupportedError struct {
	Broker  string
	Version string
}