actions

package
v2.0.1+incompatible Latest Latest
Warning

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

Go to latest
Published: Nov 19, 2019 License: AGPL-3.0 Imports: 29 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	MigrateGlobalMetaName = "actions.etl.p8-global-meta"
)
View Source
var (
	MigratePydioMetaActionName = "actions.etl.p8-legacy-meta"
)
View Source
var (
	SyncConfigActionName = "actions.etl.configs"
)
View Source
var (
	SyncSharesActionName = "actions.etl.shares"
)
View Source
var (
	SyncUsersActionName = "actions.etl.users"
)
View Source
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

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

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

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

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

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

Run the actual action code

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL