tasks

Documentation

Index

• type Result
  • func Init(fs dfs.Service, spaces spaces.Service, users users.Service, ...) Result
• type SpaceCreateTaskRunner
  • func NewSpaceCreateTaskRunner(users users.Service, spaces spaces.Service, fs dfs.Service) *SpaceCreateTaskRunner
  • func (r *SpaceCreateTaskRunner) Name() string
  • func (r *SpaceCreateTaskRunner) Run(ctx context.Context, rawArgs json.RawMessage) error
  • func (r *SpaceCreateTaskRunner) RunArgs(ctx context.Context, args *scheduler.SpaceCreateArgs) error
• type UserCreateTaskRunner
  • func NewUserCreateTaskRunner(users users.Service, spaces spaces.Service, fs dfs.Service) *UserCreateTaskRunner
  • func (r *UserCreateTaskRunner) Name() string
  • func (r *UserCreateTaskRunner) Run(ctx context.Context, rawArgs json.RawMessage) error
  • func (r *UserCreateTaskRunner) RunArgs(ctx context.Context, args *scheduler.UserCreateArgs) error
• type UserDeleteTaskRunner
  • func NewUserDeleteTaskRunner(users users.Service, webSessions websessions.Service, ...) *UserDeleteTaskRunner
  • func (r *UserDeleteTaskRunner) Name() string
  • func (j *UserDeleteTaskRunner) Run(ctx context.Context, rawArgs json.RawMessage) error
  • func (r *UserDeleteTaskRunner) RunArgs(ctx context.Context, args *scheduler.UserDeleteArgs) error

Types

type Result

type Result struct {
	fx.Out
	UserDeleteTask  runner.TaskRunner `group:"tasks"`
	UserCreateTask  runner.TaskRunner `group:"tasks"`
	SpaceCreateTask runner.TaskRunner `group:"tasks"`
}

func Init

func Init(
	fs dfs.Service,
	spaces spaces.Service,
	users users.Service,
	webSessions websessions.Service,
	davSessions davsessions.Service,
	oauthSessions oauthsessions.Service,
	oauthConsents oauthconsents.Service,
) Result

type SpaceCreateTaskRunner

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

func NewSpaceCreateTaskRunner

func NewSpaceCreateTaskRunner(users users.Service, spaces spaces.Service, fs dfs.Service) *SpaceCreateTaskRunner

func (*SpaceCreateTaskRunner) Name

func (r *SpaceCreateTaskRunner) Name() string

func (*SpaceCreateTaskRunner) Run

func (r *SpaceCreateTaskRunner) Run(ctx context.Context, rawArgs json.RawMessage) error

func (*SpaceCreateTaskRunner) RunArgs

func (r *SpaceCreateTaskRunner) RunArgs(ctx context.Context, args *scheduler.SpaceCreateArgs) error

type UserCreateTaskRunner

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

func NewUserCreateTaskRunner

func NewUserCreateTaskRunner(users users.Service, spaces spaces.Service, fs dfs.Service) *UserCreateTaskRunner

func (*UserCreateTaskRunner) Name

func (r *UserCreateTaskRunner) Name() string

func (*UserCreateTaskRunner) Run

func (r *UserCreateTaskRunner) Run(ctx context.Context, rawArgs json.RawMessage) error

func (*UserCreateTaskRunner) RunArgs

func (r *UserCreateTaskRunner) RunArgs(ctx context.Context, args *scheduler.UserCreateArgs) error

type UserDeleteTaskRunner

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

func NewUserDeleteTaskRunner

func NewUserDeleteTaskRunner(
	users users.Service,
	webSessions websessions.Service,
	davSessions davsessions.Service,
	oauthSessions oauthsessions.Service,
	oauthConsents oauthconsents.Service,
	spaces spaces.Service,
	fs dfs.Service,
) *UserDeleteTaskRunner

func (*UserDeleteTaskRunner) Name

func (r *UserDeleteTaskRunner) Name() string

func (*UserDeleteTaskRunner) Run

func (j *UserDeleteTaskRunner) Run(ctx context.Context, rawArgs json.RawMessage) error

func (*UserDeleteTaskRunner) RunArgs

func (r *UserDeleteTaskRunner) RunArgs(ctx context.Context, args *scheduler.UserDeleteArgs) error