Documentation
¶
Index ¶
Constants ¶
View Source
const ( StaticBucketDir = "static_buckets" DynamicBucketDir = "dynamic_buckets" )
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Config ¶
type Config struct {
// > @3@4@5@6
// >
// > Under the hood this plugin uses /plugin/output/file/ to collect logs.
FileConfig file.Config `json:"file_config" child:"true"` // *
// > @3@4@5@6
// >
// > Compressed files format.
CompressionType string `json:"compression_type" default:"zip" options:"zip"` // *
// s3 section
// > @3@4@5@6
// >
// > Address of default bucket.
Endpoint string `json:"endpoint" required:"true"` // *
// > @3@4@5@6
// >
// > S3 access key.
AccessKey string `json:"access_key" required:"true"` // *
// > @3@4@5@6
// >
// > S3 secret key.
SecretKey string `json:"secret_key" required:"true"` // *
// > @3@4@5@6
// >
// > Main S3 bucket.
DefaultBucket string `json:"bucket" required:"true"` // *
// > @3@4@5@6
// >
// > Additional buckets, which can also receive event.
// > Event with bucket_name field sends to such s3 bucket.
MultiBuckets `json:"multi_buckets" required:"false"` // *
// > @3@4@5@6
// >
// > S3 connection secure option.
Secure bool `json:"secure" default:"false"` // *
// > @3@4@5@6
// >
// > Change destination bucket of event.
// > Fallback to DefaultBucket if BucketEventField bucket doesn't exist.
BucketEventField string `json:"bucket_field_event" default:""` // *
// > @3@4@5@6
// >
// > Regulates number of buckets that can be created dynamically.
DynamicBucketsLimit int `json:"dynamic_buckets_limit" default:"32"` // *
// > @3@4@5@6
// >
// > Sets upload timeout.
UploadTimeout cfg.Duration `json:"upload_timeout" default:"1m" parse:"duration"` // *
UploadTimeout_ time.Duration
// > @3@4@5@6
// >
// > Retries of upload. If File.d cannot upload for this number of attempts,
// > File.d will fall with non-zero exit code or skip message (see fatal_on_failed_insert).
Retry int `json:"retry" default:"10"` // *
// > @3@4@5@6
// >
// > After an insert error, fall with a non-zero exit code or not
FatalOnFailedInsert bool `json:"fatal_on_failed_insert" default:"false"` // *
// > @3@4@5@6
// >
// > Retention milliseconds for retry to upload.
Retention cfg.Duration `json:"retention" default:"1s" parse:"duration"` // *
Retention_ time.Duration
// > @3@4@5@6
// >
// > Multiplier for exponential increase of retention between retries
RetentionExponentMultiplier int `json:"retention_exponentially_multiplier" default:"2"` // *
}
! config-params ^ config-params
func (*Config) IsMultiBucketExists ¶
type MultiBuckets ¶
type MultiBuckets []singleBucketConfig
type ObjectStoreClient ¶
type ObjectStoreClientLimiter ¶
type ObjectStoreClientLimiter struct {
// contains filtered or unexported fields
}
func NewObjectStoreClientLimiter ¶
func NewObjectStoreClientLimiter(limit int) *ObjectStoreClientLimiter
func (*ObjectStoreClientLimiter) CanCreate ¶
func (limiter *ObjectStoreClientLimiter) CanCreate() bool
func (*ObjectStoreClientLimiter) Increment ¶
func (limiter *ObjectStoreClientLimiter) Increment()
type Plugin ¶
type Plugin struct {
// contains filtered or unexported fields
}
func (*Plugin) Start ¶
func (p *Plugin) Start(config pipeline.AnyConfig, params *pipeline.OutputPluginParams)
func (*Plugin) StartWithMinio ¶
func (p *Plugin) StartWithMinio(config pipeline.AnyConfig, params *pipeline.OutputPluginParams, factory objStoreFactory)
Click to show internal directories.
Click to hide internal directories.