internal

Documentation

Index

• func LoadConfig(logger log.Logger) (*service.Config, error)
• type Environment
  • func NewEnvironment(env *Environment) (*Environment, error)
  • func (env *Environment) RunServers(terminationListener chan error) func()

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
	SpannerClient  *spanner.Client
	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.