systemapi

Documentation

Overview

Package systemapi provides components for the System API service.

Index

• Variables
• type Event
• type HTTPServerConfig
• type Server
  • func NewServer(cfg *HTTPServerConfig) (srv *Server, err error)
  • func (s *Server) Shutdown(ctx context.Context) error
  • func (s *Server) Start()
• type SystemAPIConfig
  • func LoadConfig(content []byte) (*SystemAPIConfig, error)
  • func LoadConfigFromFile(path string) (*SystemAPIConfig, error)

Variables

var MaxEvents = common.GetEnvInt("MAX_EVENTS", 1000)

Types

type Event

type Event struct {
	ReceivedAt time.Time `json:"received_at"`
	Message    string    `json:"message"`
}

type HTTPServerConfig

type HTTPServerConfig struct {
	ListenAddr   string
	Log          *httplog.Logger
	PipeFilename string
	EnablePprof  bool

	DrainDuration            time.Duration
	GracefulShutdownDuration time.Duration
	ReadTimeout              time.Duration
	WriteTimeout             time.Duration

	Config *SystemAPIConfig
}

type Server

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

func NewServer

func NewServer(cfg *HTTPServerConfig) (srv *Server, err error)

func (*Server) Shutdown

func (s *Server) Shutdown(ctx context.Context) error

func (*Server) Start

func (s *Server) Start()

type SystemAPIConfig

type SystemAPIConfig struct {
	Actions     map[string]string
	FileUploads map[string]string `toml:"file_uploads"`
}

func LoadConfig

func LoadConfig(content []byte) (*SystemAPIConfig, error)

func LoadConfigFromFile

func LoadConfigFromFile(path string) (*SystemAPIConfig, error)