spec

package
v0.0.0-...-98b2634 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 6, 2024 License: MPL-2.0 Imports: 3 Imported by: 0

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()

func (*Spec) Validate

func (s *Spec) Validate() error

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL