mocks

Documentation

Index

• type GDTaskRepository
  • func NewGDTaskRepository() *GDTaskRepository
  • func (r *GDTaskRepository) AppendOutput(_ context.Context, _ *domain.GDTask, _ []byte) error
  • func (r *GDTaskRepository) Clear()
  • func (r *GDTaskRepository) FindByID(_ context.Context, id int) (*domain.GDTask, error)
  • func (r *GDTaskRepository) FindByStatus(_ context.Context, status domain.GDTaskStatus) ([]*domain.GDTask, error)
  • func (r *GDTaskRepository) Save(_ context.Context, task *domain.GDTask) error
  • func (r *GDTaskRepository) Set(items []*domain.GDTask)
• type ServerRepository
  • func NewServerRepository() *ServerRepository
  • func (r *ServerRepository) Clear()
  • func (r *ServerRepository) FindByID(_ context.Context, id int) (*domain.Server, error)
  • func (r *ServerRepository) IDs(_ context.Context) ([]int, error)
  • func (r *ServerRepository) Save(_ context.Context, server *domain.Server) error
  • func (r *ServerRepository) Set(items []*domain.Server)
• type ServerTaskRepository
  • func NewServerTaskRepository() *ServerTaskRepository
  • func (r *ServerTaskRepository) Clear()
  • func (r *ServerTaskRepository) Fail(_ context.Context, task *domain.ServerTask, output []byte) error
  • func (r *ServerTaskRepository) Find(_ context.Context) ([]*domain.ServerTask, error)
  • func (r *ServerTaskRepository) FindByID(_ context.Context, id int) (*domain.ServerTask, error)
  • func (r *ServerTaskRepository) Save(_ context.Context, task *domain.ServerTask) error
  • func (r *ServerTaskRepository) Set(items []*domain.ServerTask)
• type TasksStatsReader
  • func (t *TasksStatsReader) Stats() domain.GDTaskStats

Types

type GDTaskRepository

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

func NewGDTaskRepository

func NewGDTaskRepository() *GDTaskRepository

func (*GDTaskRepository) AppendOutput

func (r *GDTaskRepository) AppendOutput(_ context.Context, _ *domain.GDTask, _ []byte) error

func (*GDTaskRepository) Clear

func (r *GDTaskRepository) Clear()

func (*GDTaskRepository) FindByID

func (r *GDTaskRepository) FindByID(_ context.Context, id int) (*domain.GDTask, error)

func (*GDTaskRepository) FindByStatus

func (r *GDTaskRepository) FindByStatus(_ context.Context, status domain.GDTaskStatus) ([]*domain.GDTask, error)

func (*GDTaskRepository) Save

func (r *GDTaskRepository) Save(_ context.Context, task *domain.GDTask) error

func (*GDTaskRepository) Set

func (r *GDTaskRepository) Set(items []*domain.GDTask)

type ServerRepository

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

func NewServerRepository

func NewServerRepository() *ServerRepository

func (*ServerRepository) Clear

func (r *ServerRepository) Clear()

func (*ServerRepository) FindByID

func (r *ServerRepository) FindByID(_ context.Context, id int) (*domain.Server, error)

func (*ServerRepository) IDs

func (r *ServerRepository) IDs(_ context.Context) ([]int, error)

func (*ServerRepository) Save

func (r *ServerRepository) Save(_ context.Context, server *domain.Server) error

func (*ServerRepository) Set

func (r *ServerRepository) Set(items []*domain.Server)

type ServerTaskRepository

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

func NewServerTaskRepository

func NewServerTaskRepository() *ServerTaskRepository

func (*ServerTaskRepository) Clear

func (r *ServerTaskRepository) Clear()

func (*ServerTaskRepository) Fail

func (r *ServerTaskRepository) Fail(_ context.Context, task *domain.ServerTask, output []byte) error

func (*ServerTaskRepository) Find

func (r *ServerTaskRepository) Find(_ context.Context) ([]*domain.ServerTask, error)

func (*ServerTaskRepository) FindByID

func (r *ServerTaskRepository) FindByID(_ context.Context, id int) (*domain.ServerTask, error)

func (*ServerTaskRepository) Save

func (r *ServerTaskRepository) Save(_ context.Context, task *domain.ServerTask) error

func (*ServerTaskRepository) Set

func (r *ServerTaskRepository) Set(items []*domain.ServerTask)

type TasksStatsReader

type TasksStatsReader struct {
	WorkingCount int
	WaitingCount int
}

func (*TasksStatsReader) Stats

func (t *TasksStatsReader) Stats() domain.GDTaskStats