MCPcopy Create free account
hub / github.com/AdRoll/baker / Upload

Interface Upload

api.go:147–159  ·  view source on GitHub ↗

Upload uploads files created by the topology output to a configured location.

Source from the content-addressed store, hash-verified

145
146// Upload uploads files created by the topology output to a configured location.
147type Upload interface {
148 // Run processes the output result as it comes through the channel.
149 // Run must block forever
150 // upch will receive filenames that Output wants to see uploaded.
151 Run(upch <-chan string) error
152
153 // Stop forces the upload to stop as cleanly as possible, which usually
154 // means to finish up all the existing downloads.
155 Stop()
156
157 // Stats returns stats about the upload process
158 Stats() UploadStats
159}

Callers

nothing calls this directly

Implementers 12

dummyInputtopology_test.go
S3upload/s3.go
Baseupload/uploadtest/base.go
SQSinput/sqs.go
Kinesisinput/kinesis.go
KCLinput/kcl.go
TCPinput/tcp.go
Listinput/list.go
Recordsinput/inputtest/records.go
Baseinput/inputtest/base.go
Randominput/inputtest/random.go
LogLineinput/inputtest/logline.go

Calls

no outgoing calls

Tested by

no test coverage detected