common

type BigQueryClient interface {
	Query(q string) BigQueryQueryHandle
}

type BigQueryJobHandle interface {
	Wait(ctx context.Context) (BigQueryJobStatusHandle, error)
}

type BigQueryJobStatusHandle interface {
	Err() error
}

type BigQueryQueryHandle interface {
	Run(ctx context.Context) (j BigQueryJobHandle, err error)
	SetParameters(p []bigquery.QueryParameter)
}

type BucketHandle interface {
	Object(name string) ObjectHandle
}

type ObjectHandle interface {
	NewReader(ctx context.Context) (io.ReadCloser, error)
	NewWriter(ctx context.Context) io.WriteCloser
}

type ObjectWriter interface {
	Write(p []byte) (n int, err error)
	Close() error
}

type PubSubMessageData struct {
	Bucket   string `json:"bucket"`
	FilePath string `json:"filePath"`
}

type RealBigQueryClient struct {
	Client *bigquery.Client
}

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

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

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

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

type RealStorageClient struct {
	Client *storage.Client
}

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

type StorageClient interface {
	Bucket(name string) BucketHandle
}