bigquerysink

Feb 15, 2022

Changes in this version

+ var ErrEmptyData = errors.New("data is missing from the message")

+ var ErrEmptyDatasetID = errors.New("dataset id is missing from the message")

+ var ErrEmptyProjectID = errors.New("project id is missing from the message")

+ var ErrEmptyTableID = errors.New("table id is missing from the message")

+ var ErrUnkownMessageType = errors.New("unkown message type")

+ func MustNew(client *bigquery.Client, options ...Option) pipeline.Sink

+ type Message struct

+ Data interface{}

+ DatasetID string

+ ProjectID string

+ TableID string

+ type Option func(*bigquerySink)

+ func WithIgnoreUnkownMessageTypes() Option

+ func WithIgnoreValidationErrors() Option

+ func WithLogLevel(l zerolog.Level) Option