job_executor

Documentation

Index

• type CassandraExecutor
• type GrpcExecutor
• type HTTPExecutor
• type HTTPValueExecutor
• type JobExecutor
  • func NewExecutor(externalStorage storage.Storage, siteMapStorage sitemap_storage.SiteMapStorage, ...) JobExecutor
• type MongoExecutor
• type MysqlExecutor
• type PostgresExecutor
• type SSLExpirationExecutor
• type SiteMapExecutor
• type TCPExecutor

Types

type CassandraExecutor

type CassandraExecutor func(schedulerId string,
	config *scheduler_config_storage.DbConfig,
	cTools cassandra_tools.CassandraTools) job.CheckError

type GrpcExecutor

type GrpcExecutor func(schedulerId string,
	timeout int32,
	config *scheduler_config_storage.GrpcConfig,
	opts ...grpc.DialOption) job.CheckError

type HTTPExecutor

type HTTPExecutor func(schedulerId string,
	timeout int32,
	config *scheduler_config_storage.HTTPConfig,
	httpTool httptools.HTTPTool) job.CheckError

type HTTPValueExecutor

type HTTPValueExecutor func(
	schedulerId string,
	timeout int32,
	config *scheduler_config_storage.HTTPValueConfig,
	httpTool httptools.HTTPTool) job.CheckError

type JobExecutor

type JobExecutor interface {
	Execute(schedulerID primitive.ObjectID)
}

func NewExecutor

func NewExecutor(
	externalStorage storage.Storage,
	siteMapStorage sitemap_storage.SiteMapStorage,
	httpTool httptools.HTTPTool,
	semaphoreFactoryFn func(n int) semaphore.Semaphore,
	configStorage scheduler_config_storage.Storage,
	execTCP TCPExecutor,
	execGrpc GrpcExecutor,
	execHTTP HTTPExecutor,
	execSiteMap SiteMapExecutor,
	execHTTPValue HTTPValueExecutor,
	execSSLExpiration SSLExpirationExecutor,
	execCassandra CassandraExecutor,
	execMongo MongoExecutor,
	execMysql MysqlExecutor,
	execPostgres PostgresExecutor,
) JobExecutor

type MongoExecutor

type MongoExecutor func(schedulerId string, config *scheduler_config_storage.DbConfig, mongo job.MongoConnector) job.CheckError

type MysqlExecutor

type MysqlExecutor func(schedulerId string, config *scheduler_config_storage.DbConfig, dbC job.DBConnector) job.CheckError

type PostgresExecutor

type PostgresExecutor func(schedulerId string, config *scheduler_config_storage.DbConfig, dbC job.DBConnector) job.CheckError

type SSLExpirationExecutor

type SSLExpirationExecutor func(
	schedulerId string,
	timeout int32,
	config *scheduler_config_storage.SslExpirationConfig,
	cfg *tls.Config,
) job.CheckError

type SiteMapExecutor

type SiteMapExecutor func(
	schedulerId string,
	timeout int32,
	config *scheduler_config_storage.SiteMapConfig,
	siteMapStorage sitemap_storage.SiteMapStorage,
	httpTools httptools.HTTPTool,
	semaphoreFactoryFn func(n int) semaphore.Semaphore) job.CheckError

type TCPExecutor

type TCPExecutor func(schedulerId string, timeout int32, config *scheduler_config_storage.TCPConfig) job.CheckError