common

Aug 15, 2023

Changes in this version

+ var AsyncDestinations = []string

+ func GenerateArrayOfStrings(value string) []string

+ func GetBatchRouterConfigInt64(key, destType string, defaultValue int64) int64

+ func GetTransformedData(payload stdjson.RawMessage) string

+ type AsyncDestinationManager interface

+ GetUploadStats func(UploadStatsInput GetUploadStatsInput) GetUploadStatsResponse

+ Poll func(pollInput AsyncPoll) PollStatusResponse

+ Upload func(asyncDestStruct *AsyncDestinationStruct) AsyncUploadOutput

+ type AsyncDestinationStruct struct

+ AttemptNums map[int64]int

+ CanUpload bool

+ Count int

+ CreatedAt time.Time

+ Destination *backendconfig.DestinationT

+ DestinationUploadURL string

+ Exists bool

+ FailedJobIDs []int64

+ FileName string

+ FirstAttemptedAts map[int64]time.Time

+ ImportingJobIDs []int64

+ Manager AsyncDestinationManager

+ OriginalJobParameters map[int64]stdjson.RawMessage

+ Size int

+ UploadInProgress bool

+ UploadMutex sync.RWMutex

+ type AsyncFailedPayload struct

+ Config map[string]interface{}

+ DestType string

+ ImportId string

+ Input []map[string]interface{}

+ MetaData MetaDataT

+ type AsyncJob struct

+ Message map[string]interface{}

+ Metadata map[string]interface{}

+ type AsyncPoll struct

+ ImportId string

+ type AsyncUploadOutput struct

+ AbortCount int

+ AbortJobIDs []int64

+ AbortReason string

+ DestinationID string

+ FailedCount int

+ FailedJobIDs []int64

+ FailedReason string

+ ImportingCount int

+ ImportingJobIDs []int64

+ ImportingParameters stdjson.RawMessage

+ SucceededJobIDs []int64

+ SuccessResponse string

+ type AsyncUploadT struct

+ Config map[string]interface{}

+ DestType string

+ Input []AsyncJob

+ type BatchedJobs struct

+ Connection *Connection

+ Jobs []*jobsdb.JobT

+ TimeWindow time.Time

+ type Connection struct

+ Destination backendconfig.DestinationT

+ Source backendconfig.SourceT

+ type ErrorResponse struct

+ Error string

+ type EventStatMeta struct

+ FailedKeys []int64

+ FailedReasons map[int64]string

+ SucceededKeys []int64

+ WarningKeys []int64

+ type GetUploadStatsInput struct

+ FailedJobURLs string

+ ImportingList []*jobsdb.JobT

+ Parameters stdjson.RawMessage

+ PollResultFileURLs string

+ type GetUploadStatsResponse struct

+ Metadata EventStatMeta

+ StatusCode int

+ type ImportParameters struct

+ ImportId string

+ MetaData MetaDataT

+ type InvalidManager struct

+ func (f *InvalidManager) GetUploadStats(_ GetUploadStatsInput) GetUploadStatsResponse

+ func (f *InvalidManager) Poll(_ AsyncPoll) PollStatusResponse

+ func (f *InvalidManager) Upload(asyncDestStruct *AsyncDestinationStruct) AsyncUploadOutput

+ type MetaDataT struct

+ CSVHeaders string

+ type PollStatusResponse struct

+ Complete bool

+ FailedJobURLs string

+ HasFailed bool

+ HasWarning bool

+ InProgress bool

+ StatusCode int

+ WarningJobsURL string

+ type UploadStruct struct

+ ImportId string

+ Metadata map[string]interface{}