s3

Sep 5, 2023

Changes in this version

type Receiver

+ func (r *Receiver) EventErrorCount() int

+ func (r *Receiver) EventErrorVelocity() int

+ func (r *Receiver) EventSuccessCount() int

+ func (r *Receiver) EventSuccessVelocity() int

+ func (r *Receiver) EventTs() int64

+ func (r *Receiver) Hash() string

+ func (r *Receiver) LogSuccess()

type Sender

+ func (s *Sender) EventErrorCount() int

+ func (s *Sender) EventErrorVelocity() int

+ func (s *Sender) EventSuccessCount() int

+ func (s *Sender) EventSuccessVelocity() int

+ func (s *Sender) EventTs() int64

+ func (s *Sender) Hash() string

May 18, 2023

Changes in this version

type ReceiverConfig

+ AWSAccessKeyId string

+ AWSRegion string

+ AWSRoleARN string

+ AWSSecretAccessKey string

+ type S3Error struct

+ func (e *S3Error) Error() string

+ func (e *S3Error) Unwrap() error

type SenderConfig

+ AWSAccessKeyId string

+ AWSRegion string

+ AWSRoleARN string

+ AWSSecretAccessKey string

Nov 16, 2021

Changes in this version

+ var CommitID = ""

+ var DefaultReceiverConfig = ReceiverConfig

+ var DefaultSenderConfig = SenderConfig

+ var Name = "s3"

+ var Version = "v0.0.0"

+ func NewPlugin() (*pkgplugin.Plugin, error)

+ func NewPluginVersion(name string, version string, commitID string) (*pkgplugin.Plugin, error)

+ func NewReceiver(tid tenant.Id, plugin string, name string, config interface{}, ...) (receiver.Receiver, error)

+ func NewSender(tid tenant.Id, plugin string, name string, config interface{}, ...) (sender.Sender, error)

+ type Receiver struct

+ func (r *Receiver) Config() interface{}

+ func (r *Receiver) Count() int

+ func (r *Receiver) Name() string

+ func (r *Receiver) Plugin() string

+ func (r *Receiver) Receive(next receiver.NextFn) error

+ func (r *Receiver) StopReceiving(ctx context.Context) error

+ func (r *Receiver) Tenant() tenant.Id

+ func (r *Receiver) Trigger(e event.Event)

+ type ReceiverConfig struct

+ AcknowledgeTimeout *int

+ Bucket string

+ Path string

+ Region string

+ func (rc *ReceiverConfig) Validate() error

+ func (rc *ReceiverConfig) WithDefaults() ReceiverConfig

+ type Sender struct

+ func (s *Sender) Config() interface{}

+ func (s *Sender) Count() int

+ func (s *Sender) Name() string

+ func (s *Sender) Plugin() string

+ func (s *Sender) Send(evt event.Event)

+ func (s *Sender) StopSending(ctx context.Context)

+ func (s *Sender) Tenant() tenant.Id

+ func (s *Sender) Unwrap() sender.Sender

+ type SenderConfig struct

+ Bucket string

+ FileName string

+ FilePath string

+ Path string

+ Region string

+ func (sc *SenderConfig) Validate() error

+ func (sc SenderConfig) WithDefaults() SenderConfig