Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Main ¶
type Main struct { Path string `help:"File or directory path to read from."` PilosaHosts []string `help:"Comma separated list of Pilosa hosts and ports."` Index string `help:"Pilosa index."` BatchSize uint `help:"Batch size for Pilosa imports (latency/throughput tradeoff)."` Framer pdk.DashField SubjectAt string `help:"Tells the source to add a unique 'subject' key to each record which is the filename + record number."` SubjectPath []string `help:"Path to value in each record that should be mapped to column ID. Blank gets a sequential ID."` Proxy string `help:"Bind to this address to proxy and translate requests to Pilosa"` }
Main contains the configuration for an ingester with an S3 Source.
type Source ¶
type Source struct {
// contains filtered or unexported fields
}
Source is a pdk.Source which reads json objects from files on disk.
type SrcOption ¶
SrcOption is a functional option for the file Source.
func OptSrcPath ¶
OptSrcPath sets the path name for the file or directory to use for source data.
func OptSrcSubjectAt ¶
OptSrcSubjectAt tells the source to add a new key to each record whose value will be <filename>#<record number>.
Click to show internal directories.
Click to hide internal directories.