utils

Documentation

Index

• func GetGranularitySec(granularityStr string) int64
• func GetGranularityStr(granularitySec int64) string
• func GetJobID(unit *config.Unit, rowVals []string, columns []string, ...) (string, error)
• func GetJobMap(rowVals []string, columns []string, metricType datahub_common.MetricType, ...) map[string]string
• func GetJobStr(rowVals []string, columns []string, metricType datahub_common.MetricType, ...) (string, error)
• func GetRowValue(values, columns []string, field string) (string, error)
• func ReadData(datahubServiceClnt datahub_v1alpha1.DatahubServiceClient, ...) (*datahub_data.ReadDataResponse, error)

Functions

func GetGranularitySec

func GetGranularitySec(granularityStr string) int64

func GetGranularityStr

func GetGranularityStr(granularitySec int64) string

func GetJobID

func GetJobID(unit *config.Unit, rowVals []string, columns []string,
	metricType datahub_common.MetricType, granularity int64) (string, error)

func GetJobMap

func GetJobMap(rowVals []string, columns []string,
	metricType datahub_common.MetricType, granularity int64) map[string]string

func GetJobStr

func GetJobStr(rowVals []string, columns []string,
	metricType datahub_common.MetricType, granularity int64) (string, error)

func GetRowValue

func GetRowValue(values, columns []string, field string) (string, error)

func ReadData

func ReadData(datahubServiceClnt datahub_v1alpha1.DatahubServiceClient,
	schemaMeta *datahub_schemas.SchemaMeta, readData []*datahub_data.ReadData) (
	*datahub_data.ReadDataResponse, error)