ldappool

type LDAPConnection interface {
	// SetState sets the current state of the LDAP connection to the specified LDAPState value.
	SetState(state definitions.LDAPState)

	// GetState returns the current state of the LDAP connection as a value of type definitions.LDAPState.
	GetState() definitions.LDAPState

	// SetConn sets the LDAP connection instance to be used for subsequent operations.
	SetConn(*ldap.Conn)

	// GetConn retrieves the current LDAP connection instance, allowing interaction with the LDAP server.
	GetConn() *ldap.Conn

	// GetMutex retrieves the mutex associated with the LDAP connection for synchronization purposes.
	GetMutex() *sync.Mutex

	// Connect establishes an LDAP connection using the provided GUID and configuration, returning an error if it fails.
	Connect(guid *string, ldapConf *config.LDAPConf) error

	// Bind attempts to authenticate and establish a bound state for the LDAP connection using the provided credentials.
	Bind(guid *string, ldapConf *config.LDAPConf) error

	// Unbind gracefully disconnects the LDAP connection by sending an unbind request to the server and returns any error encountered.
	Unbind() error

	// IsClosing checks whether the LDAP connection is in the process of closing and returns true if it is.
	IsClosing() bool

	// Search executes an LDAP search request based on the specified LDAPRequest and returns the results, raw entries, or an error.
	Search(ldapRequest *bktype.LDAPRequest) (bktype.AttributeMapping, []*ldap.Entry, error)

	// Modify performs an LDAP modify operation based on the provided LDAP request and returns an error if the operation fails.
	Modify(ldapRequest *bktype.LDAPRequest) error
}

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

type LDAPPool interface {
	// StartHouseKeeper starts a background process for resource management and cleanup within the LDAP pool.
	StartHouseKeeper()

	// GetNumberOfWorkers returns the total number of workers allocated to the LDAP pool.
	GetNumberOfWorkers() int

	// SetIdleConnections configures and manages idle connections in the pool based on the provided bind parameter.
	SetIdleConnections(bind bool) error

	// HandleLookupRequest handles an LDAP lookup request and utilizes a WaitGroup for managing concurrency.
	HandleLookupRequest(ldapRequest *bktype.LDAPRequest, ldapWaitGroup *sync.WaitGroup) error

	// HandleAuthRequest processes an LDAP authentication request and manages concurrency using a WaitGroup.
	HandleAuthRequest(ldapAuthRequest *bktype.LDAPAuthRequest, ldapWaitGroup *sync.WaitGroup) error

	// Close releases all resources used by the LDAPPool and terminates any background processes or connections.
	Close()
}