proto_rpc

package
v1.1.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 25, 2024 License: AGPL-3.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	Vector_PushEvents_FullMethodName  = "/vector.Vector/PushEvents"
	Vector_HealthCheck_FullMethodName = "/vector.Vector/HealthCheck"
)

Variables

View Source 
var (
	ValueNull_name = map[int32]string{
		0: "NULL_VALUE",
	}
	ValueNull_value = map[string]int32{
		"NULL_VALUE": 0,
	}
)

Enum value maps for ValueNull.

View Source 
var (
	StatisticKind_name = map[int32]string{
		0: "Histogram",
		1: "Summary",
	}
	StatisticKind_value = map[string]int32{
		"Histogram": 0,
		"Summary":   1,
	}
)

Enum value maps for StatisticKind.

View Source 
var (
	Metric_Kind_name = map[int32]string{
		0: "Incremental",
		1: "Absolute",
	}
	Metric_Kind_value = map[string]int32{
		"Incremental": 0,
		"Absolute":    1,
	}
)

Enum value maps for Metric_Kind.

View Source 
var (
	ServingStatus_name = map[int32]string{
		0: "SERVING",
		1: "NOT_SERVING",
	}
	ServingStatus_value = map[string]int32{
		"SERVING":     0,
		"NOT_SERVING": 1,
	}
)

Enum value maps for ServingStatus.

View Source 
var File_internal_app_proto_event_proto protoreflect.FileDescriptor
View Source 
var File_internal_app_proto_vector_proto protoreflect.FileDescriptor
View Source 
var Vector_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "vector.Vector",
	HandlerType: (*VectorServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "PushEvents",
			Handler:    _Vector_PushEvents_Handler,
		},
		{
			MethodName: "HealthCheck",
			Handler:    _Vector_HealthCheck_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "internal/app/proto/vector.proto",
}

Vector_ServiceDesc is the grpc.ServiceDesc for Vector service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterVectorServer 

func RegisterVectorServer(s grpc.ServiceRegistrar, srv VectorServer)

Types

type AggregatedHistogram1 

type AggregatedHistogram1 struct {
	Buckets []float64 `protobuf:"fixed64,1,rep,packed,name=buckets,proto3" json:"buckets,omitempty"`
	Counts  []uint32  `protobuf:"varint,2,rep,packed,name=counts,proto3" json:"counts,omitempty"`
	Count   uint32    `protobuf:"varint,3,opt,name=count,proto3" json:"count,omitempty"`
	Sum     float64   `protobuf:"fixed64,4,opt,name=sum,proto3" json:"sum,omitempty"`
	// contains filtered or unexported fields
}

func (*AggregatedHistogram1) Descriptor deprecated 

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

Deprecated: Use AggregatedHistogram1.ProtoReflect.Descriptor instead.

func (*AggregatedHistogram1) GetBuckets 

func (x *AggregatedHistogram1) GetBuckets() []float64

func (*AggregatedHistogram1) GetCount 

func (x *AggregatedHistogram1) GetCount() uint32

func (*AggregatedHistogram1) GetCounts 

func (x *AggregatedHistogram1) GetCounts() []uint32

func (*AggregatedHistogram1) GetSum 

func (x *AggregatedHistogram1) GetSum() float64

func (*AggregatedHistogram1) ProtoMessage 

func (*AggregatedHistogram1) ProtoMessage()

func (*AggregatedHistogram1) ProtoReflect 

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

func (*AggregatedHistogram1) Reset 

func (x *AggregatedHistogram1) Reset()

func (*AggregatedHistogram1) String 

func (x *AggregatedHistogram1) String() string

type AggregatedHistogram2 

type AggregatedHistogram2 struct {
	Buckets []*HistogramBucket `protobuf:"bytes,1,rep,name=buckets,proto3" json:"buckets,omitempty"`
	Count   uint32             `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
	Sum     float64            `protobuf:"fixed64,3,opt,name=sum,proto3" json:"sum,omitempty"`
	// contains filtered or unexported fields
}

func (*AggregatedHistogram2) Descriptor deprecated 

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

Deprecated: Use AggregatedHistogram2.ProtoReflect.Descriptor instead.

func (*AggregatedHistogram2) GetBuckets 

func (x *AggregatedHistogram2) GetBuckets() []*HistogramBucket

func (*AggregatedHistogram2) GetCount 

func (x *AggregatedHistogram2) GetCount() uint32

func (*AggregatedHistogram2) GetSum 

func (x *AggregatedHistogram2) GetSum() float64

func (*AggregatedHistogram2) ProtoMessage 

func (*AggregatedHistogram2) ProtoMessage()

func (*AggregatedHistogram2) ProtoReflect 

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

func (*AggregatedHistogram2) Reset 

func (x *AggregatedHistogram2) Reset()

func (*AggregatedHistogram2) String 

func (x *AggregatedHistogram2) String() string

type AggregatedHistogram3 

type AggregatedHistogram3 struct {
	Buckets []*HistogramBucket3 `protobuf:"bytes,1,rep,name=buckets,proto3" json:"buckets,omitempty"`
	Count   uint64              `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
	Sum     float64             `protobuf:"fixed64,3,opt,name=sum,proto3" json:"sum,omitempty"`
	// contains filtered or unexported fields
}

func (*AggregatedHistogram3) Descriptor deprecated 

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

Deprecated: Use AggregatedHistogram3.ProtoReflect.Descriptor instead.

func (*AggregatedHistogram3) GetBuckets 

func (x *AggregatedHistogram3) GetBuckets() []*HistogramBucket3

func (*AggregatedHistogram3) GetCount 

func (x *AggregatedHistogram3) GetCount() uint64

func (*AggregatedHistogram3) GetSum 

func (x *AggregatedHistogram3) GetSum() float64

func (*AggregatedHistogram3) ProtoMessage 

func (*AggregatedHistogram3) ProtoMessage()

func (*AggregatedHistogram3) ProtoReflect 

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

func (*AggregatedHistogram3) Reset 

func (x *AggregatedHistogram3) Reset()

func (*AggregatedHistogram3) String 

func (x *AggregatedHistogram3) String() string

type AggregatedSummary1 

type AggregatedSummary1 struct {
	Quantiles []float64 `protobuf:"fixed64,1,rep,packed,name=quantiles,proto3" json:"quantiles,omitempty"`
	Values    []float64 `protobuf:"fixed64,2,rep,packed,name=values,proto3" json:"values,omitempty"`
	Count     uint32    `protobuf:"varint,3,opt,name=count,proto3" json:"count,omitempty"`
	Sum       float64   `protobuf:"fixed64,4,opt,name=sum,proto3" json:"sum,omitempty"`
	// contains filtered or unexported fields
}

func (*AggregatedSummary1) Descriptor deprecated 

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

Deprecated: Use AggregatedSummary1.ProtoReflect.Descriptor instead.

func (*AggregatedSummary1) GetCount 

func (x *AggregatedSummary1) GetCount() uint32

func (*AggregatedSummary1) GetQuantiles 

func (x *AggregatedSummary1) GetQuantiles() []float64

func (*AggregatedSummary1) GetSum 

func (x *AggregatedSummary1) GetSum() float64

func (*AggregatedSummary1) GetValues 

func (x *AggregatedSummary1) GetValues() []float64

func (*AggregatedSummary1) ProtoMessage 

func (*AggregatedSummary1) ProtoMessage()

func (*AggregatedSummary1) ProtoReflect 

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

func (*AggregatedSummary1) Reset 

func (x *AggregatedSummary1) Reset()

func (*AggregatedSummary1) String 

func (x *AggregatedSummary1) String() string

type AggregatedSummary2 

type AggregatedSummary2 struct {
	Quantiles []*SummaryQuantile `protobuf:"bytes,1,rep,name=quantiles,proto3" json:"quantiles,omitempty"`
	Count     uint32             `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
	Sum       float64            `protobuf:"fixed64,3,opt,name=sum,proto3" json:"sum,omitempty"`
	// contains filtered or unexported fields
}

func (*AggregatedSummary2) Descriptor deprecated 

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

Deprecated: Use AggregatedSummary2.ProtoReflect.Descriptor instead.

func (*AggregatedSummary2) GetCount 

func (x *AggregatedSummary2) GetCount() uint32

func (*AggregatedSummary2) GetQuantiles 

func (x *AggregatedSummary2) GetQuantiles() []*SummaryQuantile

func (*AggregatedSummary2) GetSum 

func (x *AggregatedSummary2) GetSum() float64

func (*AggregatedSummary2) ProtoMessage 

func (*AggregatedSummary2) ProtoMessage()

func (*AggregatedSummary2) ProtoReflect 

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

func (*AggregatedSummary2) Reset 

func (x *AggregatedSummary2) Reset()

func (*AggregatedSummary2) String 

func (x *AggregatedSummary2) String() string

type AggregatedSummary3 

type AggregatedSummary3 struct {
	Quantiles []*SummaryQuantile `protobuf:"bytes,1,rep,name=quantiles,proto3" json:"quantiles,omitempty"`
	Count     uint64             `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
	Sum       float64            `protobuf:"fixed64,3,opt,name=sum,proto3" json:"sum,omitempty"`
	// contains filtered or unexported fields
}

func (*AggregatedSummary3) Descriptor deprecated 

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

Deprecated: Use AggregatedSummary3.ProtoReflect.Descriptor instead.

func (*AggregatedSummary3) GetCount 

func (x *AggregatedSummary3) GetCount() uint64

func (*AggregatedSummary3) GetQuantiles 

func (x *AggregatedSummary3) GetQuantiles() []*SummaryQuantile

func (*AggregatedSummary3) GetSum 

func (x *AggregatedSummary3) GetSum() float64

func (*AggregatedSummary3) ProtoMessage 

func (*AggregatedSummary3) ProtoMessage()

func (*AggregatedSummary3) ProtoReflect 

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

func (*AggregatedSummary3) Reset 

func (x *AggregatedSummary3) Reset()

func (*AggregatedSummary3) String 

func (x *AggregatedSummary3) String() string

type Counter 

type Counter struct {
	Value float64 `protobuf:"fixed64,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*Counter) Descriptor deprecated 

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

Deprecated: Use Counter.ProtoReflect.Descriptor instead.

func (*Counter) GetValue 

func (x *Counter) GetValue() float64

func (*Counter) ProtoMessage 

func (*Counter) ProtoMessage()

func (*Counter) ProtoReflect 

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

func (*Counter) Reset 

func (x *Counter) Reset()

func (*Counter) String 

func (x *Counter) String() string

type Distribution1 

type Distribution1 struct {
	Values      []float64     `protobuf:"fixed64,1,rep,packed,name=values,proto3" json:"values,omitempty"`
	SampleRates []uint32      `protobuf:"varint,2,rep,packed,name=sample_rates,json=sampleRates,proto3" json:"sample_rates,omitempty"`
	Statistic   StatisticKind `protobuf:"varint,3,opt,name=statistic,proto3,enum=vector.StatisticKind" json:"statistic,omitempty"`
	// contains filtered or unexported fields
}

func (*Distribution1) Descriptor deprecated 

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

Deprecated: Use Distribution1.ProtoReflect.Descriptor instead.

func (*Distribution1) GetSampleRates 

func (x *Distribution1) GetSampleRates() []uint32

func (*Distribution1) GetStatistic 

func (x *Distribution1) GetStatistic() StatisticKind

func (*Distribution1) GetValues 

func (x *Distribution1) GetValues() []float64

func (*Distribution1) ProtoMessage 

func (*Distribution1) ProtoMessage()

func (*Distribution1) ProtoReflect 

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

func (*Distribution1) Reset 

func (x *Distribution1) Reset()

func (*Distribution1) String 

func (x *Distribution1) String() string

type Distribution2 

type Distribution2 struct {
	Samples   []*DistributionSample `protobuf:"bytes,1,rep,name=samples,proto3" json:"samples,omitempty"`
	Statistic StatisticKind         `protobuf:"varint,2,opt,name=statistic,proto3,enum=vector.StatisticKind" json:"statistic,omitempty"`
	// contains filtered or unexported fields
}

func (*Distribution2) Descriptor deprecated 

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

Deprecated: Use Distribution2.ProtoReflect.Descriptor instead.

func (*Distribution2) GetSamples 

func (x *Distribution2) GetSamples() []*DistributionSample

func (*Distribution2) GetStatistic 

func (x *Distribution2) GetStatistic() StatisticKind

func (*Distribution2) ProtoMessage 

func (*Distribution2) ProtoMessage()

func (*Distribution2) ProtoReflect 

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

func (*Distribution2) Reset 

func (x *Distribution2) Reset()

func (*Distribution2) String 

func (x *Distribution2) String() string

type DistributionSample 

type DistributionSample struct {
	Value float64 `protobuf:"fixed64,1,opt,name=value,proto3" json:"value,omitempty"`
	Rate  uint32  `protobuf:"varint,2,opt,name=rate,proto3" json:"rate,omitempty"`
	// contains filtered or unexported fields
}

func (*DistributionSample) Descriptor deprecated 

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

Deprecated: Use DistributionSample.ProtoReflect.Descriptor instead.

func (*DistributionSample) GetRate 

func (x *DistributionSample) GetRate() uint32

func (*DistributionSample) GetValue 

func (x *DistributionSample) GetValue() float64

func (*DistributionSample) ProtoMessage 

func (*DistributionSample) ProtoMessage()

func (*DistributionSample) ProtoReflect 

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

func (*DistributionSample) Reset 

func (x *DistributionSample) Reset()

func (*DistributionSample) String 

func (x *DistributionSample) String() string

type EventArray 

type EventArray struct {

	// Types that are assignable to Events:
	//
	//	*EventArray_Logs
	//	*EventArray_Metrics
	//	*EventArray_Traces
	Events isEventArray_Events `protobuf_oneof:"events"`
	// contains filtered or unexported fields
}

func (*EventArray) Descriptor deprecated 

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

Deprecated: Use EventArray.ProtoReflect.Descriptor instead.

func (*EventArray) GetEvents 

func (m *EventArray) GetEvents() isEventArray_Events

func (*EventArray) GetLogs 

func (x *EventArray) GetLogs() *LogArray

func (*EventArray) GetMetrics 

func (x *EventArray) GetMetrics() *MetricArray

func (*EventArray) GetTraces 

func (x *EventArray) GetTraces() *TraceArray

func (*EventArray) ProtoMessage 

func (*EventArray) ProtoMessage()

func (*EventArray) ProtoReflect 

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

func (*EventArray) Reset 

func (x *EventArray) Reset()

func (*EventArray) String 

func (x *EventArray) String() string

type EventArray_Logs 

type EventArray_Logs struct {
	Logs *LogArray `protobuf:"bytes,1,opt,name=logs,proto3,oneof"`
}

type EventArray_Metrics 

type EventArray_Metrics struct {
	Metrics *MetricArray `protobuf:"bytes,2,opt,name=metrics,proto3,oneof"`
}

type EventArray_Traces 

type EventArray_Traces struct {
	Traces *TraceArray `protobuf:"bytes,3,opt,name=traces,proto3,oneof"`
}

type EventWrapper 

type EventWrapper struct {

	// Types that are assignable to Event:
	//
	//	*EventWrapper_Log
	//	*EventWrapper_Metric
	//	*EventWrapper_Trace
	Event isEventWrapper_Event `protobuf_oneof:"event"`
	// contains filtered or unexported fields
}

func (*EventWrapper) Descriptor deprecated 

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

Deprecated: Use EventWrapper.ProtoReflect.Descriptor instead.

func (*EventWrapper) GetEvent 

func (m *EventWrapper) GetEvent() isEventWrapper_Event

func (*EventWrapper) GetLog 

func (x *EventWrapper) GetLog() *Log

func (*EventWrapper) GetMetric 

func (x *EventWrapper) GetMetric() *Metric

func (*EventWrapper) GetTrace 

func (x *EventWrapper) GetTrace() *Trace

func (*EventWrapper) ProtoMessage 

func (*EventWrapper) ProtoMessage()

func (*EventWrapper) ProtoReflect 

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

func (*EventWrapper) Reset 

func (x *EventWrapper) Reset()

func (*EventWrapper) String 

func (x *EventWrapper) String() string

type EventWrapper_Log 

type EventWrapper_Log struct {
	Log *Log `protobuf:"bytes,1,opt,name=log,proto3,oneof"`
}

type EventWrapper_Metric 

type EventWrapper_Metric struct {
	Metric *Metric `protobuf:"bytes,2,opt,name=metric,proto3,oneof"`
}

type EventWrapper_Trace 

type EventWrapper_Trace struct {
	Trace *Trace `protobuf:"bytes,3,opt,name=trace,proto3,oneof"`
}

type Gauge 

type Gauge struct {
	Value float64 `protobuf:"fixed64,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*Gauge) Descriptor deprecated 

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

Deprecated: Use Gauge.ProtoReflect.Descriptor instead.

func (*Gauge) GetValue 

func (x *Gauge) GetValue() float64

func (*Gauge) ProtoMessage 

func (*Gauge) ProtoMessage()

func (*Gauge) ProtoReflect 

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

func (*Gauge) Reset 

func (x *Gauge) Reset()

func (*Gauge) String 

func (x *Gauge) String() string

type HealthCheckRequest 

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

func (*HealthCheckRequest) Descriptor deprecated 

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

Deprecated: Use HealthCheckRequest.ProtoReflect.Descriptor instead.

func (*HealthCheckRequest) ProtoMessage 

func (*HealthCheckRequest) ProtoMessage()

func (*HealthCheckRequest) ProtoReflect 

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

func (*HealthCheckRequest) Reset 

func (x *HealthCheckRequest) Reset()

func (*HealthCheckRequest) String 

func (x *HealthCheckRequest) String() string

type HealthCheckResponse 

type HealthCheckResponse struct {
	Status ServingStatus `protobuf:"varint,1,opt,name=status,proto3,enum=vector.ServingStatus" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*HealthCheckResponse) Descriptor deprecated 

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

Deprecated: Use HealthCheckResponse.ProtoReflect.Descriptor instead.

func (*HealthCheckResponse) GetStatus 

func (x *HealthCheckResponse) GetStatus() ServingStatus

func (*HealthCheckResponse) ProtoMessage 

func (*HealthCheckResponse) ProtoMessage()

func (*HealthCheckResponse) ProtoReflect 

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

func (*HealthCheckResponse) Reset 

func (x *HealthCheckResponse) Reset()

func (*HealthCheckResponse) String 

func (x *HealthCheckResponse) String() string

type HistogramBucket 

type HistogramBucket struct {
	UpperLimit float64 `protobuf:"fixed64,1,opt,name=upper_limit,json=upperLimit,proto3" json:"upper_limit,omitempty"`
	Count      uint32  `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

func (*HistogramBucket) Descriptor deprecated 

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

Deprecated: Use HistogramBucket.ProtoReflect.Descriptor instead.

func (*HistogramBucket) GetCount 

func (x *HistogramBucket) GetCount() uint32

func (*HistogramBucket) GetUpperLimit 

func (x *HistogramBucket) GetUpperLimit() float64

func (*HistogramBucket) ProtoMessage 

func (*HistogramBucket) ProtoMessage()

func (*HistogramBucket) ProtoReflect 

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

func (*HistogramBucket) Reset 

func (x *HistogramBucket) Reset()

func (*HistogramBucket) String 

func (x *HistogramBucket) String() string

type HistogramBucket3 

type HistogramBucket3 struct {
	UpperLimit float64 `protobuf:"fixed64,1,opt,name=upper_limit,json=upperLimit,proto3" json:"upper_limit,omitempty"`
	Count      uint64  `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

func (*HistogramBucket3) Descriptor deprecated 

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

Deprecated: Use HistogramBucket3.ProtoReflect.Descriptor instead.

func (*HistogramBucket3) GetCount 

func (x *HistogramBucket3) GetCount() uint64

func (*HistogramBucket3) GetUpperLimit 

func (x *HistogramBucket3) GetUpperLimit() float64

func (*HistogramBucket3) ProtoMessage 

func (*HistogramBucket3) ProtoMessage()

func (*HistogramBucket3) ProtoReflect 

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

func (*HistogramBucket3) Reset 

func (x *HistogramBucket3) Reset()

func (*HistogramBucket3) String 

func (x *HistogramBucket3) String() string

type Log 

type Log struct {

	// Deprecated, use value instead
	Fields   map[string]*Value `` /* 153-byte string literal not displayed */
	Value    *Value            `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	Metadata *Value            `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

func (*Log) Descriptor deprecated 

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

Deprecated: Use Log.ProtoReflect.Descriptor instead.

func (*Log) GetFields 

func (x *Log) GetFields() map[string]*Value

func (*Log) GetMetadata 

func (x *Log) GetMetadata() *Value

func (*Log) GetValue 

func (x *Log) GetValue() *Value

func (*Log) ProtoMessage 

func (*Log) ProtoMessage()

func (*Log) ProtoReflect 

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

func (*Log) Reset 

func (x *Log) Reset()

func (*Log) String 

func (x *Log) String() string

type LogArray 

type LogArray struct {
	Logs []*Log `protobuf:"bytes,1,rep,name=logs,proto3" json:"logs,omitempty"`
	// contains filtered or unexported fields
}

func (*LogArray) Descriptor deprecated 

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

Deprecated: Use LogArray.ProtoReflect.Descriptor instead.

func (*LogArray) GetLogs 

func (x *LogArray) GetLogs() []*Log

func (*LogArray) ProtoMessage 

func (*LogArray) ProtoMessage()

func (*LogArray) ProtoReflect 

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

func (*LogArray) Reset 

func (x *LogArray) Reset()

func (*LogArray) String 

func (x *LogArray) String() string

type Metric 

type Metric struct {
	Name      string                 `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	TagsV1    map[string]string      `` /* 167-byte string literal not displayed */
	TagsV2    map[string]*TagValues  `` /* 168-byte string literal not displayed */
	Kind      Metric_Kind            `protobuf:"varint,4,opt,name=kind,proto3,enum=vector.Metric_Kind" json:"kind,omitempty"`
	// Types that are assignable to Value:
	//
	//	*Metric_Counter
	//	*Metric_Gauge
	//	*Metric_Set
	//	*Metric_Distribution1
	//	*Metric_AggregatedHistogram1
	//	*Metric_AggregatedSummary1
	//	*Metric_Distribution2
	//	*Metric_AggregatedHistogram2
	//	*Metric_AggregatedSummary2
	//	*Metric_Sketch
	//	*Metric_AggregatedHistogram3
	//	*Metric_AggregatedSummary3
	Value      isMetric_Value `protobuf_oneof:"value"`
	Namespace  string         `protobuf:"bytes,11,opt,name=namespace,proto3" json:"namespace,omitempty"`
	IntervalMs uint32         `protobuf:"varint,18,opt,name=interval_ms,json=intervalMs,proto3" json:"interval_ms,omitempty"`
	Metadata   *Value         `protobuf:"bytes,19,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

func (*Metric) Descriptor deprecated 

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

Deprecated: Use Metric.ProtoReflect.Descriptor instead.

func (*Metric) GetAggregatedHistogram1 

func (x *Metric) GetAggregatedHistogram1() *AggregatedHistogram1

func (*Metric) GetAggregatedHistogram2 

func (x *Metric) GetAggregatedHistogram2() *AggregatedHistogram2

func (*Metric) GetAggregatedHistogram3 

func (x *Metric) GetAggregatedHistogram3() *AggregatedHistogram3

func (*Metric) GetAggregatedSummary1 

func (x *Metric) GetAggregatedSummary1() *AggregatedSummary1

func (*Metric) GetAggregatedSummary2 

func (x *Metric) GetAggregatedSummary2() *AggregatedSummary2

func (*Metric) GetAggregatedSummary3 

func (x *Metric) GetAggregatedSummary3() *AggregatedSummary3

func (*Metric) GetCounter 

func (x *Metric) GetCounter() *Counter

func (*Metric) GetDistribution1 

func (x *Metric) GetDistribution1() *Distribution1

func (*Metric) GetDistribution2 

func (x *Metric) GetDistribution2() *Distribution2

func (*Metric) GetGauge 

func (x *Metric) GetGauge() *Gauge

func (*Metric) GetIntervalMs 

func (x *Metric) GetIntervalMs() uint32

func (*Metric) GetKind 

func (x *Metric) GetKind() Metric_Kind

func (*Metric) GetMetadata 

func (x *Metric) GetMetadata() *Value

func (*Metric) GetName 

func (x *Metric) GetName() string

func (*Metric) GetNamespace 

func (x *Metric) GetNamespace() string

func (*Metric) GetSet 

func (x *Metric) GetSet() *Set

func (*Metric) GetSketch 

func (x *Metric) GetSketch() *Sketch

func (*Metric) GetTagsV1 

func (x *Metric) GetTagsV1() map[string]string

func (*Metric) GetTagsV2 

func (x *Metric) GetTagsV2() map[string]*TagValues

func (*Metric) GetTimestamp 

func (x *Metric) GetTimestamp() *timestamppb.Timestamp

func (*Metric) GetValue 

func (m *Metric) GetValue() isMetric_Value

func (*Metric) ProtoMessage 

func (*Metric) ProtoMessage()

func (*Metric) ProtoReflect 

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

func (*Metric) Reset 

func (x *Metric) Reset()

func (*Metric) String 

func (x *Metric) String() string

type MetricArray 

type MetricArray struct {
	Metrics []*Metric `protobuf:"bytes,1,rep,name=metrics,proto3" json:"metrics,omitempty"`
	// contains filtered or unexported fields
}

func (*MetricArray) Descriptor deprecated 

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

Deprecated: Use MetricArray.ProtoReflect.Descriptor instead.

func (*MetricArray) GetMetrics 

func (x *MetricArray) GetMetrics() []*Metric

func (*MetricArray) ProtoMessage 

func (*MetricArray) ProtoMessage()

func (*MetricArray) ProtoReflect 

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

func (*MetricArray) Reset 

func (x *MetricArray) Reset()

func (*MetricArray) String 

func (x *MetricArray) String() string

type Metric_AggregatedHistogram1 

type Metric_AggregatedHistogram1 struct {
	AggregatedHistogram1 *AggregatedHistogram1 `protobuf:"bytes,9,opt,name=aggregated_histogram1,json=aggregatedHistogram1,proto3,oneof"`
}

type Metric_AggregatedHistogram2 

type Metric_AggregatedHistogram2 struct {
	AggregatedHistogram2 *AggregatedHistogram2 `protobuf:"bytes,13,opt,name=aggregated_histogram2,json=aggregatedHistogram2,proto3,oneof"`
}

type Metric_AggregatedHistogram3 

type Metric_AggregatedHistogram3 struct {
	AggregatedHistogram3 *AggregatedHistogram3 `protobuf:"bytes,16,opt,name=aggregated_histogram3,json=aggregatedHistogram3,proto3,oneof"`
}

type Metric_AggregatedSummary1 

type Metric_AggregatedSummary1 struct {
	AggregatedSummary1 *AggregatedSummary1 `protobuf:"bytes,10,opt,name=aggregated_summary1,json=aggregatedSummary1,proto3,oneof"`
}

type Metric_AggregatedSummary2 

type Metric_AggregatedSummary2 struct {
	AggregatedSummary2 *AggregatedSummary2 `protobuf:"bytes,14,opt,name=aggregated_summary2,json=aggregatedSummary2,proto3,oneof"`
}

type Metric_AggregatedSummary3 

type Metric_AggregatedSummary3 struct {
	AggregatedSummary3 *AggregatedSummary3 `protobuf:"bytes,17,opt,name=aggregated_summary3,json=aggregatedSummary3,proto3,oneof"`
}

type Metric_Counter 

type Metric_Counter struct {
	Counter *Counter `protobuf:"bytes,5,opt,name=counter,proto3,oneof"`
}

type Metric_Distribution1 

type Metric_Distribution1 struct {
	Distribution1 *Distribution1 `protobuf:"bytes,8,opt,name=distribution1,proto3,oneof"`
}

type Metric_Distribution2 

type Metric_Distribution2 struct {
	Distribution2 *Distribution2 `protobuf:"bytes,12,opt,name=distribution2,proto3,oneof"`
}

type Metric_Gauge 

type Metric_Gauge struct {
	Gauge *Gauge `protobuf:"bytes,6,opt,name=gauge,proto3,oneof"`
}

type Metric_Kind 

type Metric_Kind int32
const (
	Metric_Incremental Metric_Kind = 0
	Metric_Absolute    Metric_Kind = 1
)

func (Metric_Kind) Descriptor 

func (Metric_Kind) Descriptor() protoreflect.EnumDescriptor

func (Metric_Kind) Enum 

func (x Metric_Kind) Enum() *Metric_Kind

func (Metric_Kind) EnumDescriptor deprecated 

func (Metric_Kind) EnumDescriptor() ([]byte, []int)

Deprecated: Use Metric_Kind.Descriptor instead.

func (Metric_Kind) Number 

func (x Metric_Kind) Number() protoreflect.EnumNumber

func (Metric_Kind) String 

func (x Metric_Kind) String() string

func (Metric_Kind) Type 

func (Metric_Kind) Type() protoreflect.EnumType

type Metric_Set 

type Metric_Set struct {
	Set *Set `protobuf:"bytes,7,opt,name=set,proto3,oneof"`
}

type Metric_Sketch 

type Metric_Sketch struct {
	Sketch *Sketch `protobuf:"bytes,15,opt,name=sketch,proto3,oneof"`
}

type PushEventsRequest 

type PushEventsRequest struct {
	Events []*EventWrapper `protobuf:"bytes,1,rep,name=events,proto3" json:"events,omitempty"`
	// contains filtered or unexported fields
}

func (*PushEventsRequest) Descriptor deprecated 

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

Deprecated: Use PushEventsRequest.ProtoReflect.Descriptor instead.

func (*PushEventsRequest) GetEvents 

func (x *PushEventsRequest) GetEvents() []*EventWrapper

func (*PushEventsRequest) ProtoMessage 

func (*PushEventsRequest) ProtoMessage()

func (*PushEventsRequest) ProtoReflect 

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

func (*PushEventsRequest) Reset 

func (x *PushEventsRequest) Reset()

func (*PushEventsRequest) String 

func (x *PushEventsRequest) String() string

type PushEventsResponse 

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

func (*PushEventsResponse) Descriptor deprecated 

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

Deprecated: Use PushEventsResponse.ProtoReflect.Descriptor instead.

func (*PushEventsResponse) ProtoMessage 

func (*PushEventsResponse) ProtoMessage()

func (*PushEventsResponse) ProtoReflect 

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

func (*PushEventsResponse) Reset 

func (x *PushEventsResponse) Reset()

func (*PushEventsResponse) String 

func (x *PushEventsResponse) String() string

type ServingStatus 

type ServingStatus int32
const (
	ServingStatus_SERVING     ServingStatus = 0
	ServingStatus_NOT_SERVING ServingStatus = 1
)

func (ServingStatus) Descriptor 

func (ServingStatus) Descriptor() protoreflect.EnumDescriptor

func (ServingStatus) Enum 

func (x ServingStatus) Enum() *ServingStatus

func (ServingStatus) EnumDescriptor deprecated 

func (ServingStatus) EnumDescriptor() ([]byte, []int)

Deprecated: Use ServingStatus.Descriptor instead.

func (ServingStatus) Number 

func (x ServingStatus) Number() protoreflect.EnumNumber

func (ServingStatus) String 

func (x ServingStatus) String() string

func (ServingStatus) Type 

func (ServingStatus) Type() protoreflect.EnumType

type Set 

type Set struct {
	Values []string `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*Set) Descriptor deprecated 

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

Deprecated: Use Set.ProtoReflect.Descriptor instead.

func (*Set) GetValues 

func (x *Set) GetValues() []string

func (*Set) ProtoMessage 

func (*Set) ProtoMessage()

func (*Set) ProtoReflect 

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

func (*Set) Reset 

func (x *Set) Reset()

func (*Set) String 

func (x *Set) String() string

type Sketch 

type Sketch struct {

	// Types that are assignable to Sketch:
	//
	//	*Sketch_AgentDdSketch
	Sketch isSketch_Sketch `protobuf_oneof:"sketch"`
	// contains filtered or unexported fields
}

func (*Sketch) Descriptor deprecated 

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

Deprecated: Use Sketch.ProtoReflect.Descriptor instead.

func (*Sketch) GetAgentDdSketch 

func (x *Sketch) GetAgentDdSketch() *Sketch_AgentDDSketch

func (*Sketch) GetSketch 

func (m *Sketch) GetSketch() isSketch_Sketch

func (*Sketch) ProtoMessage 

func (*Sketch) ProtoMessage()

func (*Sketch) ProtoReflect 

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

func (*Sketch) Reset 

func (x *Sketch) Reset()

func (*Sketch) String 

func (x *Sketch) String() string

type Sketch_AgentDDSketch 

type Sketch_AgentDDSketch struct {

	// Summary statistics for the samples in this sketch.
	Count uint32  `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	Min   float64 `protobuf:"fixed64,2,opt,name=min,proto3" json:"min,omitempty"`
	Max   float64 `protobuf:"fixed64,3,opt,name=max,proto3" json:"max,omitempty"`
	Sum   float64 `protobuf:"fixed64,4,opt,name=sum,proto3" json:"sum,omitempty"`
	Avg   float64 `protobuf:"fixed64,5,opt,name=avg,proto3" json:"avg,omitempty"`
	// The bins (buckets) of this sketch, where `k` and `n` are unzipped pairs.
	// `k` is the list of bin indexes that are populated, and `n` is the count of samples
	// within the given bin.
	K []int32  `protobuf:"zigzag32,6,rep,packed,name=k,proto3" json:"k,omitempty"`
	N []uint32 `protobuf:"varint,7,rep,packed,name=n,proto3" json:"n,omitempty"`
	// contains filtered or unexported fields
}

func (*Sketch_AgentDDSketch) Descriptor deprecated 

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

Deprecated: Use Sketch_AgentDDSketch.ProtoReflect.Descriptor instead.

func (*Sketch_AgentDDSketch) GetAvg 

func (x *Sketch_AgentDDSketch) GetAvg() float64

func (*Sketch_AgentDDSketch) GetCount 

func (x *Sketch_AgentDDSketch) GetCount() uint32

func (*Sketch_AgentDDSketch) GetK 

func (x *Sketch_AgentDDSketch) GetK() []int32

func (*Sketch_AgentDDSketch) GetMax 

func (x *Sketch_AgentDDSketch) GetMax() float64

func (*Sketch_AgentDDSketch) GetMin 

func (x *Sketch_AgentDDSketch) GetMin() float64

func (*Sketch_AgentDDSketch) GetN 

func (x *Sketch_AgentDDSketch) GetN() []uint32

func (*Sketch_AgentDDSketch) GetSum 

func (x *Sketch_AgentDDSketch) GetSum() float64

func (*Sketch_AgentDDSketch) ProtoMessage 

func (*Sketch_AgentDDSketch) ProtoMessage()

func (*Sketch_AgentDDSketch) ProtoReflect 

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

func (*Sketch_AgentDDSketch) Reset 

func (x *Sketch_AgentDDSketch) Reset()

func (*Sketch_AgentDDSketch) String 

func (x *Sketch_AgentDDSketch) String() string

type Sketch_AgentDdSketch 

type Sketch_AgentDdSketch struct {
	AgentDdSketch *Sketch_AgentDDSketch `protobuf:"bytes,1,opt,name=agent_dd_sketch,json=agentDdSketch,proto3,oneof"`
}

type StatisticKind 

type StatisticKind int32
const (
	StatisticKind_Histogram StatisticKind = 0
	StatisticKind_Summary   StatisticKind = 1
)

func (StatisticKind) Descriptor 

func (StatisticKind) Descriptor() protoreflect.EnumDescriptor

func (StatisticKind) Enum 

func (x StatisticKind) Enum() *StatisticKind

func (StatisticKind) EnumDescriptor deprecated 

func (StatisticKind) EnumDescriptor() ([]byte, []int)

Deprecated: Use StatisticKind.Descriptor instead.

func (StatisticKind) Number 

func (x StatisticKind) Number() protoreflect.EnumNumber

func (StatisticKind) String 

func (x StatisticKind) String() string

func (StatisticKind) Type 

func (StatisticKind) Type() protoreflect.EnumType

type SummaryQuantile 

type SummaryQuantile struct {
	Quantile float64 `protobuf:"fixed64,1,opt,name=quantile,proto3" json:"quantile,omitempty"`
	Value    float64 `protobuf:"fixed64,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*SummaryQuantile) Descriptor deprecated 

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

Deprecated: Use SummaryQuantile.ProtoReflect.Descriptor instead.

func (*SummaryQuantile) GetQuantile 

func (x *SummaryQuantile) GetQuantile() float64

func (*SummaryQuantile) GetValue 

func (x *SummaryQuantile) GetValue() float64

func (*SummaryQuantile) ProtoMessage 

func (*SummaryQuantile) ProtoMessage()

func (*SummaryQuantile) ProtoReflect 

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

func (*SummaryQuantile) Reset 

func (x *SummaryQuantile) Reset()

func (*SummaryQuantile) String 

func (x *SummaryQuantile) String() string

type TagValue 

type TagValue struct {
	Value *string `protobuf:"bytes,1,opt,name=value,proto3,oneof" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*TagValue) Descriptor deprecated 

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

Deprecated: Use TagValue.ProtoReflect.Descriptor instead.

func (*TagValue) GetValue 

func (x *TagValue) GetValue() string

func (*TagValue) ProtoMessage 

func (*TagValue) ProtoMessage()

func (*TagValue) ProtoReflect 

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

func (*TagValue) Reset 

func (x *TagValue) Reset()

func (*TagValue) String 

func (x *TagValue) String() string

type TagValues 

type TagValues struct {
	Values []*TagValue `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*TagValues) Descriptor deprecated 

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

Deprecated: Use TagValues.ProtoReflect.Descriptor instead.

func (*TagValues) GetValues 

func (x *TagValues) GetValues() []*TagValue

func (*TagValues) ProtoMessage 

func (*TagValues) ProtoMessage()

func (*TagValues) ProtoReflect 

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

func (*TagValues) Reset 

func (x *TagValues) Reset()

func (*TagValues) String 

func (x *TagValues) String() string

type Trace 

type Trace struct {
	Fields   map[string]*Value `` /* 153-byte string literal not displayed */
	Metadata *Value            `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

func (*Trace) Descriptor deprecated 

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

Deprecated: Use Trace.ProtoReflect.Descriptor instead.

func (*Trace) GetFields 

func (x *Trace) GetFields() map[string]*Value

func (*Trace) GetMetadata 

func (x *Trace) GetMetadata() *Value

func (*Trace) ProtoMessage 

func (*Trace) ProtoMessage()

func (*Trace) ProtoReflect 

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

func (*Trace) Reset 

func (x *Trace) Reset()

func (*Trace) String 

func (x *Trace) String() string

type TraceArray 

type TraceArray struct {
	Traces []*Trace `protobuf:"bytes,1,rep,name=traces,proto3" json:"traces,omitempty"`
	// contains filtered or unexported fields
}

func (*TraceArray) Descriptor deprecated 

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

Deprecated: Use TraceArray.ProtoReflect.Descriptor instead.

func (*TraceArray) GetTraces 

func (x *TraceArray) GetTraces() []*Trace

func (*TraceArray) ProtoMessage 

func (*TraceArray) ProtoMessage()

func (*TraceArray) ProtoReflect 

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

func (*TraceArray) Reset 

func (x *TraceArray) Reset()

func (*TraceArray) String 

func (x *TraceArray) String() string

type UnimplementedVectorServer 

type UnimplementedVectorServer struct {
}

UnimplementedVectorServer must be embedded to have forward compatible implementations.

func (UnimplementedVectorServer) HealthCheck 

func (UnimplementedVectorServer) HealthCheck(context.Context, *HealthCheckRequest) (*HealthCheckResponse, error)

func (UnimplementedVectorServer) PushEvents 

func (UnimplementedVectorServer) PushEvents(context.Context, *PushEventsRequest) (*PushEventsResponse, error)

type UnsafeVectorServer 

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

UnsafeVectorServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to VectorServer will result in compilation errors.

type Value 

type Value struct {

	// Types that are assignable to Kind:
	//
	//	*Value_RawBytes
	//	*Value_Timestamp
	//	*Value_Integer
	//	*Value_Float
	//	*Value_Boolean
	//	*Value_Map
	//	*Value_Array
	//	*Value_Null
	Kind isValue_Kind `protobuf_oneof:"kind"`
	// contains filtered or unexported fields
}

func (*Value) Descriptor deprecated 

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

Deprecated: Use Value.ProtoReflect.Descriptor instead.

func (*Value) GetArray 

func (x *Value) GetArray() *ValueArray

func (*Value) GetBoolean 

func (x *Value) GetBoolean() bool

func (*Value) GetFloat 

func (x *Value) GetFloat() float64

func (*Value) GetInteger 

func (x *Value) GetInteger() int64

func (*Value) GetKind 

func (m *Value) GetKind() isValue_Kind

func (*Value) GetMap 

func (x *Value) GetMap() *ValueMap

func (*Value) GetNull 

func (x *Value) GetNull() ValueNull

func (*Value) GetRawBytes 

func (x *Value) GetRawBytes() []byte

func (*Value) GetTimestamp 

func (x *Value) GetTimestamp() *timestamppb.Timestamp

func (*Value) ProtoMessage 

func (*Value) ProtoMessage()

func (*Value) ProtoReflect 

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

func (*Value) Reset 

func (x *Value) Reset()

func (*Value) String 

func (x *Value) String() string

type ValueArray 

type ValueArray struct {
	Items []*Value `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
	// contains filtered or unexported fields
}

func (*ValueArray) Descriptor deprecated 

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

Deprecated: Use ValueArray.ProtoReflect.Descriptor instead.

func (*ValueArray) GetItems 

func (x *ValueArray) GetItems() []*Value

func (*ValueArray) ProtoMessage 

func (*ValueArray) ProtoMessage()

func (*ValueArray) ProtoReflect 

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

func (*ValueArray) Reset 

func (x *ValueArray) Reset()

func (*ValueArray) String 

func (x *ValueArray) String() string

type ValueMap 

type ValueMap struct {
	Fields map[string]*Value `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ValueMap) Descriptor deprecated 

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

Deprecated: Use ValueMap.ProtoReflect.Descriptor instead.

func (*ValueMap) GetFields 

func (x *ValueMap) GetFields() map[string]*Value

func (*ValueMap) ProtoMessage 

func (*ValueMap) ProtoMessage()

func (*ValueMap) ProtoReflect 

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

func (*ValueMap) Reset 

func (x *ValueMap) Reset()

func (*ValueMap) String 

func (x *ValueMap) String() string

type ValueNull 

type ValueNull int32
const (
	ValueNull_NULL_VALUE ValueNull = 0
)

func (ValueNull) Descriptor 

func (ValueNull) Descriptor() protoreflect.EnumDescriptor

func (ValueNull) Enum 

func (x ValueNull) Enum() *ValueNull

func (ValueNull) EnumDescriptor deprecated 

func (ValueNull) EnumDescriptor() ([]byte, []int)

Deprecated: Use ValueNull.Descriptor instead.

func (ValueNull) Number 

func (x ValueNull) Number() protoreflect.EnumNumber

func (ValueNull) String 

func (x ValueNull) String() string

func (ValueNull) Type 

func (ValueNull) Type() protoreflect.EnumType

type Value_Array 

type Value_Array struct {
	Array *ValueArray `protobuf:"bytes,8,opt,name=array,proto3,oneof"`
}

type Value_Boolean 

type Value_Boolean struct {
	Boolean bool `protobuf:"varint,6,opt,name=boolean,proto3,oneof"`
}

type Value_Float 

type Value_Float struct {
	Float float64 `protobuf:"fixed64,5,opt,name=float,proto3,oneof"`
}

type Value_Integer 

type Value_Integer struct {
	Integer int64 `protobuf:"varint,4,opt,name=integer,proto3,oneof"`
}

type Value_Map 

type Value_Map struct {
	Map *ValueMap `protobuf:"bytes,7,opt,name=map,proto3,oneof"`
}

type Value_Null 

type Value_Null struct {
	Null ValueNull `protobuf:"varint,9,opt,name=null,proto3,enum=vector.ValueNull,oneof"`
}

type Value_RawBytes 

type Value_RawBytes struct {
	RawBytes []byte `protobuf:"bytes,1,opt,name=raw_bytes,json=rawBytes,proto3,oneof"`
}

type Value_Timestamp 

type Value_Timestamp struct {
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=timestamp,proto3,oneof"`
}

type VectorClient 

type VectorClient interface {
	PushEvents(ctx context.Context, in *PushEventsRequest, opts ...grpc.CallOption) (*PushEventsResponse, error)
	HealthCheck(ctx context.Context, in *HealthCheckRequest, opts ...grpc.CallOption) (*HealthCheckResponse, error)
}

VectorClient is the client API for Vector service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewVectorClient 

func NewVectorClient(cc grpc.ClientConnInterface) VectorClient

type VectorServer 

type VectorServer interface {
	PushEvents(context.Context, *PushEventsRequest) (*PushEventsResponse, error)
	HealthCheck(context.Context, *HealthCheckRequest) (*HealthCheckResponse, error)
	// contains filtered or unexported methods
}

VectorServer is the server API for Vector service. All implementations must embed UnimplementedVectorServer for forward compatibility

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.