s3

Documentation

Index

• type Connector
  • func NewS3Connector() *Connector
  • func (c *Connector) CloseConnection()
  • func (c *Connector) GetClient() *minio.Client
  • func (c *Connector) InitConnection(def *conf.DataSourceDefinition)

Types

type Connector

type Connector struct {
	abstract.ConfigurableConnector

	Bucket string
	Prefix string
	Region string
	// contains filtered or unexported fields
}

Connector ... S3 connector

func NewS3Connector

func NewS3Connector() *Connector

NewS3Connector factory

func (*Connector) CloseConnection

func (c *Connector) CloseConnection()

CloseConnection ... terminates the connection

func (*Connector) GetClient

func (c *Connector) GetClient() *minio.Client

GetClient ... Returns the client from the connector

func (*Connector) InitConnection

func (c *Connector) InitConnection(def *conf.DataSourceDefinition)

InitConnection ... inits connection