s3

Documentation

Overview

Package s3 implements S3-compatible state store.

Index

• type JSONFS3Store
  • func NewJSONFS3Store(o *JSONS3StoreOptions) *JSONFS3Store
  • func (fs *JSONFS3Store) BytesToCluster(bytes []byte) (*cluster.Cluster, error)
  • func (fs *JSONFS3Store) Commit(c *cluster.Cluster) error
  • func (fs *JSONFS3Store) Destroy() error
  • func (fs *JSONFS3Store) Exists() bool
  • func (fs *JSONFS3Store) GetCluster() (*cluster.Cluster, error)
  • func (fs *JSONFS3Store) List() ([]string, error)
  • func (fs *JSONFS3Store) Read(relativePath string) ([]byte, error)
  • func (fs *JSONFS3Store) ReadStore() ([]byte, error)
  • func (fs *JSONFS3Store) Rename(existingRelativePath, newRelativePath string) error
• type JSONS3StoreOptions
• type S3BucketOptions

Types

type JSONFS3Store

type JSONFS3Store struct {
	BucketOptions *S3BucketOptions
	Client        *minio.Client
	ClusterName   string
	BasePath      string
	AbsolutePath  string
	// contains filtered or unexported fields
}

JSONFS3 exists to save the cluster at runtime to the file defined in the state.ClusterJSONFile constant. We perform this operation so that various bash scripts can get the cluster state at runtime without having to inject key/value pairs into the script or anything like that.

func NewJSONFS3Store

func NewJSONFS3Store(o *JSONS3StoreOptions) *JSONFS3Store

func (*JSONFS3Store) BytesToCluster

func (fs *JSONFS3Store) BytesToCluster(bytes []byte) (*cluster.Cluster, error)

func (*JSONFS3Store) Commit

func (fs *JSONFS3Store) Commit(c *cluster.Cluster) error

func (*JSONFS3Store) Destroy

func (fs *JSONFS3Store) Destroy() error

func (*JSONFS3Store) Exists

func (fs *JSONFS3Store) Exists() bool

func (*JSONFS3Store) GetCluster

func (fs *JSONFS3Store) GetCluster() (*cluster.Cluster, error)

func (*JSONFS3Store) List

func (fs *JSONFS3Store) List() ([]string, error)

func (*JSONFS3Store) Read

func (fs *JSONFS3Store) Read(relativePath string) ([]byte, error)

func (*JSONFS3Store) ReadStore

func (fs *JSONFS3Store) ReadStore() ([]byte, error)

func (*JSONFS3Store) Rename

func (fs *JSONFS3Store) Rename(existingRelativePath, newRelativePath string) error

type JSONS3StoreOptions

type JSONS3StoreOptions struct {
	BasePath      string
	ClusterName   string
	Client        *minio.Client
	BucketOptions *S3BucketOptions
}

type S3BucketOptions

type S3BucketOptions struct {
	EndpointURL string
	BucketName  string
}