gcs

package
v0.7.21 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 24, 2023 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type BlobObjectClient

type BlobObjectClient interface {
	Objects(ctx context.Context, bucket string, query *storage.Query) ObjectIterator
}

BlobObjectClient This is used to abstract actual gcs client

func NewClient

func NewClient(keyFilePath string) (BlobObjectClient, error)

type BlobStorageClient

type BlobStorageClient interface {
	ListDlqMetadata(bucketInfo BucketInfo) ([]models.DlqMetadata, error)
}

BlobStorageClient This is used in service

type BucketInfo

type BucketInfo struct {
	BucketName string
	Prefix     string
	Delim      string
}

type Client

type Client struct {
	StorageClient BlobObjectClient
}

func (Client) ListDlqMetadata

func (client Client) ListDlqMetadata(bucketInfo BucketInfo) ([]models.DlqMetadata, error)

type ObjectIterator

type ObjectIterator interface {
	Next() (*storage.ObjectAttrs, error)
}

type SClient

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

func (SClient) Objects

func (c SClient) Objects(ctx context.Context, bucket string, query *storage.Query) ObjectIterator

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL