archive

Documentation

Overview

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

Index

• type ArchiveAction
  • func (a *ArchiveAction) GetName() string
  • func (a *ArchiveAction) Init(job *jobs.Job, cl client.Client, action *jobs.Action) error
  • func (a *ArchiveAction) Run(ctx context.Context, channels *actions.RunnableChannels, ...) (jobs.ActionMessage, error)

Types

type ArchiveAction

type ArchiveAction struct {
	RemainingRows uint64
}

ArchiveAction implements archiving.

func (*ArchiveAction) GetName

func (a *ArchiveAction) GetName() string

GetName returns this action unique identifier

func (*ArchiveAction) Init

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

Init passes parameters to the action

func (*ArchiveAction) Run

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

Run the actual action code