system

Documentation

Index

• type Module
• type Service
• type System
  • func NewSystem(cfg config.AppConfig) (*System, error)
  • func (s *System) Config() config.AppConfig
  • func (s *System) DB() *sql.DB
  • func (s *System) JS() nats.JetStreamContext
  • func (s *System) Logger() zerolog.Logger
  • func (s *System) MigrateDB(fs fs.FS) error
  • func (s *System) Mux() *chi.Mux
  • func (s *System) RPC() *grpc.Server
  • func (s *System) WaitForRPC(ctx context.Context) error
  • func (s *System) WaitForStream(ctx context.Context) error
  • func (s *System) WaitForWeb(ctx context.Context) error
  • func (s *System) Waiter() waiter.Waiter

Types

type Module

type Module interface {
	Startup(context.Context, Service) error
}

type Service

type Service interface {
	Config() config.AppConfig
	DB() *sql.DB
	JS() nats.JetStreamContext
	Mux() *chi.Mux
	RPC() *grpc.Server
	Waiter() waiter.Waiter
	Logger() zerolog.Logger
}

type System

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

func NewSystem

func NewSystem(cfg config.AppConfig) (*System, error)

func (*System) Config

func (s *System) Config() config.AppConfig

func (*System) DB

func (s *System) DB() *sql.DB

func (*System) JS

func (s *System) JS() nats.JetStreamContext

func (*System) Logger

func (s *System) Logger() zerolog.Logger

func (*System) MigrateDB

func (s *System) MigrateDB(fs fs.FS) error

func (*System) Mux

func (s *System) Mux() *chi.Mux

func (*System) RPC

func (s *System) RPC() *grpc.Server

func (*System) WaitForRPC

func (s *System) WaitForRPC(ctx context.Context) error

func (*System) WaitForStream

func (s *System) WaitForStream(ctx context.Context) error

func (*System) WaitForWeb

func (s *System) WaitForWeb(ctx context.Context) error

func (*System) Waiter

func (s *System) Waiter() waiter.Waiter