actions

Documentation

Index

• Variables
• func ComputeContextForUser(ctx context.Context, name string, user *idm.User) (context.Context, error)
• type MigrateGlobalMetaAction
  • func (c *MigrateGlobalMetaAction) FindSlug(ctx context.Context, p8WsId string) string
  • func (c *MigrateGlobalMetaAction) GetDescription(lang ...string) actions.ActionDescription
  • func (c *MigrateGlobalMetaAction) GetName() string
  • func (c *MigrateGlobalMetaAction) GetParametersForm() *forms.Form
  • func (c *MigrateGlobalMetaAction) GetRouter() nodes.Client
  • func (c *MigrateGlobalMetaAction) Init(job *jobs.Job, action *jobs.Action) error
  • func (c *MigrateGlobalMetaAction) Run(ctx context.Context, channels *actions.RunnableChannels, ...) (*jobs.ActionMessage, error)
• type MigratePydioMetaAction
  • func (c *MigratePydioMetaAction) BrowseNodesForMeta(ctx context.Context, slug string, channels *actions.RunnableChannels) []error
  • func (c *MigratePydioMetaAction) GetDescription(lang ...string) actions.ActionDescription
  • func (c *MigratePydioMetaAction) GetName() string
  • func (c *MigratePydioMetaAction) GetParametersForm() *forms.Form
  • func (c *MigratePydioMetaAction) GetRouter() nodes.Client
  • func (c *MigratePydioMetaAction) Init(job *jobs.Job, action *jobs.Action) error
  • func (c *MigratePydioMetaAction) ProvidesProgress() bool
  • func (c *MigratePydioMetaAction) Run(ctx context.Context, channels *actions.RunnableChannels, ...) (*jobs.ActionMessage, error)
  • func (c *MigratePydioMetaAction) WorkspaceHasTemplatePath(ctx context.Context, ws *idm.Workspace) (bool, error)
• type SyncSharesAction
  • func (c *SyncSharesAction) GetDescription(lang ...string) actions.ActionDescription
  • func (c *SyncSharesAction) GetName() string
  • func (c *SyncSharesAction) GetParametersForm() *forms.Form
  • func (c *SyncSharesAction) Init(job *jobs.Job, action *jobs.Action) error
  • func (c *SyncSharesAction) ParseStores(params map[string]string) error
  • func (c *SyncSharesAction) ProvidesProgress() bool
  • func (c *SyncSharesAction) Run(ctx context.Context, channels *actions.RunnableChannels, ...) (*jobs.ActionMessage, error)
• type SyncUsersAction
  • func (c *SyncUsersAction) GetDescription(lang ...string) actions.ActionDescription
  • func (c *SyncUsersAction) GetName() string
  • func (c *SyncUsersAction) GetParametersForm() *forms.Form
  • func (c *SyncUsersAction) Init(job *jobs.Job, action *jobs.Action) error
  • func (c *SyncUsersAction) ParseStores(params map[string]string) error
  • func (c *SyncUsersAction) ProvidesProgress() bool
  • func (c *SyncUsersAction) Run(ctx context.Context, channels *actions.RunnableChannels, ...) (*jobs.ActionMessage, error)
• type SyncWorkspacesAction
  • func (c *SyncWorkspacesAction) GetDescription(lang ...string) actions.ActionDescription
  • func (c *SyncWorkspacesAction) GetName() string
  • func (c *SyncWorkspacesAction) GetParametersForm() *forms.Form
  • func (c *SyncWorkspacesAction) Init(job *jobs.Job, action *jobs.Action) error
  • func (c *SyncWorkspacesAction) ParseStores(params map[string]string) error
  • func (c *SyncWorkspacesAction) ProvidesProgress() bool
  • func (c *SyncWorkspacesAction) Run(ctx context.Context, channels *actions.RunnableChannels, ...) (*jobs.ActionMessage, error)

Variables

var (
	MigrateGlobalMetaName = "actions.etl.p8-global-meta"
)

var (
	MigratePydioMetaActionName = "actions.etl.p8-legacy-meta"
)

var (
	SyncSharesActionName = "actions.etl.shares"
)

var (
	SyncUsersActionName = "actions.etl.users"
)

var (
	SyncWorkspacesActionName = "actions.etl.p8-workspaces"
)

Functions

func ComputeContextForUser

func ComputeContextForUser(ctx context.Context, name string, user *idm.User) (context.Context, error)

Types

type MigrateGlobalMetaAction

type MigrateGlobalMetaAction struct {
	common.RuntimeHolder
	// contains filtered or unexported fields
}

func (*MigrateGlobalMetaAction) FindSlug

func (c *MigrateGlobalMetaAction) FindSlug(ctx context.Context, p8WsId string) string

func (*MigrateGlobalMetaAction) GetDescription

func (c *MigrateGlobalMetaAction) GetDescription(lang ...string) actions.ActionDescription

GetDescription returns action description

func (*MigrateGlobalMetaAction) GetName

func (c *MigrateGlobalMetaAction) GetName() string

GetName returns the unique identifier of this action.

func (*MigrateGlobalMetaAction) GetParametersForm

func (c *MigrateGlobalMetaAction) GetParametersForm() *forms.Form

GetParametersForm returns a UX form

func (*MigrateGlobalMetaAction) GetRouter

func (c *MigrateGlobalMetaAction) GetRouter() nodes.Client

GetRouter returns an initialized router

func (*MigrateGlobalMetaAction) Init

func (c *MigrateGlobalMetaAction) Init(job *jobs.Job, action *jobs.Action) error

Init passes relevant parameters.

func (*MigrateGlobalMetaAction) Run

func (c *MigrateGlobalMetaAction) Run(ctx context.Context, channels *actions.RunnableChannels, input *jobs.ActionMessage) (*jobs.ActionMessage, error)

Run the actual action code

type MigratePydioMetaAction

type MigratePydioMetaAction struct {
	common.RuntimeHolder
	// contains filtered or unexported fields
}

func (*MigratePydioMetaAction) BrowseNodesForMeta

func (c *MigratePydioMetaAction) BrowseNodesForMeta(ctx context.Context, slug string, channels *actions.RunnableChannels) []error

func (*MigratePydioMetaAction) GetDescription

func (c *MigratePydioMetaAction) GetDescription(lang ...string) actions.ActionDescription

GetDescription returns action description

func (*MigratePydioMetaAction) GetName

func (c *MigratePydioMetaAction) GetName() string

GetName returns the unique identifier of this action.

func (*MigratePydioMetaAction) GetParametersForm

func (c *MigratePydioMetaAction) GetParametersForm() *forms.Form

GetParametersForm returns a UX form

func (*MigratePydioMetaAction) GetRouter

func (c *MigratePydioMetaAction) GetRouter() nodes.Client

GetRouter returns an initialized router

func (*MigratePydioMetaAction) Init

func (c *MigratePydioMetaAction) Init(job *jobs.Job, action *jobs.Action) error

Init passes relevant parameters.

func (*MigratePydioMetaAction) ProvidesProgress

func (c *MigratePydioMetaAction) ProvidesProgress() bool

ProvidesProgress implements ProgressProvider interface

func (*MigratePydioMetaAction) Run

func (c *MigratePydioMetaAction) Run(ctx context.Context, channels *actions.RunnableChannels, input *jobs.ActionMessage) (*jobs.ActionMessage, error)

Run performs the actual action code

func (*MigratePydioMetaAction) WorkspaceHasTemplatePath

func (c *MigratePydioMetaAction) WorkspaceHasTemplatePath(ctx context.Context, ws *idm.Workspace) (bool, error)

type SyncSharesAction

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

func (*SyncSharesAction) GetDescription

func (c *SyncSharesAction) GetDescription(lang ...string) actions.ActionDescription

GetDescription returns action description

func (*SyncSharesAction) GetName

func (c *SyncSharesAction) GetName() string

GetName returns the unique identifier of this action.

func (*SyncSharesAction) GetParametersForm

func (c *SyncSharesAction) GetParametersForm() *forms.Form

GetParametersForm returns a UX form

func (*SyncSharesAction) Init

func (c *SyncSharesAction) Init(job *jobs.Job, action *jobs.Action) error

Init passes relevant parameters.

func (*SyncSharesAction) ParseStores

func (c *SyncSharesAction) ParseStores(params map[string]string) error

ParseStores interpret parameters as sync stores

func (*SyncSharesAction) ProvidesProgress

func (c *SyncSharesAction) ProvidesProgress() bool

ProvidesProgress implements ProgressProvider interface

func (*SyncSharesAction) Run

func (c *SyncSharesAction) Run(ctx context.Context, channels *actions.RunnableChannels, input *jobs.ActionMessage) (*jobs.ActionMessage, error)

Run the actual action code

type SyncUsersAction

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

func (*SyncUsersAction) GetDescription

func (c *SyncUsersAction) GetDescription(lang ...string) actions.ActionDescription

GetDescription returns action description

func (*SyncUsersAction) GetName

func (c *SyncUsersAction) GetName() string

GetName returns the Unique Identifier of this task.

func (*SyncUsersAction) GetParametersForm

func (c *SyncUsersAction) GetParametersForm() *forms.Form

GetParametersForm returns a UX form

func (*SyncUsersAction) Init

func (c *SyncUsersAction) Init(job *jobs.Job, action *jobs.Action) error

Init parses and validates parameters

func (*SyncUsersAction) ParseStores

func (c *SyncUsersAction) ParseStores(params map[string]string) error

ParseStores interpret parameters as sync stores

func (*SyncUsersAction) ProvidesProgress

func (c *SyncUsersAction) ProvidesProgress() bool

ProvidesProgress implements ProgressProvider interface

func (*SyncUsersAction) Run

func (c *SyncUsersAction) Run(ctx context.Context, channels *actions.RunnableChannels, input *jobs.ActionMessage) (*jobs.ActionMessage, error)

Run the actual action code

type SyncWorkspacesAction

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

func (*SyncWorkspacesAction) GetDescription

func (c *SyncWorkspacesAction) GetDescription(lang ...string) actions.ActionDescription

GetDescription returns action description

func (*SyncWorkspacesAction) GetName

func (c *SyncWorkspacesAction) GetName() string

GetName returns the unique identifier of this action.

func (*SyncWorkspacesAction) GetParametersForm

func (c *SyncWorkspacesAction) GetParametersForm() *forms.Form

GetParametersForm returns a UX form

func (*SyncWorkspacesAction) Init

func (c *SyncWorkspacesAction) Init(job *jobs.Job, action *jobs.Action) error

Init passes relevant parameters.

func (*SyncWorkspacesAction) ParseStores

func (c *SyncWorkspacesAction) ParseStores(params map[string]string) error

ParseStores interpret parameters as sync stores

func (*SyncWorkspacesAction) ProvidesProgress

func (c *SyncWorkspacesAction) ProvidesProgress() bool

ProvidesProgress implements ProgressProvider interface

func (*SyncWorkspacesAction) Run

func (c *SyncWorkspacesAction) Run(ctx context.Context, channels *actions.RunnableChannels, input *jobs.ActionMessage) (*jobs.ActionMessage, error)

Run the actual action code.