Documentation
¶
Index ¶
Constants ¶
View Source
const ( GRPCMaxRecvMsgSize = 128 << 20 // 128MB GRPCMaxSendMsgSize = 128 << 20 // 128MB DialTimeout = time.Second * 5 BootstrapTimeout = time.Second * 10 )
Variables ¶
This section is empty.
Functions ¶
func NewScheduler ¶
func NewScheduler(l log.Logger, conf *config.ServerConfig, pluginRepo dag.PluginRepo, projecGetter airflow.ProjectGetter, secretGetter airflow.SecretGetter, ) (*airflow.Scheduler, error)
Types ¶
type OptimusServer ¶
type OptimusServer struct {
// contains filtered or unexported fields
}
func New ¶
func New(conf *config.ServerConfig) (*OptimusServer, error)
func (*OptimusServer) Shutdown ¶
func (s *OptimusServer) Shutdown()
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.