Versions in this module Expand all Collapse all v0 v0.7.1 Jul 25, 2023 v0.7.0 Jul 20, 2023 Changes in this version + const BootstrapTimeout + const DialTimeout + const GRPCMaxRecvMsgSize + const GRPCMaxSendMsgSize + func NewLogger(level string) log.Logger + func NewScheduler(l log.Logger, conf *config.ServerConfig, pluginRepo dag.PluginRepo, ...) (*airflow.Scheduler, error) + type OptimusServer struct + func New(conf *config.ServerConfig) (*OptimusServer, error) + func (s *OptimusServer) Shutdown()
Go to main page