archive

Documentation

Overview

Package archive provides implementation of actions to work with archive files.

Index

• type CompressAction
  • func (c *CompressAction) GetDescription(lang ...string) actions.ActionDescription
  • func (c *CompressAction) GetName() string
  • func (c *CompressAction) GetParametersForm() *forms.Form
  • func (c *CompressAction) Init(job *jobs.Job, _ client.Client, action *jobs.Action) error
  • func (c *CompressAction) Run(ctx context.Context, channels *actions.RunnableChannels, ...) (jobs.ActionMessage, error)
  • func (c *CompressAction) SetNodeFilterAsWalkFilter(f *jobs.NodesSelector)
• type ExtractAction
  • func (ex *ExtractAction) GetDescription(_ ...string) actions.ActionDescription
  • func (ex *ExtractAction) GetName() string
  • func (ex *ExtractAction) GetParametersForm() *forms.Form
  • func (ex *ExtractAction) Init(job *jobs.Job, _ client.Client, action *jobs.Action) error
  • func (ex *ExtractAction) Run(ctx context.Context, channels *actions.RunnableChannels, ...) (jobs.ActionMessage, error)

Types

type CompressAction

type CompressAction struct {
	tools.ScopedRouterConsumer
	Format     string
	TargetName string
	// contains filtered or unexported fields
}

CompressAction implements compression. Currently, it supports zip, tar and tar.gz formats.

func (*CompressAction) GetDescription

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

GetDescription returns action description

func (*CompressAction) GetName

func (c *CompressAction) GetName() string

GetName returns this action unique identifier

func (*CompressAction) GetParametersForm

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

GetParametersForm returns a UX form

func (*CompressAction) Init

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

Init passes parameters to the action

func (*CompressAction) Run

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

Run the actual action code

func (*CompressAction) SetNodeFilterAsWalkFilter

func (c *CompressAction) SetNodeFilterAsWalkFilter(f *jobs.NodesSelector)

SetNodeFilterAsWalkFilter declares this action as RecursiveNodeWalkerAction

type ExtractAction

type ExtractAction struct {
	tools.ScopedRouterConsumer
	// contains filtered or unexported fields
}

func (*ExtractAction) GetDescription

func (ex *ExtractAction) GetDescription(_ ...string) actions.ActionDescription

GetDescription returns action description

func (*ExtractAction) GetName

func (ex *ExtractAction) GetName() string

GetName returns this action unique identifier

func (*ExtractAction) GetParametersForm

func (ex *ExtractAction) GetParametersForm() *forms.Form

GetParametersForm returns a UX form

func (*ExtractAction) Init

func (ex *ExtractAction) Init(job *jobs.Job, _ client.Client, action *jobs.Action) error

Init passes parameters to the action

func (*ExtractAction) Run

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

Run the actual action code