job

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
  • func NewDBConnection() DBConnection
  • func (m DBConnection) Close() error
  • func (m DBConnection) Connect(driver string, dataSource string) error
  • func (m DBConnection) Ping() error
• type DBConnector
• type DbClient
• type MongoClient
• type MongoConnection
  • func NewMongoConnection() MongoConnection
  • func (m MongoConnection) Connect(ctx context.Context, opts ...*options.ClientOptions) error
  • func (m MongoConnection) Ping(ctx context.Context, rp *readpref.ReadPref) error
• type MongoConnector

Types

type CheckError

type CheckError interface {
	GetLogData() *apiPb.SchedulerResponse
}

func ExecCassandra

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

func ExecMongo(schedulerId string, config *scheduler_config_storage.DbConfig, mongo MongoConnector) CheckError

func ExecMysql

func ExecMysql(schedulerId string, config *scheduler_config_storage.DbConfig, dbC DBConnector) CheckError

func ExecPostgres

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

type DBConnection struct {
	Client DbClient
	Open   func(driverName, dataSourceName string) (*sql.DB, error)
}

func NewDBConnection

func NewDBConnection() DBConnection

func (DBConnection) Close

func (m DBConnection) Close() error

func (DBConnection) Connect

func (m DBConnection) Connect(driver string, dataSource string) error

func (DBConnection) Ping

func (m DBConnection) Ping() error

type DBConnector

type DBConnector interface {
	Connect(string, string) error
	Ping() error
	Close() error
}

type DbClient

type DbClient interface {
	Ping() error
	Close() error
}

type MongoClient

type MongoClient interface {
	Ping(ctx context.Context, rp *readpref.ReadPref) error
}

type MongoConnection

type MongoConnection struct {
	Client   MongoClient
	Connect_ func(ctx context.Context, opts ...*options.ClientOptions) (*mongo.Client, error)
}

func NewMongoConnection

func NewMongoConnection() MongoConnection

func (MongoConnection) Connect

func (m MongoConnection) Connect(ctx context.Context, opts ...*options.ClientOptions) error

func (MongoConnection) Ping

func (m MongoConnection) Ping(ctx context.Context, rp *readpref.ReadPref) error

type MongoConnector

type MongoConnector interface {
	Connect(ctx context.Context, opts ...*options.ClientOptions) error
	Ping(ctx context.Context, rp *readpref.ReadPref) error
}