Documentation ¶
Index ¶
Constants ¶
View Source
const ( ConfVarStreamName = "kinesis-stream" ConfVarAwsAccessKeyId = "aws-access-key-id" ConfVarAwsSecretAccessKey = "aws-secret-access-key" ConfVarAwsRegion = "aws-region" ConfVarEndpoint = "endpoint" )
Variables ¶
View Source
var Flags = []cli.Flag{ cli.StringFlag{ Name: "config", Value: "config.yaml", Usage: "bifrost YAML config file", }, altsrc.NewStringFlag(cli.StringFlag{ Name: ConfVarStreamName, Usage: "kinesis stream name", EnvVar: "BIFROST_KINESIS_STREAM", }), altsrc.NewStringFlag(cli.StringFlag{ Name: ConfVarAwsAccessKeyId, Usage: "aws access key id", EnvVar: "AWS_ACCESS_KEY_ID", Value: "", }), altsrc.NewStringFlag(cli.StringFlag{ Name: ConfVarAwsSecretAccessKey, Usage: "aws secret access key", EnvVar: "AWS_SECRET_ACCESS_KEY", Value: "", }), altsrc.NewStringFlag(cli.StringFlag{ Name: ConfVarAwsRegion, Usage: "aws region", EnvVar: "AWS_REGION", Value: "", }), altsrc.NewStringFlag(cli.StringFlag{ Name: ConfVarEndpoint, Usage: "endpoint", EnvVar: "ENDPOINT", Value: "", Hidden: true, }), }
Functions ¶
func New ¶
func New( shutdownHandler shutdown.ShutdownHandler, txnsWritten chan<- *ordered_map.OrderedMap, statsChan chan stats.Stat, workers int, inputChans []<-chan transport.Batch, transportConfig map[string]interface{}) []*transport.Transporter
func NewBatchFactory ¶
func NewBatchFactory(transportConfig map[string]interface{}) transport.BatchFactory
Types ¶
type KinesisBatchFactory ¶
type KinesisBatchFactory struct {
// contains filtered or unexported fields
}
Click to show internal directories.
Click to hide internal directories.