gcp

README

Golang GCP tools

• Some GCP SDK's wrappers for Serverless usage scenarios.

Documentation

Index

• type BigQueryClient
  • func (c *BigQueryClient) GetRowsFromSQL(sql string) [][]bigquery.Value
  • func (c *BigQueryClient) InsertRows(dataSet string, table string, rows interface{})
• type FireStoreClient
  • func (c *FireStoreClient) BatchInsert(docs []interface{}) (allIds []string)
  • func (c *FireStoreClient) Get(id string) *firestore.DocumentSnapshot
  • func (c *FireStoreClient) Set(id string, data interface{})
• type PubSubClient
• type PubSubMsg
• type StorageClient
  • func (c *StorageClient) Write(object string, content io.Reader)

Types

type BigQueryClient

type BigQueryClient struct {
	ProjectID string
}

BigQueryClient The wrapper of BigQuery client

func (*BigQueryClient) GetRowsFromSQL

func (c *BigQueryClient) GetRowsFromSQL(sql string) [][]bigquery.Value

GetRowsFromSQL Get the result rows from SQL

func (*BigQueryClient) InsertRows

func (c *BigQueryClient) InsertRows(dataSet string, table string, rows interface{})

InsertRows Insert rows to table

type FireStoreClient

type FireStoreClient struct {
	ProjectID  string
	Collection string
}

FireStoreClient The fire store client

func (*FireStoreClient) BatchInsert

func (c *FireStoreClient) BatchInsert(docs []interface{}) (allIds []string)

BatchInsert - Batch insert

func (*FireStoreClient) Get

func (c *FireStoreClient) Get(id string) *firestore.DocumentSnapshot

Get ...

func (*FireStoreClient) Set

func (c *FireStoreClient) Set(id string, data interface{})

Set ...

type PubSubClient

type PubSubClient struct {
}

PubSubClient The PubSub client

type PubSubMsg

type PubSubMsg struct {
	Data []byte `json:"data"`
}

PubSubMsg - The PubSub message

type StorageClient

type StorageClient struct {
	ProjectID string
	Timeout   time.Duration
	Bucket    string
}

StorageClient ...

func (*StorageClient) Write

func (c *StorageClient) Write(object string, content io.Reader)