internal

Documentation

Index

• func CheckVersionAndDB(dataDir string) (int64, dbm.BackendType, error)
• func Compress(homeDir string, chainID string, backendType dbm.BackendType, blockHeight int64, ...) error
• func GetChainID(homeDir string) (string, error)
• func LoadConfig() (aws.Config, error)
• type GCSUploader
  • func NewGCSUploader(bucket string) (*GCSUploader, error)
  • func (u *GCSUploader) Upload(reader io.Reader, filename string) error
• type ProgressReader
  • func (pr *ProgressReader) Read(p []byte) (int, error)
• type S3Uploader
  • func NewS3Uploader(bucket string, cfg aws.Config) (*S3Uploader, error)
  • func (u *S3Uploader) Upload(reader io.Reader, filename string) error
• type Uploader

Functions

func CheckVersionAndDB

func CheckVersionAndDB(
	dataDir string,
) (int64, dbm.BackendType, error)

CheckVersion gets the height of this node

func Compress

func Compress(homeDir string, chainID string, backendType dbm.BackendType, blockHeight int64, uploader Uploader, keepLocal bool, nodeType string) error

func GetChainID

func GetChainID(homeDir string) (string, error)

GetChainID returns the chain ID of the chain

func LoadConfig

func LoadConfig() (aws.Config, error)

Types

type GCSUploader

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

func NewGCSUploader

func NewGCSUploader(bucket string) (*GCSUploader, error)

func (*GCSUploader) Upload

func (u *GCSUploader) Upload(reader io.Reader, filename string) error

type ProgressReader

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

func (*ProgressReader) Read

func (pr *ProgressReader) Read(p []byte) (int, error)

type S3Uploader

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

func NewS3Uploader

func NewS3Uploader(bucket string, cfg aws.Config) (*S3Uploader, error)

func (*S3Uploader) Upload

func (u *S3Uploader) Upload(reader io.Reader, filename string) error

type Uploader

type Uploader interface {
	Upload(reader io.Reader, filename string) error
}