server

Documentation

Index

• func NewRouter(conf Config, assets *embed.FS, logsStorage tracer.Storage) (*http.Router, error)
• type Config
  • func LoadConfig(gitHash, buildDate string) Config
• type Exporters
  • func StartExporters(ctx context.Context, conf Config, logsStorage tracer.Storage) *Exporters
  • func (ex *Exporters) Stop()
• type MongoDB
  • func ConnectToMongoDB(ctx context.Context, conf MongoDBConfig) (*MongoDB, error)
  • func (db *MongoDB) Close(ctx context.Context) error
• type MongoDBConfig
• type ServiceConfig
• type ServiceExporterConfig

Functions

func NewRouter

func NewRouter(conf Config, assets *embed.FS, logsStorage tracer.Storage) (*http.Router, error)

Types

type Config

type Config struct {
	GitHash   string `yaml:"-"`
	BuildDate string `yaml:"-"`

	Release bool `yaml:"release"`

	ListenPort uint16        `yaml:"listen_port"`
	MongoDB    MongoDBConfig `yaml:"mongo_db"`

	Services map[string]ServiceConfig `yaml:"services"`
}

func LoadConfig

func LoadConfig(gitHash, buildDate string) Config

type Exporters

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

func StartExporters

func StartExporters(ctx context.Context, conf Config, logsStorage tracer.Storage) *Exporters

func (*Exporters) Stop

func (ex *Exporters) Stop()

type MongoDB

type MongoDB struct {
	*mongo.Database
}

func ConnectToMongoDB

func ConnectToMongoDB(ctx context.Context, conf MongoDBConfig) (*MongoDB, error)

func (*MongoDB) Close

func (db *MongoDB) Close(ctx context.Context) error

type MongoDBConfig

type MongoDBConfig struct {
	Address  string `yaml:"address"`
	Database string `yaml:"database"`
	Username string `yaml:"username"`
	Password string `yaml:"password"`
}

type ServiceConfig

type ServiceConfig struct {
	Exporter ServiceExporterConfig `yaml:"exporter"`
}

type ServiceExporterConfig

type ServiceExporterConfig struct {
	URL     string        `yaml:"url"`
	Secret  string        `yaml:"secret"`
	Refresh time.Duration `yaml:"refresh"`
	Timeout time.Duration `yaml:"timeout"`
}