enumerator

Documentation

Index

• func Glob(pattern string) ([]string, error)
• func GlobS3(path string) (prefix string, pattern string)
• func HasMeta(path string) bool
• type FileEnumerator
  • func NewFileEnumerator(config config.SupplierConfig) *FileEnumerator
  • func (s *FileEnumerator) Enumerate() ([]string, error)
  • func (s *FileEnumerator) Origin() string
• type FileEnumeratorConfig
• type S3Enumerator
  • func NewS3Enumerator(config config.SupplierConfig) *S3Enumerator
  • func (s *S3Enumerator) Enumerate() ([]string, error)
  • func (s *S3Enumerator) Origin() string
• type StateEnumerator
  • func GetEnumerator(config config.SupplierConfig) StateEnumerator

Functions

func Glob

func Glob(pattern string) ([]string, error)

func GlobS3

func GlobS3(path string) (prefix string, pattern string)

func HasMeta

func HasMeta(path string) bool

Types

type FileEnumerator

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

func NewFileEnumerator

func NewFileEnumerator(config config.SupplierConfig) *FileEnumerator

func (*FileEnumerator) Enumerate

func (s *FileEnumerator) Enumerate() ([]string, error)

func (*FileEnumerator) Origin

func (s *FileEnumerator) Origin() string

type FileEnumeratorConfig

type FileEnumeratorConfig struct {
	Bucket *string
	Prefix *string
}

type S3Enumerator

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

func NewS3Enumerator

func NewS3Enumerator(config config.SupplierConfig) *S3Enumerator

func (*S3Enumerator) Enumerate

func (s *S3Enumerator) Enumerate() ([]string, error)

func (*S3Enumerator) Origin

func (s *S3Enumerator) Origin() string

type StateEnumerator

type StateEnumerator interface {
	Origin() string
	Enumerate() ([]string, error)
}

func GetEnumerator

func GetEnumerator(config config.SupplierConfig) StateEnumerator