batchrouter

Documentation

Index

• type BatchJobsT
• type DestinationT
• type ErrorResponseT
• type HandleT
  • func (brt *HandleT) Disable()
  • func (brt *HandleT) Enable()
  • func (brt *HandleT) Setup(jobsDB *jobsdb.HandleT, destType string)
• type ObjectStorageT
• type StorageUploadOutput

Types

type BatchJobsT

type BatchJobsT struct {
	Jobs             []*jobsdb.JobT
	BatchDestination DestinationT
}

type DestinationT

type DestinationT struct {
	Source      backendconfig.SourceT
	Destination backendconfig.DestinationT
}

type ErrorResponseT

type ErrorResponseT struct {
	Error string
}

type HandleT

type HandleT struct {
	// contains filtered or unexported fields
}

func (*HandleT) Disable

func (brt *HandleT) Disable()

Disable disables a router:)

func (*HandleT) Enable

func (brt *HandleT) Enable()

Enable enables a router :)

func (*HandleT) Setup

func (brt *HandleT) Setup(jobsDB *jobsdb.HandleT, destType string)

Setup initializes this module

type ObjectStorageT

type ObjectStorageT struct {
	Config          map[string]interface{}
	Key             string
	Provider        string
	DestinationID   string
	DestinationType string
}

type StorageUploadOutput

type StorageUploadOutput struct {
	Config         map[string]interface{}
	Key            string
	LocalFilePaths []string
	JournalOpID    int64
	Error          error
	FirstEventAt   string
	LastEventAt    string
	TotalEvents    int
}