actions

Documentation

Index

• Variables
• func ComputeContextForUser(ctx context.Context, name string, user *idm.User) (context.Context, error)
• type ConnectorConfigs
• type MigrateGlobalMetaAction
  • func (c *MigrateGlobalMetaAction) FindSlug(ctx context.Context, p8WsId string) string
  • func (c *MigrateGlobalMetaAction) GetName() string
  • func (c *MigrateGlobalMetaAction) GetRouter() *views.Router
  • func (c *MigrateGlobalMetaAction) Init(job *jobs.Job, cl client.Client, 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) GetName() string
  • func (c *MigratePydioMetaAction) GetRouter() *views.Router
  • func (c *MigratePydioMetaAction) Init(job *jobs.Job, cl client.Client, 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 SyncConfigAction
  • func (c *SyncConfigAction) GetName() string
  • func (c *SyncConfigAction) Init(job *jobs.Job, cl client.Client, action *jobs.Action) error
  • func (c *SyncConfigAction) ProvidesProgress() bool
  • func (c *SyncConfigAction) Run(ctx context.Context, channels *actions.RunnableChannels, ...) (jobs.ActionMessage, error)
• type SyncSharesAction
  • func (c *SyncSharesAction) GetName() string
  • func (c *SyncSharesAction) Init(job *jobs.Job, cl client.Client, action *jobs.Action) error
  • func (c *SyncSharesAction) ProvidesProgress() bool
  • func (c *SyncSharesAction) Run(ctx context.Context, channels *actions.RunnableChannels, ...) (jobs.ActionMessage, error)
• type SyncUsersAction
  • func (c *SyncUsersAction) GetName() string
  • func (c *SyncUsersAction) Init(job *jobs.Job, cl client.Client, action *jobs.Action) error
  • func (c *SyncUsersAction) ProvidesProgress() bool
  • func (c *SyncUsersAction) Run(ctx context.Context, channels *actions.RunnableChannels, ...) (jobs.ActionMessage, error)
• type SyncWorkspacesAction
  • func (c *SyncWorkspacesAction) GetName() string
  • func (c *SyncWorkspacesAction) Init(job *jobs.Job, cl client.Client, action *jobs.Action) 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 (
	SyncConfigActionName = "actions.etl.configs"
)

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 ConnectorConfigs

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

type MigrateGlobalMetaAction

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

func (*MigrateGlobalMetaAction) FindSlug

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

func (*MigrateGlobalMetaAction) GetName

func (c *MigrateGlobalMetaAction) GetName() string

Unique identifier

func (*MigrateGlobalMetaAction) GetRouter

func (c *MigrateGlobalMetaAction) GetRouter() *views.Router

func (*MigrateGlobalMetaAction) Init

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

Pass 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 {
	// contains filtered or unexported fields
}

func (*MigratePydioMetaAction) BrowseNodesForMeta

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

func (*MigratePydioMetaAction) GetName

func (c *MigratePydioMetaAction) GetName() string

Unique identifier

func (*MigratePydioMetaAction) GetRouter

func (c *MigratePydioMetaAction) GetRouter() *views.Router

func (*MigratePydioMetaAction) Init

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

func (*MigratePydioMetaAction) ProvidesProgress

func (c *MigratePydioMetaAction) ProvidesProgress() bool

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 SyncConfigAction

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

func (*SyncConfigAction) GetName

func (c *SyncConfigAction) GetName() string

GetName returns the unique identifier of this action.

func (*SyncConfigAction) Init

func (c *SyncConfigAction) Init(job *jobs.Job, cl client.Client, action *jobs.Action) error

Init passes relevant parameters.

func (*SyncConfigAction) ProvidesProgress

func (c *SyncConfigAction) ProvidesProgress() bool

func (*SyncConfigAction) Run

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

Run the actual action code.

type SyncSharesAction

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

func (*SyncSharesAction) GetName

func (c *SyncSharesAction) GetName() string

Unique identifier

func (*SyncSharesAction) Init

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

Pass parameters

func (*SyncSharesAction) ProvidesProgress

func (c *SyncSharesAction) ProvidesProgress() bool

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) GetName

func (c *SyncUsersAction) GetName() string

GetName returns the Unique Identifier of this task.

func (*SyncUsersAction) Init

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

Init parses and validates parameters

func (*SyncUsersAction) ProvidesProgress

func (c *SyncUsersAction) ProvidesProgress() bool

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) GetName

func (c *SyncWorkspacesAction) GetName() string

Unique identifier

func (*SyncWorkspacesAction) Init

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

Pass parameters

func (*SyncWorkspacesAction) ProvidesProgress

func (c *SyncWorkspacesAction) ProvidesProgress() bool

func (*SyncWorkspacesAction) Run

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

Run the actual action code