server

Documentation

Index

• Constants
• func NewLogger(level string) log.Logger
• func NewScheduler(l log.Logger, conf config.ServerConfig, pluginRepo dag.PluginRepo, ...) (*airflow.Scheduler, error)
• type OptimusServer
  • func New(conf config.ServerConfig) (*OptimusServer, error)
  • func (s *OptimusServer) Shutdown()

Constants

const (
	GRPCMaxRecvMsgSize = 128 << 20 // 128MB
	GRPCMaxSendMsgSize = 128 << 20 // 128MB

	DialTimeout      = time.Second * 5
	BootstrapTimeout = time.Second * 10
)

Functions

func NewLogger

func NewLogger(level string) log.Logger

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()