Documentation ¶
Index ¶
- Variables
- func ProcessConnectionCounts(ctx context.Context, databaseConn *sql.DB, sqlTimeout time.Duration, ...) error
- func ProcessStaleConnections(ctx context.Context, databaseConn *sql.DB, sqlTimeout time.Duration, ...) error
- func StartConnectedAccountReport(accountsToExcludeCmdLineArg string, processorFunc ConnectionCountProcessor)
- func UpdateStaleTimestampInDB(ctx context.Context, databaseConn *sql.DB, sqlTimeout time.Duration, ...)
- type ConnectionCountProcessor
- type ConnectionProcessor
- type ConnectionRegistrar
- type FatalError
- type GetAllConnections
- type GetConnectionByClientID
- type GetConnectionsByOrgID
- type SqlConnectionRegistrar
- func (scm *SqlConnectionRegistrar) FindConnectionByClientID(ctx context.Context, client_id domain.ClientID) (domain.ConnectorClientState, error)
- func (scm *SqlConnectionRegistrar) Register(ctx context.Context, rhcClient domain.ConnectorClientState) error
- func (scm *SqlConnectionRegistrar) Unregister(ctx context.Context, client_id domain.ClientID) error
Constants ¶
This section is empty.
Variables ¶
View Source
var InvalidClientIDError = errors.New("Invalid ClientID")
View Source
var InvalidOrgIDError = errors.New("Invalid OrgID")
View Source
var NotFoundError = errors.New("Not found")
Functions ¶
func ProcessConnectionCounts ¶
func ProcessStaleConnections ¶
func StartConnectedAccountReport ¶
func StartConnectedAccountReport(accountsToExcludeCmdLineArg string, processorFunc ConnectionCountProcessor)
Types ¶
type ConnectionProcessor ¶
type ConnectionProcessor func(context.Context, domain.ConnectorClientState) error
type ConnectionRegistrar ¶
type FatalError ¶
type FatalError struct {
Err error
}
func (FatalError) Error ¶
func (fe FatalError) Error() string
type GetAllConnections ¶
type GetAllConnections func(context.Context, int, int) (map[domain.AccountID]map[domain.ClientID]domain.ConnectorClientState, int, error)
func NewGetAllConnections ¶
type GetConnectionByClientID ¶
type GetConnectionByClientID func(context.Context, *logrus.Entry, domain.OrgID, domain.ClientID) (domain.ConnectorClientState, error)
type GetConnectionsByOrgID ¶
type GetConnectionsByOrgID func(context.Context, *logrus.Entry, domain.OrgID, int, int) (map[domain.ClientID]domain.ConnectorClientState, int, error)
type SqlConnectionRegistrar ¶
type SqlConnectionRegistrar struct {
// contains filtered or unexported fields
}
func (*SqlConnectionRegistrar) FindConnectionByClientID ¶
func (scm *SqlConnectionRegistrar) FindConnectionByClientID(ctx context.Context, client_id domain.ClientID) (domain.ConnectorClientState, error)
func (*SqlConnectionRegistrar) Register ¶
func (scm *SqlConnectionRegistrar) Register(ctx context.Context, rhcClient domain.ConnectorClientState) error
func (*SqlConnectionRegistrar) Unregister ¶
Click to show internal directories.
Click to hide internal directories.