Documentation
¶
Index ¶
- type PubSubClientWrapper
- func (c *PubSubClientWrapper) Close() error
- func (c *PubSubClientWrapper) CreateBigQuerySubscription(id string, topic *pubsub.Topic, table string) error
- func (c *PubSubClientWrapper) CreateTopicWithSchema(topic, schema string) (*pubsub.Topic, error)
- func (c *PubSubClientWrapper) DeleteTopic(id string) error
- func (c *PubSubClientWrapper) DetachSubscription(sub string) error
- func (c *PubSubClientWrapper) GetTopic(id string) *pubsub.Topic
- type PubSubSchemaClientWrapper
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type PubSubClientWrapper ¶
type PubSubClientWrapper struct {
// contains filtered or unexported fields
}
func GetPubSubInstance ¶
func GetPubSubInstance() *PubSubClientWrapper
func (*PubSubClientWrapper) Close ¶
func (c *PubSubClientWrapper) Close() error
func (*PubSubClientWrapper) CreateBigQuerySubscription ¶
func (c *PubSubClientWrapper) CreateBigQuerySubscription(id string, topic *pubsub.Topic, table string) error
Pub/Sub creates and maintains a service account for each project in the format service-project-number@gcp-sa-pubsub.iam.gserviceaccount.com. To create a BigQuery subscription, the Pub/Sub service account must have permission to write to the specific BigQuery table and to read the table metadata. Grant the BigQuery Data Editor (roles/bigquery.dataEditor) role and the BigQuery Metadata Viewer (roles/bigquery.metadataViewer) role to the Pub/Sub service account. Steps: 1. In the Google Cloud console, go to the IAM -> Click Grant access 2. In the Add Principals section, enter the name of your Pub/Sub service account. The format of the service account is service-project-number@gcp-sa-pubsub.iam.gserviceaccount.com. For example, for a project with project-number=112233445566, the service account is of the format service-112233445566@gcp-sa-pubsub.iam.gserviceaccount.com. 3. In the Assign Roles section, click Add roles, and add: - BigQuery Data Editor role - BigQuery Metadata Viewer role 4. Click Save
func (*PubSubClientWrapper) CreateTopicWithSchema ¶
func (c *PubSubClientWrapper) CreateTopicWithSchema(topic, schema string) (*pubsub.Topic, error)
func (*PubSubClientWrapper) DeleteTopic ¶
func (c *PubSubClientWrapper) DeleteTopic(id string) error
func (*PubSubClientWrapper) DetachSubscription ¶
func (c *PubSubClientWrapper) DetachSubscription(sub string) error
type PubSubSchemaClientWrapper ¶
type PubSubSchemaClientWrapper struct {
// contains filtered or unexported fields
}
func GetPubSubSchemaInstance ¶
func GetPubSubSchemaInstance() *PubSubSchemaClientWrapper
func (*PubSubSchemaClientWrapper) Close ¶
func (c *PubSubSchemaClientWrapper) Close() error
func (*PubSubSchemaClientWrapper) CreateProtoBufSchema ¶
func (c *PubSubSchemaClientWrapper) CreateProtoBufSchema(schema, protoFile string) error
CreateProtoBufSchema creates a schema resource from a schema proto file
func (*PubSubSchemaClientWrapper) DeleteSchema ¶
func (c *PubSubSchemaClientWrapper) DeleteSchema(id string) error
Source Files