startup

Documentation

Index

• func ReadSecretFromFile(filename string) (string, error)
• type BotRunner
  • func NewBotRunner(logger zerolog.Logger, config Config) (*BotRunner, error)
  • func (r *BotRunner) Start() error
  • func (r *BotRunner) Stop()
• type Config
• type MigrationRunner
  • func NewMigrationRunner(logger zerolog.Logger, dbUrl string) (*MigrationRunner, error)
  • func (m *MigrationRunner) Migrate() error
• type SchedulerRunner
  • func NewSchedulerRunner(logger zerolog.Logger, config Config) (*SchedulerRunner, error)
  • func (r *SchedulerRunner) Start() error
  • func (r *SchedulerRunner) Stop()
• type ServerRunner
  • func NewServerRunner(logger zerolog.Logger, config Config) (*ServerRunner, error)
  • func (r *ServerRunner) Start() error
  • func (r *ServerRunner) Stop()
• type Storage
  • func NewStorage(logger zerolog.Logger, dbUrl string) (*Storage, error)
  • func (s *Storage) Migrate() error

Functions

func ReadSecretFromFile

func ReadSecretFromFile(filename string) (string, error)

Types

type BotRunner

type BotRunner struct {
	Logger     zerolog.Logger
	ClientConn *grpc.ClientConn
	DiscordBot discord.Bot

	Conn        *nats.Conn
	EncodedConn *nats.EncodedConn
	WaitGroup   *sync.WaitGroup
	// contains filtered or unexported fields
}

func NewBotRunner

func NewBotRunner(logger zerolog.Logger, config Config) (*BotRunner, error)

func (*BotRunner) Start

func (r *BotRunner) Start() error

func (*BotRunner) Stop

func (r *BotRunner) Stop()

type Config

type Config struct {
	GrpcPort          int
	HttpPort          int
	NatsServers       string
	DbUrl             string
	DiscordToken      string
	DiscordTokenFile  string
	ReceivingEndpoint string
}

type MigrationRunner

type MigrationRunner struct {
	Logger  zerolog.Logger
	Storage *Storage
}

func NewMigrationRunner

func NewMigrationRunner(logger zerolog.Logger, dbUrl string) (*MigrationRunner, error)

func (*MigrationRunner) Migrate

func (m *MigrationRunner) Migrate() error

type SchedulerRunner

type SchedulerRunner struct {
	Logger       zerolog.Logger
	EncodedConn  *nats.EncodedConn
	Subscription *nats.Subscription
	Scheduler    scheduler.Scheduler
	// contains filtered or unexported fields
}

func NewSchedulerRunner

func NewSchedulerRunner(logger zerolog.Logger, config Config) (*SchedulerRunner, error)

func (*SchedulerRunner) Start

func (r *SchedulerRunner) Start() error

func (*SchedulerRunner) Stop

func (r *SchedulerRunner) Stop()

type ServerRunner

type ServerRunner struct {
	Logger      zerolog.Logger
	Storage     *Storage
	Conn        *nats.Conn
	EncodedConn *nats.EncodedConn
	GrpcServer  *grpc.Server
	GrpcPort    int
	WaitGroup   *sync.WaitGroup
	Processor   processor.Processor
	Builtin     builtin.HttpServer
}

func NewServerRunner

func NewServerRunner(logger zerolog.Logger, config Config) (*ServerRunner, error)

func (*ServerRunner) Start

func (r *ServerRunner) Start() error

func (*ServerRunner) Stop

func (r *ServerRunner) Stop()

type Storage

type Storage struct {
	ProcessorRepository processor.Repository
	IntentRepository    intent.Repository
	SchedulerRepository scheduler.Repository
	UserRepository      user.Repository
}

func NewStorage

func NewStorage(logger zerolog.Logger, dbUrl string) (*Storage, error)

func (*Storage) Migrate

func (s *Storage) Migrate() error