server

Documentation

Index

• Variables
• type App
  • func NewApp(cfg *config.Server) *App
  • func (app *App) Run(ctx context.Context) error
• type BodyStoreHealth
• type EventOutputHealth
• type HealthResponse
• type ModuleHealth
• type ModuleRuntimeHealth
• type OutputHealth

Variables

var Command = &cli.Command{
	Name:            "server",
	Usage:           "start directive proxy server",
	Action:          config.Manager.Action(action),
	Commands:        []*cli.Command{version.Command},
	HideHelpCommand: true,
}

Types

type App

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

func NewApp

func NewApp(cfg *config.Server) *App

func (*App) Run

func (app *App) Run(ctx context.Context) error

type BodyStoreHealth

type BodyStoreHealth struct {
	Status               string `json:"status"`
	MemoryUsedBytes      int64  `json:"memory_used_bytes"`
	MemoryAvailableBytes int64  `json:"memory_available_bytes"`
	QueuedRequests       int    `json:"queued_requests"`
	AdmittedTotal        uint64 `json:"admitted_total"`
	QueueFullTotal       uint64 `json:"queue_full_total"`
	QueueTimeoutTotal    uint64 `json:"queue_timeout_total"`
	CanceledTotal        uint64 `json:"canceled_total"`
	MaxQueueWaitMS       int64  `json:"max_queue_wait_ms"`
}

type EventOutputHealth

type EventOutputHealth struct {
	Enabled bool         `json:"enabled"`
	Status  string       `json:"status"`
	Sink    OutputHealth `json:"sink"`
}

type HealthResponse

type HealthResponse struct {
	Status      string              `json:"status" example:"ok"`
	Timestamp   time.Time           `json:"timestamp"`
	Modules     ModuleRuntimeHealth `json:"modules"`
	EventOutput EventOutputHealth   `json:"event_output"`
	BodyStore   BodyStoreHealth     `json:"body_store"`
}

type ModuleHealth

type ModuleHealth struct {
	Status        string     `json:"status"`
	LastFailureAt *time.Time `json:"last_failure_at,omitempty"`
}

type ModuleRuntimeHealth

type ModuleRuntimeHealth struct {
	Status string                  `json:"status"`
	Items  map[string]ModuleHealth `json:"items"`
}

type OutputHealth

type OutputHealth struct {
	Type           string     `json:"type"`
	Status         string     `json:"status"`
	LastFailureAt  *time.Time `json:"last_failure_at,omitempty"`
	QueuedRecords  int64      `json:"queued_records,omitzero"`
	QueuedBytes    int64      `json:"queued_bytes,omitzero"`
	DroppedRecords uint64     `json:"dropped_records,omitzero"`
}