Documentation ¶
Index ¶
- type CheckError
- func ExecCassandra(schedulerID string, config *scheduler_config_storage.DbConfig, ...) CheckError
- func ExecGrpc(schedulerID string, timeout int32, config *scheduler_config_storage.GrpcConfig, ...) CheckError
- func ExecHTTP(schedulerID string, timeout int32, config *scheduler_config_storage.HTTPConfig, ...) CheckError
- func ExecHTTPValue(schedulerID string, timeout int32, ...) CheckError
- func ExecMongo(schedulerId string, config *scheduler_config_storage.DbConfig, ...) CheckError
- func ExecMysql(schedulerId string, config *scheduler_config_storage.DbConfig, dbC DBConnector) CheckError
- func ExecPostgres(schedulerId string, config *scheduler_config_storage.DbConfig, dbC DBConnector) CheckError
- func ExecSSL(schedulerID string, timeout int32, ...) CheckError
- func ExecSiteMap(schedulerID string, timeout int32, ...) CheckError
- func ExecTCP(schedulerID string, timeout int32, config *scheduler_config_storage.TCPConfig) CheckError
- type DBConnection
- type DBConnector
- type DbClient
- type MongoClient
- type MongoConnection
- type MongoConnector
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CheckError ¶
type CheckError interface {
GetLogData() *apiPb.SchedulerResponse
}
func ExecCassandra ¶ added in v1.15.0
func ExecCassandra(schedulerID string, config *scheduler_config_storage.DbConfig, cTools cassandra_tools.CassandraTools) CheckError
func ExecGrpc ¶
func ExecGrpc(schedulerID string, timeout int32, config *scheduler_config_storage.GrpcConfig, opts ...grpc.DialOption) CheckError
func ExecHTTP ¶
func ExecHTTP(schedulerID string, timeout int32, config *scheduler_config_storage.HTTPConfig, httpTool httptools.HTTPTool) CheckError
func ExecHTTPValue ¶
func ExecHTTPValue(schedulerID string, timeout int32, config *scheduler_config_storage.HTTPValueConfig, httpTool httptools.HTTPTool) CheckError
func ExecMongo ¶ added in v1.15.0
func ExecMongo(schedulerId string, config *scheduler_config_storage.DbConfig, mongo MongoConnector) CheckError
func ExecMysql ¶ added in v1.15.0
func ExecMysql(schedulerId string, config *scheduler_config_storage.DbConfig, dbC DBConnector) CheckError
func ExecPostgres ¶ added in v1.15.0
func ExecPostgres(schedulerId string, config *scheduler_config_storage.DbConfig, dbC DBConnector) CheckError
func ExecSSL ¶
func ExecSSL(schedulerID string, timeout int32, config *scheduler_config_storage.SslExpirationConfig, cfg *tls.Config) CheckError
func ExecSiteMap ¶
func ExecSiteMap(schedulerID string, timeout int32, config *scheduler_config_storage.SiteMapConfig, siteMapStorage sitemap_storage.SiteMapStorage, httpTools httptools.HTTPTool, semaphoreFactoryFn func(n int) semaphore.Semaphore) CheckError
func ExecTCP ¶
func ExecTCP(schedulerID string, timeout int32, config *scheduler_config_storage.TCPConfig) CheckError
type DBConnection ¶ added in v1.15.0
type DBConnection struct { Client DbClient Open func(driverName, dataSourceName string) (*sql.DB, error) }
func NewDBConnection ¶ added in v1.15.0
func NewDBConnection() DBConnection
func (DBConnection) Close ¶ added in v1.15.0
func (m DBConnection) Close() error
func (DBConnection) Connect ¶ added in v1.15.0
func (m DBConnection) Connect(driver string, dataSource string) error
func (DBConnection) Ping ¶ added in v1.15.0
func (m DBConnection) Ping() error
type DBConnector ¶ added in v1.15.0
type MongoClient ¶ added in v1.15.0
type MongoConnection ¶ added in v1.15.0
type MongoConnection struct { Client MongoClient Connect_ func(ctx context.Context, opts ...*options.ClientOptions) (*mongo.Client, error) }
func NewMongoConnection ¶ added in v1.15.0
func NewMongoConnection() MongoConnection
func (MongoConnection) Connect ¶ added in v1.15.0
func (m MongoConnection) Connect(ctx context.Context, opts ...*options.ClientOptions) error
Click to show internal directories.
Click to hide internal directories.