gcs

Documentation

Index

• type BlobObjectClient
  • func NewClient(keyFilePath string) (BlobObjectClient, error)
• type BlobStorageClient
• type BucketInfo
• type Client
  • func (client Client) ListDlqMetadata(bucketInfo BucketInfo) ([]models.DlqMetadata, error)
• type ObjectIterator
• type SClient
  • func (c SClient) Objects(ctx context.Context, bucket string, query *storage.Query) ObjectIterator

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