scheduler

package
v0.0.0-...-059fb3b Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 10, 2024 License: AGPL-3.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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 *sql.DB, 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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.