s3

package
v0.0.1-0...-a0864a0 Latest Latest
Warning

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

Go to latest
Published: Aug 20, 2019 License: MIT Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewComponent

func NewComponent() component.Base

NewComponent Return a new Base

Types

type S3

type S3 struct {
	// contains filtered or unexported fields
}

S3 struct

func (*S3) Init

func (s *S3) Init(config cfg.Config, logger zap.SugaredLogger) error

Init func Initialize the S3 output plugin

func (*S3) SetJobChan

func (s *S3) SetJobChan(t <-chan job.Job)

SetJobChan set Job chan that this plugin will use to receive jobs

func (*S3) Start

func (s *S3) Start() error

Start the plugin and be ready for taking jobs

func (*S3) Stop

func (s *S3) Stop() error

Stop func Send a close signal to stop chan to stop taking jobs and Stop everything safely

Jump to

Keyboard shortcuts

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