bqstream

Documentation

Index

• type BQStreamProducer
  • func NewProducer(destination *backendconfig.DestinationT, o common.Opts) (*BQStreamProducer, error)
  • func (producer *BQStreamProducer) Close() error
  • func (producer *BQStreamProducer) Produce(jsonData json.RawMessage, _ interface{}) (statusCode int, respStatus, responseMessage string)
• type Client
• type Config

Types

type BQStreamProducer

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

func NewProducer

func NewProducer(destination *backendconfig.DestinationT, o common.Opts) (*BQStreamProducer, error)

func (*BQStreamProducer) Close

func (producer *BQStreamProducer) Close() error

func (*BQStreamProducer) Produce

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

type Client

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

type Config

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