internal

package
v0.30.4 Latest Latest
Warning

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

Go to latest
Published: Apr 12, 2024 License: Apache-2.0 Imports: 24 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func LoadConfig

func LoadConfig(logger log.Logger) (*service.Config, error)

Types

type Environment

type Environment struct {
	Logger         log.Logger
	Config         *service.Config
	TimeService    stime.TimeService
	DB             *sql.DB
	InternalClient *http.Client
	Events         events.Emitter
	Telemetry      telemetry.Config

	PublicRouter *mux.Router
	AdminServer  *admin.Server
	Shutdown     func()

	HTTPFiles   *pubsub.Topic
	StreamFiles *pubsub.Topic
	ODFIFiles   odfi.Scheduler

	FileReceiver *pipeline.FileReceiver
}

Environment - Contains everything thats been instantiated for this service.

func NewEnvironment

func NewEnvironment(env *Environment) (*Environment, error)

NewEnvironment - Generates a new default environment. Overrides can be specified via configs.

func (*Environment) RunServers

func (env *Environment) RunServers(terminationListener chan error) func()

RunServers - Boots up all the servers and awaits till they are stopped.

Directories

Path Synopsis
stream
Package stream exposes gocloud.dev/pubsub and side-loads various packages to register implementations such as kafka or in-memory.
Package stream exposes gocloud.dev/pubsub and side-loads various packages to register implementations such as kafka or in-memory.
web

Jump to

Keyboard shortcuts

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