Documentation ¶
Index ¶
- func PubSubMessageSenderFactory(ctx context.Context, projectID string, topicID string) func(msgData PubSubMessageData) error
- func SendPubSubMessage(ctx context.Context, projectId, topicId string, data PubSubMessageData) error
- type BigQueryClient
- type BigQueryJobHandle
- type BigQueryJobStatusHandle
- type BigQueryQueryHandle
- type BucketHandle
- type ObjectHandle
- type ObjectWriter
- type PubSubMessageData
- type RealBigQueryClient
- type RealBigQueryJobHandle
- type RealBigQueryJobStatusHandle
- type RealBigQueryQueryHandle
- type RealStorageBucketHandle
- type RealStorageClient
- type RealStorageObjectHandle
- type StorageClient
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func SendPubSubMessage ¶
func SendPubSubMessage(ctx context.Context, projectId, topicId string, data PubSubMessageData) error
Types ¶
type BigQueryClient ¶
type BigQueryClient interface {
Query(q string) BigQueryQueryHandle
}
type BigQueryJobHandle ¶
type BigQueryJobHandle interface {
Wait(ctx context.Context) (BigQueryJobStatusHandle, error)
}
type BigQueryJobStatusHandle ¶
type BigQueryJobStatusHandle interface {
Err() error
}
type BigQueryQueryHandle ¶
type BigQueryQueryHandle interface { Run(ctx context.Context) (j BigQueryJobHandle, err error) SetParameters(p []bigquery.QueryParameter) }
type BucketHandle ¶
type BucketHandle interface {
Object(name string) ObjectHandle
}
type ObjectHandle ¶
type ObjectHandle interface { NewReader(ctx context.Context) (io.ReadCloser, error) NewWriter(ctx context.Context) io.WriteCloser }
type ObjectWriter ¶
type PubSubMessageData ¶
type RealBigQueryClient ¶
func (*RealBigQueryClient) Query ¶
func (r *RealBigQueryClient) Query(q string) BigQueryQueryHandle
type RealBigQueryJobHandle ¶
type RealBigQueryJobHandle struct {
// contains filtered or unexported fields
}
func (*RealBigQueryJobHandle) Wait ¶
func (s *RealBigQueryJobHandle) Wait(ctx context.Context) (BigQueryJobStatusHandle, error)
type RealBigQueryJobStatusHandle ¶
type RealBigQueryJobStatusHandle struct {
// contains filtered or unexported fields
}
func (*RealBigQueryJobStatusHandle) Err ¶
func (s *RealBigQueryJobStatusHandle) Err() error
type RealBigQueryQueryHandle ¶
type RealBigQueryQueryHandle struct {
// contains filtered or unexported fields
}
func (*RealBigQueryQueryHandle) Run ¶
func (r *RealBigQueryQueryHandle) Run(ctx context.Context) (j BigQueryJobHandle, err error)
func (*RealBigQueryQueryHandle) SetParameters ¶
func (r *RealBigQueryQueryHandle) SetParameters(p []bigquery.QueryParameter)
type RealStorageBucketHandle ¶
type RealStorageBucketHandle struct {
// contains filtered or unexported fields
}
func (*RealStorageBucketHandle) Object ¶
func (rbh *RealStorageBucketHandle) Object(name string) ObjectHandle
type RealStorageClient ¶
func (*RealStorageClient) Bucket ¶
func (r *RealStorageClient) Bucket(name string) BucketHandle
type RealStorageObjectHandle ¶
type RealStorageObjectHandle struct {
// contains filtered or unexported fields
}
func (*RealStorageObjectHandle) NewReader ¶
func (roh *RealStorageObjectHandle) NewReader(ctx context.Context) (io.ReadCloser, error)
func (*RealStorageObjectHandle) NewWriter ¶
func (roh *RealStorageObjectHandle) NewWriter(ctx context.Context) io.WriteCloser
type StorageClient ¶
type StorageClient interface {
Bucket(name string) BucketHandle
}
The StorageClient interface is defined for the *storage.Client type.
Click to show internal directories.
Click to hide internal directories.