provider

Documentation

Index

• Constants
• type Handler
  • func NewHandler(app *conf.AppConfig, operFn OperGenFunc, objFn ObjectGenFunc) (*Handler, error)
  • func (h *Handler) Init() error
• type Job
• type Object
• type ObjectGenFunc
• type ObjectKey
  • func (k *ObjectKey) String(method conf.Naming, omit bool) string
• type OperGenFunc
• type Operator
• type Stats
  • func (s *Stats) IncFailed(n int, b int64)
  • func (s *Stats) IncObjects(n int, b int64)
  • func (s *Stats) IncSkipped(n int, b int64)
  • func (s *Stats) Merge(other *Stats)
  • func (s *Stats) ReadableString() map[int64]string
  • func (s *Stats) String() string
• type Supports
  • func NewSupports(bucketCreate, bucketDelete, objectDelete, getObjectTags bool) *Supports

Constants

const (
	JobStatusWaiting = iota
	JobStatusQueued
	JobStatusSkipped
	JobStatusFailed
	JobStatusDone
)

const (
	EmptyPath = ""
)

Types

type Handler

type Handler struct {
	Stats *Stats
	// contains filtered or unexported fields
}

func NewHandler

func NewHandler(app *conf.AppConfig, operFn OperGenFunc, objFn ObjectGenFunc) (*Handler, error)

func (*Handler) Init

func (h *Handler) Init() error

type Job

type Job struct {
	App *conf.AppConfig

	Object     Object
	Metadata   *objectify.FileObj
	Key        string
	SearchRoot string

	AppTags map[string]string
	// contains filtered or unexported fields
}

type Object

type Object interface {
	Destroy() error
	Generate() error
	Post() error
	Pre() error
}

type ObjectGenFunc

type ObjectGenFunc func(job *Job) Object

type ObjectKey

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

func (*ObjectKey) String

func (k *ObjectKey) String(method conf.Naming, omit bool) string

type OperGenFunc

type OperGenFunc func(app *conf.AppConfig) (oper Operator, err error)

type Operator

type Operator interface {
	BucketCreate() error
	BucketExists() (bool, error)
	BucketDelete() error

	ObjectDelete(key string) error
	ObjectExists(obj Object) (bool, error)
	ObjectUpload(obj Object) error
	GetObjectTags(key string) (map[string]string, error)

	Support() *Supports
}

type Stats

type Stats struct {
	Objects      int
	ObjectsBytes int64
	Failed       int
	Skipped      int
	SkippedBytes int64
}

func (*Stats) IncFailed

func (s *Stats) IncFailed(n int, b int64)

func (*Stats) IncObjects

func (s *Stats) IncObjects(n int, b int64)

func (*Stats) IncSkipped

func (s *Stats) IncSkipped(n int, b int64)

func (*Stats) Merge

func (s *Stats) Merge(other *Stats)

func (*Stats) ReadableString

func (s *Stats) ReadableString() map[int64]string

func (*Stats) String

func (s *Stats) String() string

type Supports

type Supports struct {
	BucketCreate  bool
	BucketDelete  bool
	ObjectDelete  bool
	GetObjectTags bool
}

func NewSupports

func NewSupports(bucketCreate, bucketDelete, objectDelete, getObjectTags bool) *Supports