writers

Documentation

Index

• Constants
• Variables
• type GitWriter
  • func (g *GitWriter) ReadFile(filePath string) ([]byte, error)
  • func (g *GitWriter) UpdateFiles(subDir string, workPlacementName string, workloadsToCreate []v1alpha1.Workload, ...) (string, error)
• type S3Writer
  • func (b *S3Writer) ReadFile(filename string) ([]byte, error)
  • func (b *S3Writer) RemoveObject(objectName string) error
  • func (b *S3Writer) UpdateFiles(subDir string, _ string, workloadsToCreate []v1alpha1.Workload, ...) (string, 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 (
	AuthMethodIAM       = "IAM"
	AuthMethodAccessKey = "accessKey"
)

Variables

var FileNotFound = fmt.Errorf("file not found")

Types

type GitWriter

type GitWriter struct {
	GitServer gitServer
	Author    gitAuthor
	Path      string
	Log       logr.Logger
}

func (*GitWriter) ReadFile

func (g *GitWriter) ReadFile(filePath string) ([]byte, error)

func (*GitWriter) UpdateFiles

func (g *GitWriter) UpdateFiles(subDir string, workPlacementName string, workloadsToCreate []v1alpha1.Workload, workloadsToDelete []string) (string, error)

type S3Writer

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

func (*S3Writer) ReadFile

func (b *S3Writer) ReadFile(filename string) ([]byte, error)

func (*S3Writer) RemoveObject

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

func (*S3Writer) UpdateFiles

func (b *S3Writer) UpdateFiles(subDir string, _ string, workloadsToCreate []v1alpha1.Workload, workloadsToDelete []string) (string, error)

type StateStoreWriter

type StateStoreWriter interface {
	UpdateFiles(subDir string, workPlacementName string, workloadsToCreate []v1alpha1.Workload, workloadsToDelete []string) (string, error)
	ReadFile(filename string) ([]byte, 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)