nightwatch

Documentation

Index

• func InstallJobAPI(router *gin.Engine, db *gorm.DB)
• type Config
  • func (c *Config) CreateWatcherConfig() (*watcher.AggregateConfig, error)
  • func (c *Config) New(stopCh <-chan struct{}) (*nightWatch, error)
• type RESTServer
  • func NewRESTServer(stopCh <-chan struct{}, addr string, tlsOptions *genericoptions.TLSOptions, ...) *RESTServer
  • func (rs *RESTServer) Start()

Functions

func InstallJobAPI

func InstallJobAPI(router *gin.Engine, db *gorm.DB)

Types

type Config

type Config struct {
	HealthOptions     *genericoptions.HealthOptions
	MySQLOptions      *genericoptions.MySQLOptions
	RedisOptions      *genericoptions.RedisOptions
	WatchOptions      *watch.Options
	HTTPOptions       *genericoptions.HTTPOptions
	TLSOptions        *genericoptions.TLSOptions
	DisableRESTServer bool
	// The maximum concurrency event of user watcher.
	UserWatcherMaxWorkers int64
	// The list of watchers that should be disabled.
	Client clientset.Interface
	// Created from MySQLOptions.
	DB *gorm.DB
}

Config holds the configuration for the nightwatch server.

func (*Config) CreateWatcherConfig

func (c *Config) CreateWatcherConfig() (*watcher.AggregateConfig, error)

CreateWatcherConfig used to create configuration used by all watcher.

func (*Config) New

func (c *Config) New(stopCh <-chan struct{}) (*nightWatch, error)

New creates an asynchronous task instance.

type RESTServer

type RESTServer struct {
	// contains filtered or unexported fields
}

RESTServer represents the HTTP server with optional TLS and graceful shutdown capabilities.

func NewRESTServer

func NewRESTServer(stopCh <-chan struct{}, addr string, tlsOptions *genericoptions.TLSOptions, db *gorm.DB) *RESTServer

NewRESTServer creates a new instance of RESTServer with the specified options.

func (*RESTServer) Start

func (rs *RESTServer) Start()

Start begins listening for incoming requests and handles graceful shutdown if stopCh is provided.