cidataloader

type BigQueryDataItem struct {
	Instance *DataInstance
	Row      map[string]string
	InsertID string
}

type BigQueryLoader struct {
	ProjectID string
	DataSetID string
	Client    *bigquery.Client
	DryRun    bool
	// contains filtered or unexported fields
}

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

type ClientError struct {
	Err  error
	Call string
}

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

type ComplexInterval struct {
	Locator        Locator   `json:"locator" bigquery:"locator"`
	Message        Message   `json:"message" bigquery:"message"`
	From           time.Time `json:"from_time" bigquery:"from_time"`
	To             time.Time `json:"to_time" bigquery:"to_time"`
	IntervalSource string    `json:"interval_source" bigquery:"interval_source"`
	JobRunName     string    `json:"JobRunName" bigquery:"JobRunName"`
	Source         string    `json:"source" bigquery:"source"`
}

type DataFile struct {
	TableName       string              `json:"table_name"`
	Schema          map[string]DataType `json:"schema"`
	SchemaMapping   map[string]string   `json:"schema_mapping"`
	Rows            []map[string]string `json:"rows"`
	ComplexRows     []interface{}       `json:"complex_rows"`
	ExpirationDays  int                 `json:"expiration_days"`
	PartitionColumn string              `json:"partition_column"`
	PartitionType   string              `json:"partition_type"`
	ChunkSize       int                 `json:"chunk_size"`
}

type DataInstance struct {
	Source                 string
	CreationTime           time.Time
	JobRunName             string
	DataFile               *DataFile
	SkipMetaDataValidation bool
}

type DataLoader interface {
	ValidateTable(ctx context.Context, dataInstance DataInstance) error
	FindExistingData(ctx context.Context, partitionTime time.Time, partitionColumn, tableName, jobRunName, source string) (bool, error)
	LoadDataItems(ctx context.Context, dataInstance DataInstance) ([]interface{}, error)
}

type DataType = string

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

type JobRunDataEvent struct {
	Job         string
	BuildID     string
	Filename    string
	Event       *event.Event
	Name        string
	Bucket      string
	TimeCreated time.Time
}

type KeyValue struct {
	Key string `json:"key" bigquery:"key"`
	Val string `json:"value" bigquery:"value"`
}

type Locator struct {
	Type                  string     `json:"type" bigquery:"type"`
	Hmsg                  string     `json:"hmsg" bigquery:"hmsg"`
	Namespace             string     `json:"namespace" bigquery:"namespace"`
	Node                  string     `json:"node" bigquery:"node"`
	Pod                   string     `json:"pod" bigquery:"pod"`
	Uid                   string     `json:"uid" bigquery:"uid"`
	Container             string     `json:"container" bigquery:"container"`
	E2eTest               string     `json:"e2eTest" bigquery:"e2eTest"`
	BackendDisruptionName string     `json:"backend_disruption_name" bigquery:"backend_disruption_name"`
	Keys                  []KeyValue `json:"keys" bigquery:"keys"`
}

type Message struct {
	Reason         string     `json:"reason" bigquery:"reason"`
	Cause          string     `json:"cause" bigquery:"cause"`
	HumanMessage   string     `json:"human_message" bigquery:"human_message"`
	Container      string     `json:"container" bigquery:"container"`
	FirstTimestamp time.Time  `json:"firstimestamp" bigquery:"firstTimestamp"`
	LastTimestamp  time.Time  `json:"lastimestamp" bigquery:"lastTimestamp"`
	Image          string     `json:"image" bigquery:"image"`
	Constructed    string     `json:"constructed" bigquery:"constructed"`
	Status         string     `json:"status" bigquery:"status"`
	Node           string     `json:"node" bigquery:"node"`
	Annotations    []KeyValue `json:"annotations" bigquery:"annotations"`
}

type OutputMetric struct {
	Timestamp int64  `json:"timestamp"`
	Value     string `json:"value"`
}

type PrometheusData struct {
	ResultType string             `json:"resultType"`
	Result     []PrometheusMetric `json:"result"`
}

type PrometheusLabels map[string]string

type PrometheusMetric struct {
	Metric PrometheusLabels `json:"metric"`
	Value  PrometheusValue  `json:"value"`
}

type PrometheusResult struct {
	Status string         `json:"status"`
	Data   PrometheusData `json:"data"`
}

type PrometheusValue struct {
	Timestamp int64
	Value     string
}

type SimpleUploader interface {
	// contains filtered or unexported methods
}

type StorageObjectData struct {
	Bucket      string            `json:"bucket"`
	Name        string            `json:"name"`
	Size        int64             `json:"size,string"`
	ContentType string            `json:"contentType"`
	TimeCreated time.Time         `json:"timeCreated"`
	Updated     time.Time         `json:"updated"`
	MD5Hash     string            `json:"md5Hash"`
	Metadata    map[string]string `json:"metadata"`
}