Documentation ¶
Index ¶
Constants ¶
View Source
const ( ErrFailedToEnqueueMessages = "batchapi.failed_to_enqueue_messages" ErrMessageExceedsMaxSize = "batchapi.message_exceeds_max_size" )
Variables ¶
This section is empty.
Functions ¶
Types ¶
type DelimitedFiles ¶
type Enqueuer ¶
type Enqueuer struct {
// contains filtered or unexported fields
}
func NewEnqueuer ¶
func (*Enqueuer) UploadBatchCount ¶
type FilePathLister ¶
type ItemList ¶
type ItemList struct { Items []json.RawMessage `json:"items"` BatchSize int `json:"batch_size"` }
type JobSubmission ¶
type JobSubmission struct { ItemList *ItemList `json:"item_list"` FilePathLister *FilePathLister `json:"file_path_lister"` DelimitedFiles *DelimitedFiles `json:"delimited_files"` }
Click to show internal directories.
Click to hide internal directories.