proto

Documentation

Index

• Constants
• Variables
• type BQColumn
  • func (*BQColumn) Descriptor() ([]byte, []int)
  • func (x *BQColumn) GetColumnName() string
  • func (x *BQColumn) GetColumnType() string
  • func (x *BQColumn) GetLabel() string
  • func (*BQColumn) ProtoMessage()
  • func (x *BQColumn) ProtoReflect() protoreflect.Message
  • func (x *BQColumn) Reset()
  • func (x *BQColumn) String() string
• type SurfacerConf
  • func (*SurfacerConf) Descriptor() ([]byte, []int)
  • func (x *SurfacerConf) GetBatchTimerSec() int64
  • func (x *SurfacerConf) GetBigqueryColumns() []*BQColumn
  • func (x *SurfacerConf) GetBigqueryDataset() string
  • func (x *SurfacerConf) GetBigqueryTable() string
  • func (x *SurfacerConf) GetBigqueryTimeoutSec() int64
  • func (x *SurfacerConf) GetMetricNameColName() string
  • func (x *SurfacerConf) GetMetricTimeColName() string
  • func (x *SurfacerConf) GetMetricValueColName() string
  • func (x *SurfacerConf) GetMetricsBatchSize() int64
  • func (x *SurfacerConf) GetMetricsBufferSize() int64
  • func (x *SurfacerConf) GetProjectName() string
  • func (*SurfacerConf) ProtoMessage()
  • func (x *SurfacerConf) ProtoReflect() protoreflect.Message
  • func (x *SurfacerConf) Reset()
  • func (x *SurfacerConf) String() string

Constants

const (
	Default_SurfacerConf_BigqueryTimeoutSec = int64(30)
	Default_SurfacerConf_MetricsBufferSize  = int64(100000)
	Default_SurfacerConf_BatchTimerSec      = int64(10)
	Default_SurfacerConf_MetricsBatchSize   = int64(1000)
	Default_SurfacerConf_MetricTimeColName  = string("metric_time")
	Default_SurfacerConf_MetricNameColName  = string("metric_name")
	Default_SurfacerConf_MetricValueColName = string("metric_value")
)

Default values for SurfacerConf fields.

Variables

var File_github_com_cloudprober_cloudprober_surfacers_internal_bigquery_proto_config_proto protoreflect.FileDescriptor

Types

type BQColumn

type BQColumn struct {
	Label      *string `protobuf:"bytes,1,opt,name=label" json:"label,omitempty"`
	ColumnName *string `protobuf:"bytes,2,opt,name=column_name,json=columnName" json:"column_name,omitempty"`
	ColumnType *string `protobuf:"bytes,3,opt,name=column_type,json=columnType" json:"column_type,omitempty"`
	// contains filtered or unexported fields
}

func (*BQColumn) Descriptor

func (*BQColumn) Descriptor() ([]byte, []int)

Deprecated: Use BQColumn.ProtoReflect.Descriptor instead.

func (*BQColumn) GetColumnName

func (x *BQColumn) GetColumnName() string

func (*BQColumn) GetColumnType

func (x *BQColumn) GetColumnType() string

func (*BQColumn) GetLabel

func (x *BQColumn) GetLabel() string

func (*BQColumn) ProtoMessage

func (*BQColumn) ProtoMessage()

func (*BQColumn) ProtoReflect

func (x *BQColumn) ProtoReflect() protoreflect.Message

func (*BQColumn) Reset

func (x *BQColumn) Reset()

func (*BQColumn) String

func (x *BQColumn) String() string

type SurfacerConf

type SurfacerConf struct {
	ProjectName     *string `protobuf:"bytes,1,opt,name=project_name,json=projectName" json:"project_name,omitempty"`
	BigqueryDataset *string `protobuf:"bytes,2,opt,name=bigquery_dataset,json=bigqueryDataset" json:"bigquery_dataset,omitempty"`
	BigqueryTable   *string `protobuf:"bytes,3,opt,name=bigquery_table,json=bigqueryTable" json:"bigquery_table,omitempty"`
	// It represents the bigquery table columns.
	//
	//	bigquery_columns {
	//	  label: "id",
	//	  column_name: "id",
	//	  column_type: "string",
	//	}
	BigqueryColumns []*BQColumn `protobuf:"bytes,4,rep,name=bigquery_columns,json=bigqueryColumns" json:"bigquery_columns,omitempty"`
	// It represents bigquery client timeout in seconds. So, if bigquery insertion
	// is not completed within this time period then the request will fail and the
	// failed rows will be retried later.
	BigqueryTimeoutSec *int64 `protobuf:"varint,5,opt,name=bigquery_timeout_sec,json=bigqueryTimeoutSec,def=30" json:"bigquery_timeout_sec,omitempty"`
	MetricsBufferSize  *int64 `protobuf:"varint,6,opt,name=metrics_buffer_size,json=metricsBufferSize,def=100000" json:"metrics_buffer_size,omitempty"`
	// This denotes the time interval after which data will be inserted in
	// bigquery. Default is 10 seconds. So after every 10 seconds all the em in
	// current will be inserted in bigquery in a default batch size of 1000
	BatchTimerSec    *int64 `protobuf:"varint,7,opt,name=batch_timer_sec,json=batchTimerSec,def=10" json:"batch_timer_sec,omitempty"`
	MetricsBatchSize *int64 `protobuf:"varint,8,opt,name=metrics_batch_size,json=metricsBatchSize,def=1000" json:"metrics_batch_size,omitempty"`
	// Column name for metrics name, value and timestamp
	MetricTimeColName  *string `protobuf:"bytes,9,opt,name=metric_time_col_name,json=metricTimeColName,def=metric_time" json:"metric_time_col_name,omitempty"`
	MetricNameColName  *string `` /* 126-byte string literal not displayed */
	MetricValueColName *string `` /* 130-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*SurfacerConf) Descriptor

func (*SurfacerConf) Descriptor() ([]byte, []int)

Deprecated: Use SurfacerConf.ProtoReflect.Descriptor instead.

func (*SurfacerConf) GetBatchTimerSec

func (x *SurfacerConf) GetBatchTimerSec() int64

func (*SurfacerConf) GetBigqueryColumns

func (x *SurfacerConf) GetBigqueryColumns() []*BQColumn

func (*SurfacerConf) GetBigqueryDataset

func (x *SurfacerConf) GetBigqueryDataset() string

func (*SurfacerConf) GetBigqueryTable

func (x *SurfacerConf) GetBigqueryTable() string

func (*SurfacerConf) GetBigqueryTimeoutSec

func (x *SurfacerConf) GetBigqueryTimeoutSec() int64

func (*SurfacerConf) GetMetricNameColName

func (x *SurfacerConf) GetMetricNameColName() string

func (*SurfacerConf) GetMetricTimeColName

func (x *SurfacerConf) GetMetricTimeColName() string

func (*SurfacerConf) GetMetricValueColName

func (x *SurfacerConf) GetMetricValueColName() string

func (*SurfacerConf) GetMetricsBatchSize

func (x *SurfacerConf) GetMetricsBatchSize() int64

func (*SurfacerConf) GetMetricsBufferSize

func (x *SurfacerConf) GetMetricsBufferSize() int64

func (*SurfacerConf) GetProjectName

func (x *SurfacerConf) GetProjectName() string

func (*SurfacerConf) ProtoMessage

func (*SurfacerConf) ProtoMessage()

func (*SurfacerConf) ProtoReflect

func (x *SurfacerConf) ProtoReflect() protoreflect.Message

func (*SurfacerConf) Reset

func (x *SurfacerConf) Reset()

func (*SurfacerConf) String

func (x *SurfacerConf) String() string