Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

object_disk

package

Go to main page

Versions in this module

v2

v2.4.17

Dec 19, 2023

v2.4.16

Dec 19, 2023

v2.4.15

Dec 19, 2023

Changes in this version

+ var DisksConnections map[string]ObjectStorageConnection

+ var DisksCredentials map[string]ObjectStorageCredentials

+ var SystemDisks map[string]clickhouse.Disk

+ func ConvertLocalPathToRemote(diskName, localPath string) (string, error)

+ func CopyObject(ctx context.Context, ch *clickhouse.ClickHouse, cfg *config.Config, ...) error

+ func DeleteFile(ctx context.Context, diskName, remotePath string) error

+ func DeleteFileWithContent(ctx context.Context, ch *clickhouse.ClickHouse, cfg *config.Config, ...) error

+ func GetFileReader(ctx context.Context, diskName, remotePath string) (io.ReadCloser, error)

+ func GetFileSize(ctx context.Context, ch *clickhouse.ClickHouse, cfg *config.Config, ...) (int64, error)

+ func InitCredentialsAndConnections(ctx context.Context, ch *clickhouse.ClickHouse, cfg *config.Config, ...) error

+ func PutFile(ctx context.Context, diskName, remotePath string, content []byte) error

+ func ReadBoolText(scanner *bufio.Scanner) (bool, error)

+ func ReadFileContent(ctx context.Context, ch *clickhouse.ClickHouse, cfg *config.Config, ...) ([]byte, error)

+ func ReadInt64Text(scanner *bufio.Scanner) (int64, error)

+ func ReadIntText(scanner *bufio.Scanner) (int, error)

+ func WriteFileContent(ctx context.Context, ch *clickhouse.ClickHouse, cfg *config.Config, ...) error

+ func WriteMetadataToFile(metadata *Metadata, path string) error

+ type Metadata struct

+ InlineData string

+ Path string

+ ReadOnly bool

+ RefCount int

+ StorageObjectCount int

+ StorageObjects []StorageObject

+ TotalSize int64

+ Version MetadataVersion

+ func ReadMetadataFromFile(path string) (*Metadata, error)

+ func ReadMetadataFromReader(metadataFile io.ReadCloser, path string) (*Metadata, error)

+ type MetadataVersion uint32

+ const VersionAbsolutePaths

+ const VersionInlineData

+ const VersionReadOnlyFlag

+ const VersionRelativePath

+ type Object struct

+ Created time.Time

+ Deleted time.Time

+ Deletes []string

+ Key string

+ Size int64

+ Versions []string

+ type ObjectStorageConnection struct

+ AzureBlob *storage.AzureBlob

+ MetadataPath string

+ S3 *storage.S3

+ Type string

+ func (c *ObjectStorageConnection) GetRemoteBucket() string

+ func (c *ObjectStorageConnection) GetRemotePath() string

+ func (c *ObjectStorageConnection) GetRemoteStorage() storage.RemoteStorage

+ type ObjectStorageCredentials struct

+ AzureAccountKey string

+ AzureAccountName string

+ AzureContainerName string

+ EndPoint string

+ S3AccessKey string

+ S3AssumeRole string

+ S3Region string

+ S3SecretKey string

+ S3StorageClass string

+ Type string

+ type StorageObject struct

+ ObjectRelativePath string

+ ObjectSize int64