pkg

type BigQueryField struct {
	Name string `json:"name"`
	Type string `json:"type"`
	Mode string `json:"mode"`
}

type BigqueryConfig struct {
	ProjectId string `json:"projectId"`
	Dataset   string `json:"dataset"`
}

type Config struct {
	Jobs []Job `json:"jobs"`
}

type Destination struct {
	Type                 string              `json:"type"`
	BatchSize            int                 `json:"batchSize"`
	TimestampColumnName  string              `json:"timestampColumnName"`
	TimestampFormat      string              `json:"timestampFormat"`
	TimePartitioningType string              `json:"timePartitioningType"`
	Expiration           string              `json:"expiration"`
	ClusterBy            []string            `json:"clusterBy"`
	BigqueryConfig       BigqueryConfig      `json:"bigqueryConfig"`
	GoogleStorageConfig  GoogleStorageConfig `json:"googleStorageConfig"`
}

type Event map[string]interface{}

type Filter struct {
	Type   string          `json:"type"`
	Name   string          `json:"name"`
	Action string          `json:"action"`
	Target Target          `json:"target,omitempty"`
	Schema []BigQueryField `json:"schema,omitempty"`
}

type GoogleStorageConfig struct {
	ProjectId  string `json:"projectId"`
	Bucket     string `json:"bucket"`
	BlobPrefix string `json:"blobPrefix"`
}

type Job struct {
	Name        string      `json:"name"`
	Suspend     bool        `json:"suspend"`
	Source      Source      `json:"source"`
	Filters     []Filter    `json:"filters"`
	Destination Destination `json:"destination,omitempty"`
}

type PubsubConfig struct {
	ProjectId              string `json:"projectId"`
	SubscriptionId         string `json:"subscriptionId"`
	MaxOutstandingMessages int    `json:"maxOutstandingMessages"`
	AttributeKeyName       string `json:"attributeKeyName"`
}

type Source struct {
	Type         string       `json:"type"`
	PubsubConfig PubsubConfig `json:"pubsubConfig"`
}

type Target struct {
	Table string `json:"table"`
}