bqstream

Documentation

Index

• func CloseProducer(producer interface{}) error
• func Produce(jsonData json.RawMessage, producer interface{}, destConfig interface{}) (statusCode int, respStatus string, responseMessage string)
• type Client
  • func NewProducer(destinationConfig interface{}, o Opts) (*Client, error)
• type Config
• type Credentials
• type Opts

Functions

func CloseProducer

func CloseProducer(producer interface{}) error

func Produce

func Produce(jsonData json.RawMessage, producer interface{}, destConfig interface{}) (statusCode int, respStatus string, responseMessage string)

Types

type Client

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

func NewProducer

func NewProducer(destinationConfig interface{}, o Opts) (*Client, error)

type Config

type Config struct {
	Credentials string `json:"credentials"`
	ProjectId   string `json:"projectId"`
	DatasetId   string `json:"datasetId"`
	TableId     string `json:"tableId"`
}

type Credentials

type Credentials struct {
	Email      string `json:"client_email"`
	PrivateKey string `json:"private_key"`
	TokenUrl   string `json:"token_uri"`
}

type Opts

type Opts struct {
	Timeout time.Duration
}