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

Method Run

api.go:151–151  ·  view source on GitHub ↗

Run processes the output result as it comes through the channel. Run must block forever upch will receive filenames that Output wants to see uploaded.

(upch <-chan string)

Source from the content-addressed store, hash-verified

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.

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