scheduler

Documentation

Index

• type FSGCArgs
  • func (a FSGCArgs) Validate() error
• type FSMoveArgs
  • func (a FSMoveArgs) Validate() error
• type FSRefreshSizeArg
  • func (a FSRefreshSizeArg) Validate() error
• type FSRemoveDuplicateFileArgs
  • func (a FSRemoveDuplicateFileArgs) Validate() error
• type FileUploadArgs
  • func (a FileUploadArgs) Validate() error
• type MockService
  • func NewMockService(t interface{ ... }) *MockService
  • func (_m *MockService) RegisterFSMoveTask(ctx context.Context, args *FSMoveArgs) error
  • func (_m *MockService) RegisterFSRefreshSizeTask(ctx context.Context, args *FSRefreshSizeArg) error
  • func (_m *MockService) RegisterFSRemoveDuplicateFile(ctx context.Context, args *FSRemoveDuplicateFileArgs) error
  • func (_m *MockService) RegisterFileUploadTask(ctx context.Context, args *FileUploadArgs) error
  • func (_m *MockService) RegisterSpaceCreateTask(ctx context.Context, args *SpaceCreateArgs) error
  • func (_m *MockService) RegisterUserCreateTask(ctx context.Context, args *UserCreateArgs) error
  • func (_m *MockService) RegisterUserDeleteTask(ctx context.Context, args *UserDeleteArgs) error
  • func (_m *MockService) Run(ctx context.Context) error
• type Service
  • func Init(db sqlstorage.Querier, tools tools.Tools) Service
• type SpaceCreateArgs
  • func (a SpaceCreateArgs) Validate() error
• type TasksService
  • func NewService(storage taskstorage.Storage, tools tools.Tools) *TasksService
  • func (t *TasksService) RegisterFSGCTask(ctx context.Context) error
  • func (t *TasksService) RegisterFSMoveTask(ctx context.Context, args *FSMoveArgs) error
  • func (t *TasksService) RegisterFSRefreshSizeTask(ctx context.Context, args *FSRefreshSizeArg) error
  • func (t *TasksService) RegisterFSRemoveDuplicateFile(ctx context.Context, args *FSRemoveDuplicateFileArgs) error
  • func (t *TasksService) RegisterFileUploadTask(ctx context.Context, args *FileUploadArgs) error
  • func (t *TasksService) RegisterSpaceCreateTask(ctx context.Context, args *SpaceCreateArgs) error
  • func (t *TasksService) RegisterUserCreateTask(ctx context.Context, args *UserCreateArgs) error
  • func (t *TasksService) RegisterUserDeleteTask(ctx context.Context, args *UserDeleteArgs) error
  • func (t *TasksService) Run(ctx context.Context) error
• type UserCreateArgs
  • func (a UserCreateArgs) Validate() error
• type UserDeleteArgs
  • func (a UserDeleteArgs) Validate() error

Types

type FSGCArgs

type FSGCArgs struct{}

func (FSGCArgs) Validate

func (a FSGCArgs) Validate() error

type FSMoveArgs

type FSMoveArgs struct {
	SpaceID     uuid.UUID `json:"space"`
	SourceInode uuid.UUID `json:"source-inode"`
	TargetPath  string    `json:"target-path"`
	MovedAt     time.Time `json:"moved-at"`
	MovedBy     uuid.UUID `json:"moved-by"`
}

func (FSMoveArgs) Validate

func (a FSMoveArgs) Validate() error

type FSRefreshSizeArg

type FSRefreshSizeArg struct {
	ModifiedAt time.Time `json:"modified_at"`
	INode      uuid.UUID `json:"inode"`
}

func (FSRefreshSizeArg) Validate

func (a FSRefreshSizeArg) Validate() error

type FSRemoveDuplicateFileArgs

type FSRemoveDuplicateFileArgs struct {
	DuplicateFileID uuid.UUID `json:"duplicate-file-id"`
	ExistingFileID  uuid.UUID `json:"existing-file-id"`
}

func (FSRemoveDuplicateFileArgs) Validate

func (a FSRemoveDuplicateFileArgs) Validate() error

type FileUploadArgs

type FileUploadArgs struct {
	UploadedAt time.Time `json:"uploaded-at"`
	SpaceID    uuid.UUID `json:"space-id"`
	FileID     uuid.UUID `json:"file-id"`
	INodeID    uuid.UUID `json:"inode-id"`
}

func (FileUploadArgs) Validate

func (a FileUploadArgs) Validate() error

type MockService

type MockService struct {
	mock.Mock
}

MockService is an autogenerated mock type for the Service type

func NewMockService

func NewMockService(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockService

NewMockService creates a new instance of MockService. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*MockService) RegisterFSMoveTask

func (_m *MockService) RegisterFSMoveTask(ctx context.Context, args *FSMoveArgs) error

RegisterFSMoveTask provides a mock function with given fields: ctx, args

func (*MockService) RegisterFSRefreshSizeTask

func (_m *MockService) RegisterFSRefreshSizeTask(ctx context.Context, args *FSRefreshSizeArg) error

RegisterFSRefreshSizeTask provides a mock function with given fields: ctx, args

func (*MockService) RegisterFSRemoveDuplicateFile

func (_m *MockService) RegisterFSRemoveDuplicateFile(ctx context.Context, args *FSRemoveDuplicateFileArgs) error

RegisterFSRemoveDuplicateFile provides a mock function with given fields: ctx, args

func (*MockService) RegisterFileUploadTask

func (_m *MockService) RegisterFileUploadTask(ctx context.Context, args *FileUploadArgs) error

RegisterFileUploadTask provides a mock function with given fields: ctx, args

func (*MockService) RegisterSpaceCreateTask

func (_m *MockService) RegisterSpaceCreateTask(ctx context.Context, args *SpaceCreateArgs) error

RegisterSpaceCreateTask provides a mock function with given fields: ctx, args

func (*MockService) RegisterUserCreateTask

func (_m *MockService) RegisterUserCreateTask(ctx context.Context, args *UserCreateArgs) error

RegisterUserCreateTask provides a mock function with given fields: ctx, args

func (*MockService) RegisterUserDeleteTask

func (_m *MockService) RegisterUserDeleteTask(ctx context.Context, args *UserDeleteArgs) error

RegisterUserDeleteTask provides a mock function with given fields: ctx, args

func (*MockService) Run

func (_m *MockService) Run(ctx context.Context) error

Run provides a mock function with given fields: ctx

type Service

type Service interface {
	Run(ctx context.Context) error
	RegisterFileUploadTask(ctx context.Context, args *FileUploadArgs) error
	RegisterFSMoveTask(ctx context.Context, args *FSMoveArgs) error
	RegisterUserCreateTask(ctx context.Context, args *UserCreateArgs) error
	RegisterUserDeleteTask(ctx context.Context, args *UserDeleteArgs) error
	RegisterFSRefreshSizeTask(ctx context.Context, args *FSRefreshSizeArg) error
	RegisterFSRemoveDuplicateFile(ctx context.Context, args *FSRemoveDuplicateFileArgs) error
	RegisterSpaceCreateTask(ctx context.Context, args *SpaceCreateArgs) error
}

func Init

func Init(db sqlstorage.Querier, tools tools.Tools) Service

type SpaceCreateArgs

type SpaceCreateArgs struct {
	UserID uuid.UUID   `json:"user-id"`
	Name   string      `json:"name"`
	Owners []uuid.UUID `json:"owners"`
}

func (SpaceCreateArgs) Validate

func (a SpaceCreateArgs) Validate() error

type TasksService

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

func NewService

func NewService(storage taskstorage.Storage, tools tools.Tools) *TasksService

func (*TasksService) RegisterFSGCTask

func (t *TasksService) RegisterFSGCTask(ctx context.Context) error

func (*TasksService) RegisterFSMoveTask

func (t *TasksService) RegisterFSMoveTask(ctx context.Context, args *FSMoveArgs) error

func (*TasksService) RegisterFSRefreshSizeTask

func (t *TasksService) RegisterFSRefreshSizeTask(ctx context.Context, args *FSRefreshSizeArg) error

func (*TasksService) RegisterFSRemoveDuplicateFile

func (t *TasksService) RegisterFSRemoveDuplicateFile(ctx context.Context, args *FSRemoveDuplicateFileArgs) error

func (*TasksService) RegisterFileUploadTask

func (t *TasksService) RegisterFileUploadTask(ctx context.Context, args *FileUploadArgs) error

func (*TasksService) RegisterSpaceCreateTask

func (t *TasksService) RegisterSpaceCreateTask(ctx context.Context, args *SpaceCreateArgs) error

func (*TasksService) RegisterUserCreateTask

func (t *TasksService) RegisterUserCreateTask(ctx context.Context, args *UserCreateArgs) error

func (*TasksService) RegisterUserDeleteTask

func (t *TasksService) RegisterUserDeleteTask(ctx context.Context, args *UserDeleteArgs) error

func (*TasksService) Run

func (t *TasksService) Run(ctx context.Context) error

type UserCreateArgs

type UserCreateArgs struct {
	UserID uuid.UUID `json:"user-id"`
}

func (UserCreateArgs) Validate

func (a UserCreateArgs) Validate() error

type UserDeleteArgs

type UserDeleteArgs struct {
	UserID uuid.UUID `json:"user-id"`
}

func (UserDeleteArgs) Validate

func (a UserDeleteArgs) Validate() error