server

package
v0.12.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 14, 2024 License: Apache-2.0 Imports: 67 Imported by: 0

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

Directories

Path Synopsis
cmd
handler

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL