Versions in this module Expand all Collapse all v0 v0.0.1 Nov 17, 2023 Changes in this version + type ARROWSchema struct + ReadSessionSchema *storagepb.ReadSession_ArrowSchema + Schema *arrow.Schema + Text string + type AVROSchema struct + ReadSessionSchema *storagepb.ReadSession_AvroSchema + Schema *types.AVROSchema + Text string + type ErrorFormat struct + Code int + Errors []*ServerError + Message string + type ErrorReason string + const AccessDenied + const BackendError + const BillingNotEnabled + const BillingTierLimitExceeded + const Blocked + const Duplicate + const InternalError + const Invalid + const InvalidQuery + const InvalidUser + const JobBackendError + const JobInternalError + const NotFound + const NotImplemented + const QuotaExceeded + const RateLimitExceeded + const ResourceInUse + const ResourcesExceeded + const ResponseTooLarge + const Stopped + const TableUnavailable + const Timeout + type Handler struct + HTTPMethod string + Handler http.Handler + Path string + type LogFormat string + const LogFormatConsole + const LogFormatJSON + type LogLevel string + const LogLevelDebug + const LogLevelError + const LogLevelFatal + const LogLevelInfo + const LogLevelUnknown + const LogLevelWarn + type ResponseError struct + Error *ErrorFormat + type Server struct + Handler http.Handler + func New(storage Storage) (*Server, error) + func (s *Server) Close() error + func (s *Server) Load(sources ...Source) error + func (s *Server) Serve(ctx context.Context, httpAddr, grpcAddr string) error + func (s *Server) SetLogFormat(format LogFormat) error + func (s *Server) SetLogLevel(level LogLevel) error + func (s *Server) SetProject(id string) error + func (s *Server) Stop(ctx context.Context) error + func (s *Server) TestServer() *TestServer + type ServerError struct + DebugInfo string + Location string + Message string + Reason ErrorReason + Status int + func (e *ServerError) Error() string + func (e *ServerError) ErrorProto() *bigqueryv2.ErrorProto + func (e *ServerError) Response() []byte + type Source func(*Server) error + func StructSource(projects ...*types.Project) Source + func YAMLSource(path string) Source + type Storage string + const MemoryStorage + const TempStorage + type TableType string + const DefaultTableType + const ExternalTableType + const MaterializedViewTableType + const SnapshotTableType + const ViewTableType + type TestServer struct + DialerOption grpc.DialOption + func (s *TestServer) GRPCClientOptions(ctx context.Context) ([]option.ClientOption, error) + func (s *TestServer) GRPCDial(ctx context.Context) (*grpc.ClientConn, error) + type UploadJob struct + Configuration *UploadJobConfiguration + JobReference *bigqueryv2.JobReference + func (j *UploadJob) ToJob() *bigqueryv2.Job + type UploadJobConfiguration struct + Load *UploadJobConfigurationLoad + type UploadJobConfigurationLoad struct + AllowJaggedRows bool + AllowQuotedNewlines bool + Autodetect bool + Clustering *bigqueryv2.Clustering + CreateDisposition string + DecimalTargetTypes []string + DestinationEncryptionConfiguration *bigqueryv2.EncryptionConfiguration + DestinationTable *bigqueryv2.TableReference + DestinationTableProperties *bigqueryv2.DestinationTableProperties + Encoding string + FieldDelimiter string + HivePartitioningOptions *bigqueryv2.HivePartitioningOptions + IgnoreUnknownValues bool + JsonExtension string + MaxBadRecords int64 + NullMarker string + ParquetOptions *bigqueryv2.ParquetOptions + PreserveAsciiControlCharacters bool + ProjectionFields []string + Quote *string + RangePartitioning *bigqueryv2.RangePartitioning + Schema *bigqueryv2.TableSchema + SchemaInline string + SchemaInlineFormat string + SchemaUpdateOptions []string + SkipLeadingRows json.Number + SourceFormat string + SourceUris []string + TimePartitioning *bigqueryv2.TimePartitioning + UseAvroLogicalTypes bool + WriteDisposition string
Go to main page