batch

package
v0.0.0-...-0ade494 Latest Latest
Warning

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

Go to latest
Published: Aug 26, 2022 License: AGPL-3.0 Imports: 22 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	StatusTrackerFileName = "rudderDeleteTracker.txt"
)

Functions

This section is empty.

Types

type Batch

type Batch struct {
	FM         filemanager.FileManager
	DM         deleteManager
	TmpDirPath string
	// contains filtered or unexported fields
}

type BatchManager

type BatchManager struct {
	FMFactory filemanager.FileManagerFactory
}

func (*BatchManager) Delete

func (bm *BatchManager) Delete(ctx context.Context, job model.Job, destConfig map[string]interface{}, destName string) model.JobStatus

Delete users corresponding to input userAttributes from a given batch destination

func (*BatchManager) GetSupportedDestinations

func (bm *BatchManager) GetSupportedDestinations() []string

type S3DeleteManager

type S3DeleteManager struct{}

Jump to

Keyboard shortcuts

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