s3

Feb 1, 2024

Changes in this version

type Config

+ FatalOnFailedInsert bool

+ Retention cfg.Duration

+ RetentionExponentMultiplier int

+ Retention_ time.Duration

+ Retry int

Nov 16, 2022

Changes in this version

type Config

+ UploadTimeout cfg.Duration

+ UploadTimeout_ time.Duration

type ObjectStoreClient

+ FPutObjectWithContext func(ctx context.Context, bucketName, objectName, filePath string, ...) (n int64, err error)

Oct 14, 2022

Changes in this version

type Plugin

+ func (p *Plugin) RegisterMetrics(ctl *metric.Ctl)

Feb 16, 2022

Changes in this version

+ const DynamicBucketDir

+ const StaticBucketDir

+ var ErrCreateOutputPluginCantCheckBucket = errors.New("could not check bucket")

+ var ErrCreateOutputPluginNoSuchBucket = errors.New("bucket doesn't exist")

+ func Factory() (pipeline.AnyPlugin, pipeline.AnyConfig)

+ type Config struct

+ AccessKey string

+ BucketEventField string

+ CompressionType string

+ DefaultBucket string

+ DynamicBucketsLimit int

+ Endpoint string

+ FileConfig file.Config

+ SecretKey string

+ Secure bool

+ func (c *Config) IsMultiBucketExists(bucketName string) bool

+ type MultiBuckets []singleBucketConfig

+ type ObjectStoreClient interface

+ BucketExists func(bucketName string) (bool, error)

+ FPutObject func(bucketName, objectName, filePath string, opts minio.PutObjectOptions) (n int64, err error)

+ MakeBucket func(bucketName string, location string) (err error)

+ type ObjectStoreClientLimiter struct

+ func NewObjectStoreClientLimiter(limit int) *ObjectStoreClientLimiter

+ func (limiter *ObjectStoreClientLimiter) CanCreate() bool

+ func (limiter *ObjectStoreClientLimiter) Increment()

+ type Plugin struct

+ func (p *Plugin) Out(event *pipeline.Event)

+ func (p *Plugin) Start(config pipeline.AnyConfig, params *pipeline.OutputPluginParams)

+ func (p *Plugin) StartWithMinio(config pipeline.AnyConfig, params *pipeline.OutputPluginParams, ...)

+ func (p *Plugin) Stop()