actions

package
v2.2.1+incompatible Latest Latest
Warning

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

 Go to latest Published: Feb 17, 2021 License: AGPL-3.0 Imports: 31 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) GetDescription 

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

func (*MigrateGlobalMetaAction) GetName 

func (c *MigrateGlobalMetaAction) GetName() string

Unique identifier

func (*MigrateGlobalMetaAction) GetParametersForm 

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

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

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

func (*MigratePydioMetaAction) GetName 

func (c *MigratePydioMetaAction) GetName() string

Unique identifier

func (*MigratePydioMetaAction) GetParametersForm 

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

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

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

func (*SyncConfigAction) GetName 

func (c *SyncConfigAction) GetName() string

GetName returns the unique identifier of this action.

func (*SyncConfigAction) GetParametersForm 

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

func (*SyncConfigAction) Init 

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

Init passes relevant parameters.

func (*SyncConfigAction) ParseStores 

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

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

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

func (*SyncSharesAction) GetName 

func (c *SyncSharesAction) GetName() string

Unique identifier

func (*SyncSharesAction) GetParametersForm 

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

func (*SyncSharesAction) Init 

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

Pass parameters

func (*SyncSharesAction) ParseStores 

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

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

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

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

func (*SyncUsersAction) Init 

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

Init parses and validates parameters

func (*SyncUsersAction) ParseStores 

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

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

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

func (*SyncWorkspacesAction) GetName 

func (c *SyncWorkspacesAction) GetName() string

Unique identifier

func (*SyncWorkspacesAction) GetParametersForm 

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

func (*SyncWorkspacesAction) Init 

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

Pass parameters

func (*SyncWorkspacesAction) ParseStores 

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

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

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.