batch

Documentation

Index

• Variables
• type Batch
• type BatchManager
  • func (bm *BatchManager) Delete(ctx context.Context, job model.Job, destConfig map[string]interface{}, ...) model.JobStatus
  • func (bm *BatchManager) GetSupportedDestinations() []string
• type S3DeleteManager

Variables

var (
	StatusTrackerFileName = "rudderDeleteTracker.txt"
)

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{}