writers

Documentation

Index

• Constants
• type GitWriter
  • func (g *GitWriter) RemoveObject(filePath string) error
  • func (g *GitWriter) WriteDirWithObjects(deleteExistingContentsInDir bool, subDir string, toWrite ...v1alpha1.Workload) error
• type S3Writer
  • func (b *S3Writer) RemoveObject(objectName string) error
  • func (b *S3Writer) WriteDirWithObjects(deleteExistingContentsInDir bool, dir string, toWrite ...v1alpha1.Workload) error
• type StateStoreWriter
  • func NewGitWriter(logger logr.Logger, stateStoreSpec v1alpha1.GitStateStoreSpec, ...) (StateStoreWriter, error)
  • func NewS3Writer(logger logr.Logger, stateStoreSpec v1alpha1.BucketStateStoreSpec, ...) (StateStoreWriter, error)

Constants

const (
	Add    string = "Add"
	Delete string = "Delete"
)

const (
	AuthMethodIAM       = "IAM"
	AuthMethodAccessKey = "accessKey"
)

const (
	DeleteExistingContentsInDir   = true
	PreserveExistingContentsInDir = false
)

Types

type GitWriter

type GitWriter struct {
	Log logr.Logger
	// contains filtered or unexported fields
}

func (*GitWriter) RemoveObject

func (g *GitWriter) RemoveObject(filePath string) error

func (*GitWriter) WriteDirWithObjects

func (g *GitWriter) WriteDirWithObjects(deleteExistingContentsInDir bool, subDir string, toWrite ...v1alpha1.Workload) error

type S3Writer

type S3Writer struct {
	Log        logr.Logger
	RepoClient *minio.Client
	BucketName string
	// contains filtered or unexported fields
}

func (*S3Writer) RemoveObject

func (b *S3Writer) RemoveObject(objectName string) error

func (*S3Writer) WriteDirWithObjects

func (b *S3Writer) WriteDirWithObjects(deleteExistingContentsInDir bool, dir string, toWrite ...v1alpha1.Workload) error

type StateStoreWriter

type StateStoreWriter interface {
	WriteDirWithObjects(deleteExistingContentsInDir bool, dir string, workloads ...v1alpha1.Workload) error
	RemoveObject(objectName string) error
}

func NewGitWriter

func NewGitWriter(logger logr.Logger, stateStoreSpec v1alpha1.GitStateStoreSpec, destination v1alpha1.Destination, creds map[string][]byte) (StateStoreWriter, error)

func NewS3Writer

func NewS3Writer(logger logr.Logger, stateStoreSpec v1alpha1.BucketStateStoreSpec, destination v1alpha1.Destination, creds map[string][]byte) (StateStoreWriter, error)