manager

Documentation

Index

• Constants
• func WithoutGracefulShutdown() opt
• type Config
• type Environment
• type Manager
  • func New(opts ...opt) *Manager
  • func (m *Manager) App() string
  • func (m *Manager) Context() context.Context
  • func (m *Manager) Env() Environment
  • func (m *Manager) ForceKill()
  • func (m *Manager) Logger() util.Logger
  • func (m *Manager) Metrics() util.Metrics
  • func (m *Manager) RegisterBackgroundSvc(name string, starter backgroundSvcStarter, stopper backgroundSvcStopper)
  • func (m *Manager) RegisterGRPCServer(name string, port string, opts ...grpc.ServerOption) *grpc.Server
  • func (m *Manager) RegisterHttpServer(name string, srv *http.Server)
  • func (m *Manager) WaitForInterrupt()

Constants

const (
	EnvLocal       Environment = "local"
	EnvTest                    = "test"
	EnvDevelopment             = "development"
	EnvProduction              = "production"
)

Functions

func WithoutGracefulShutdown

func WithoutGracefulShutdown() opt

Types

type Config

type Config struct {
	AppName     string      `env:"APP"`
	Env         Environment `env:"ENV" envDefault:"local"`
	DatadogIP   string      `env:"DATADOG_IP"`
	DatadogPort string      `env:"DATADOG_PORT"`
}

type Environment

type Environment string

type Manager

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

func New

func New(opts ...opt) *Manager

func (*Manager) App

func (m *Manager) App() string

func (*Manager) Context

func (m *Manager) Context() context.Context

func (*Manager) Env

func (m *Manager) Env() Environment

func (*Manager) ForceKill

func (m *Manager) ForceKill()

func (*Manager) Logger

func (m *Manager) Logger() util.Logger

func (*Manager) Metrics

func (m *Manager) Metrics() util.Metrics

func (*Manager) RegisterBackgroundSvc

func (m *Manager) RegisterBackgroundSvc(name string, starter backgroundSvcStarter, stopper backgroundSvcStopper)

func (*Manager) RegisterGRPCServer

func (m *Manager) RegisterGRPCServer(name string, port string, opts ...grpc.ServerOption) *grpc.Server

func (*Manager) RegisterHttpServer

func (m *Manager) RegisterHttpServer(name string, srv *http.Server)

func (*Manager) WaitForInterrupt

func (m *Manager) WaitForInterrupt()