pullman

Feb 11, 2022

Changes in this version

+ func CacheOptions(ttl time.Duration, cleanupPeriod time.Duration) func(*PullManager) error

+ func GetString(c Config, key string) (string, bool)

+ func HashStrings(strings ...string) string

+ func OpenFile(path string) (*os.File, error)

+ func RegisterProvider(providerType string, provider StorageProvider)

+ type Config interface

+ Get func(name string) (interface{}, bool)

+ GetType func() string

+ type PullCommand struct

+ Directory string

+ RepositoryConfig Config

+ Targets []Target

+ type PullManager struct

+ func NewPullManager(log logr.Logger, options ...func(*PullManager)) *PullManager

+ func (p *PullManager) Pull(ctx context.Context, pc PullCommand) error

+ type RepositoryClient interface

+ Pull func(context.Context, PullCommand) error

+ type RepositoryConfig struct

+ func NewRepositoryConfig(storageType string, config map[string]interface{}) *RepositoryConfig

+ func (rc *RepositoryConfig) Get(key string) (interface{}, bool)

+ func (rc *RepositoryConfig) GetString(key string) (string, bool)

+ func (rc *RepositoryConfig) GetType() string

+ func (rc *RepositoryConfig) MarshalJSON() ([]byte, error)

+ func (rc *RepositoryConfig) Set(key string, val interface{})

+ func (rc *RepositoryConfig) UnmarshalJSON(bs []byte) error

+ type StorageProvider interface

+ GetKey func(config Config) string

+ NewRepository func(config Config, log logr.Logger) (RepositoryClient, error)

+ type Target struct

+ LocalPath string

+ RemotePath string