commandimpl

Documentation

Index

• func NewCommandRepository(db db.DB, queries *sqlc.Queries) command.Repository
• func NewRunningCmdRepository() command.RunningCommandRepository
• func NewService(deleteOldCmdCfg config.DeleteOldCommand, log *slog.Logger, ...) command.Service
• type Service
  • func (s *Service) CancelActiveCloudCommands(ctx context.Context) error
  • func (s *Service) CancelAllRunningCommands(ctx context.Context) error
  • func (s *Service) CancelCurrentProcessingCommand(ctx context.Context) error
  • func (s *Service) CreateCommand(ctx context.Context, params command.CreateCommandParams) (command.Command, error)
  • func (s *Service) DeleteCommandByID(ctx context.Context, params command.DeleteCommandByIDParams) error
  • func (s *Service) DeleteOldCommands(ctx context.Context) error
  • func (s *Service) GetCommandByID(ctx context.Context, params command.GetCommandByIDParams) (command.Command, error)
  • func (s *Service) GetCurrentProcessingCommand(ctx context.Context) (command.Command, error)
  • func (s *Service) ListCommands(ctx context.Context, params command.ListCommandsParams) (paging.List[command.Command], error)
  • func (s *Service) RunNextExecutableCommand(ctx context.Context) error

Functions

func NewCommandRepository

func NewCommandRepository(db db.DB, queries *sqlc.Queries) command.Repository

func NewRunningCmdRepository

func NewRunningCmdRepository() command.RunningCommandRepository

func NewService

func NewService(
	deleteOldCmdCfg config.DeleteOldCommand,
	log *slog.Logger,
	validator validator.Validator,
	publisher eventbus.Publisher,
	runningCmdRepository command.RunningCommandRepository,
	commandRepository command.Repository,
	processingLock command.ProcessingLock,
	executorService command.ExecutorService,
) command.Service

Types

type Service

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

func (*Service) CancelActiveCloudCommands

func (s *Service) CancelActiveCloudCommands(ctx context.Context) error

func (*Service) CancelAllRunningCommands

func (s *Service) CancelAllRunningCommands(ctx context.Context) error

func (*Service) CancelCurrentProcessingCommand

func (s *Service) CancelCurrentProcessingCommand(ctx context.Context) error

func (*Service) CreateCommand

func (s *Service) CreateCommand(ctx context.Context, params command.CreateCommandParams) (command.Command, error)

func (*Service) DeleteCommandByID

func (s *Service) DeleteCommandByID(ctx context.Context, params command.DeleteCommandByIDParams) error

func (*Service) DeleteOldCommands

func (s *Service) DeleteOldCommands(ctx context.Context) error

func (*Service) GetCommandByID

func (s *Service) GetCommandByID(ctx context.Context, params command.GetCommandByIDParams) (command.Command, error)

func (*Service) GetCurrentProcessingCommand

func (s *Service) GetCurrentProcessingCommand(ctx context.Context) (command.Command, error)

func (*Service) ListCommands

func (s *Service) ListCommands(ctx context.Context, params command.ListCommandsParams) (paging.List[command.Command], error)

func (*Service) RunNextExecutableCommand

func (s *Service) RunNextExecutableCommand(ctx context.Context) error