Versions in this module Expand all Collapse all v0 v0.1.3 Dec 2, 2024 Changes in this version + type AuthPolicyInput struct + Body string + Header map[string][]string + Method string + Path string + Query map[string][]string + Remote string + type AuthPolicyOutput struct + Deny bool + type BigQueryDest struct + Dataset types.BQDatasetID + Partition types.BQPartition + Table types.BQTableID + type CloudStorageEvent struct + Bucket types.CSBucket + ContentType string + Crc32c string + Etag string + Generation string + ID string + Kind string + Md5Hash string + MediaLink string + Metageneration string + Name types.CSObjectID + SelfLink string + Size string + StorageClass string + TimeCreated string + TimeStorageClassUpdated string + Updated string + func (x CloudStorageEvent) ToObject() Object + type CloudStorageObject struct + Bucket types.CSBucket + Name types.CSObjectID + type Digest struct + Alg string + Value string + type EnqueueRequest struct + URLs []types.ObjectURL + type EnqueueResponse struct + Count int64 + Elapsed time.Duration + Size int64 + type EventPolicyOutput struct + Sources []*Source + type EventarcDirectEvent struct + Bucket types.CSBucket + ContentType string + Crc32c string + Etag string + Generation string + ID string + Kind string + Md5Hash string + MediaLink string + Metageneration string + Name types.CSObjectID + SelfLink string + Size string + StorageClass string + TimeCreated string + TimeStorageClassUpdated string + Updated string + type IngestLog struct + DatasetID types.BQDatasetID + Error string + FinishedAt time.Time + ID types.IngestID + LogCount int + ObjectSchema types.ObjectSchema + StartedAt time.Time + Success bool + TableID types.BQTableID + TableSchema string + func (x *IngestLog) Raw() *IngestLogRaw + type IngestLogRaw struct + FinishedAt int64 + StartedAt int64 + type LoadDataRequest struct + CSEvent *CloudStorageEvent + type LoadLog struct + Error string + FinishedAt time.Time + ID types.RequestID + Ingests []*IngestLog + Sources []*SourceLog + StartedAt time.Time + Success bool + func (x *LoadLog) Raw() *LoadLogRaw + type LoadLogRaw struct + FinishedAt int64 + Ingests []*IngestLogRaw + Sources []*SourceLogRaw + StartedAt int64 + type LoadRequest struct + Object Object + Source Source + type Log struct + Data map[string]any + ID types.LogID + Timestamp float64 + func (x *Log) Validate() error + type LogRecord struct + Data any + ID types.LogID + IngestID types.IngestID + IngestedAt time.Time + Timestamp time.Time + func (x LogRecord) Raw() *LogRecordRaw + type LogRecordRaw struct + IngestedAt int64 + Timestamp int64 + type LogRecordSet map[BigQueryDest][]*LogRecord + func (x LogRecordSet) Merge(src LogRecordSet) + type MetadataConfig struct + func NewMetadataConfig(dataset types.BQDatasetID, table types.BQTableID) *MetadataConfig + func (x *MetadataConfig) Dataset() types.BQDatasetID + func (x *MetadataConfig) Table() types.BQTableID + type Object struct + CS *CloudStorageObject + CreatedAt *int64 + Data any + Digests []Digest + Size *int64 + func NewObjectFromCloudStorageAttrs(attrs *storage.ObjectAttrs) Object + type PubSubBody struct + Message PubSubMessage + Subscription string + type PubSubMessage struct + Attributes map[string]string + Data string + MessageID string + PublishTime string + type SchemaPolicyOutput struct + Logs []*Log + type Source struct + Compress types.ObjectCompress + Parser types.ObjectParser + Schema types.ObjectSchema + func (x Source) Validate() error + type SourceLog struct + CS *CloudStorageObject + FinishedAt time.Time + RowCount int + Source Source + StartedAt time.Time + Success bool + func (x *SourceLog) Raw() *SourceLogRaw + type SourceLogRaw struct + FinishedAt int64 + StartedAt int64 + type State struct + CreatedAt time.Time + ExpiresAt time.Time + ID string + RequestID types.RequestID + State types.MsgState + TTL time.Time + UpdatedAt time.Time + func (x *State) Acquired(now time.Time) bool + type SwarmMessage struct + Objects []*Object
Go to main page