Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var JSONSchema string
Functions ¶
This section is empty.
Types ¶
type Spec ¶
type Spec struct { // Kinesis Firehose delivery stream ARN where data will be sent to. // Format: `arn:${Partition}:firehose:${Region}:${Account}:deliverystream/${DeliveryStreamName}`. StreamARN string `json:"stream_arn" jsonschema:"required,minLength=1"` // Amount of retries to perform when writing a batch. MaxRetries int `json:"max_retries,omitempty" jsonschema:"minimum=1,default=5"` // Number of bytes (as Arrow buffer size) to write before starting a new record. MaxRecordSizeBytes int `json:"max_record_size_bytes,omitempty" jsonschema:"minimum=1,default=1024000"` // Number of records allowed in a single batch. MaxBatchRecords int `json:"max_batch_records,omitempty" jsonschema:"minimum=1,default=500"` // Number of bytes allowed in a single batch. MaxBatchSizeBytes int `json:"max_batch_size_bytes,omitempty" jsonschema:"minimum=1,default=4194000"` }
Amazon Kinesis Firehose destination plugin spec.
func (*Spec) SetDefaults ¶
func (s *Spec) SetDefaults()
Click to show internal directories.
Click to hide internal directories.