logcache_v1

package
v2.0.7 Latest Latest
Warning

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

 Go to latest Published: Jan 30, 2024 License: Apache-2.0 Imports: 17 Imported by: 2

Documentation

Overview

Package logcache_v1 is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package logcache_v1 is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var (
	EnvelopeType_name = map[int32]string{
		0: "ANY",
		1: "LOG",
		2: "COUNTER",
		3: "GAUGE",
		4: "TIMER",
		5: "EVENT",
	}
	EnvelopeType_value = map[string]int32{
		"ANY":     0,
		"LOG":     1,
		"COUNTER": 2,
		"GAUGE":   3,
		"TIMER":   4,
		"EVENT":   5,
	}
)

Enum value maps for EnvelopeType.

View Source 
var Egress_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "logcache.v1.Egress",
	HandlerType: (*EgressServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Read",
			Handler:    _Egress_Read_Handler,
		},
		{
			MethodName: "Meta",
			Handler:    _Egress_Meta_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "go-log-cache/api/v1/egress.proto",
}

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

View Source 
var File_go_log_cache_api_v1_egress_proto protoreflect.FileDescriptor
View Source 
var File_go_log_cache_api_v1_ingress_proto protoreflect.FileDescriptor
View Source 
var File_go_log_cache_api_v1_orchestration_proto protoreflect.FileDescriptor
View Source 
var File_go_log_cache_api_v1_promql_proto protoreflect.FileDescriptor
View Source 
var Ingress_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "logcache.v1.Ingress",
	HandlerType: (*IngressServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Send",
			Handler:    _Ingress_Send_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "go-log-cache/api/v1/ingress.proto",
}

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

View Source 
var Orchestration_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "logcache.v1.Orchestration",
	HandlerType: (*OrchestrationServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "AddRange",
			Handler:    _Orchestration_AddRange_Handler,
		},
		{
			MethodName: "RemoveRange",
			Handler:    _Orchestration_RemoveRange_Handler,
		},
		{
			MethodName: "ListRanges",
			Handler:    _Orchestration_ListRanges_Handler,
		},
		{
			MethodName: "SetRanges",
			Handler:    _Orchestration_SetRanges_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "go-log-cache/api/v1/orchestration.proto",
}

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

View Source 
var PromQLQuerier_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "logcache.v1.PromQLQuerier",
	HandlerType: (*PromQLQuerierServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "InstantQuery",
			Handler:    _PromQLQuerier_InstantQuery_Handler,
		},
		{
			MethodName: "RangeQuery",
			Handler:    _PromQLQuerier_RangeQuery_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "go-log-cache/api/v1/promql.proto",
}

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

Functions

func RegisterEgressHandler 

func RegisterEgressHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterEgressHandler registers the http handlers for service Egress to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterEgressHandlerClient 

func RegisterEgressHandlerClient(ctx context.Context, mux *runtime.ServeMux, client EgressClient) error

RegisterEgressHandlerClient registers the http handlers for service Egress to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "EgressClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "EgressClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "EgressClient" to call the correct interceptors.

func RegisterEgressHandlerFromEndpoint 

func RegisterEgressHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterEgressHandlerFromEndpoint is same as RegisterEgressHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterEgressHandlerServer 

func RegisterEgressHandlerServer(ctx context.Context, mux *runtime.ServeMux, server EgressServer) error

RegisterEgressHandlerServer registers the http handlers for service Egress to "mux". UnaryRPC :call EgressServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterEgressHandlerFromEndpoint instead.

func RegisterEgressServer 

func RegisterEgressServer(s grpc.ServiceRegistrar, srv EgressServer)

func RegisterIngressServer 

func RegisterIngressServer(s grpc.ServiceRegistrar, srv IngressServer)

func RegisterOrchestrationServer 

func RegisterOrchestrationServer(s grpc.ServiceRegistrar, srv OrchestrationServer)

func RegisterPromQLQuerierHandler 

func RegisterPromQLQuerierHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterPromQLQuerierHandler registers the http handlers for service PromQLQuerier to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterPromQLQuerierHandlerClient 

func RegisterPromQLQuerierHandlerClient(ctx context.Context, mux *runtime.ServeMux, client PromQLQuerierClient) error

RegisterPromQLQuerierHandlerClient registers the http handlers for service PromQLQuerier to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "PromQLQuerierClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "PromQLQuerierClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "PromQLQuerierClient" to call the correct interceptors.

func RegisterPromQLQuerierHandlerFromEndpoint 

func RegisterPromQLQuerierHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterPromQLQuerierHandlerFromEndpoint is same as RegisterPromQLQuerierHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterPromQLQuerierHandlerServer 

func RegisterPromQLQuerierHandlerServer(ctx context.Context, mux *runtime.ServeMux, server PromQLQuerierServer) error

RegisterPromQLQuerierHandlerServer registers the http handlers for service PromQLQuerier to "mux". UnaryRPC :call PromQLQuerierServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterPromQLQuerierHandlerFromEndpoint instead.

func RegisterPromQLQuerierServer 

func RegisterPromQLQuerierServer(s grpc.ServiceRegistrar, srv PromQLQuerierServer)

Types

type AddRangeRequest 

type AddRangeRequest struct {
	Range *Range `protobuf:"bytes,1,opt,name=range,proto3" json:"range,omitempty"`
	// contains filtered or unexported fields
}

func (*AddRangeRequest) Descriptor deprecated 

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

Deprecated: Use AddRangeRequest.ProtoReflect.Descriptor instead.

func (*AddRangeRequest) GetRange 

func (x *AddRangeRequest) GetRange() *Range

func (*AddRangeRequest) ProtoMessage 

func (*AddRangeRequest) ProtoMessage()

func (*AddRangeRequest) ProtoReflect 

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

func (*AddRangeRequest) Reset 

func (x *AddRangeRequest) Reset()

func (*AddRangeRequest) String 

func (x *AddRangeRequest) String() string

type AddRangeResponse 

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

func (*AddRangeResponse) Descriptor deprecated 

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

Deprecated: Use AddRangeResponse.ProtoReflect.Descriptor instead.

func (*AddRangeResponse) ProtoMessage 

func (*AddRangeResponse) ProtoMessage()

func (*AddRangeResponse) ProtoReflect 

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

func (*AddRangeResponse) Reset 

func (x *AddRangeResponse) Reset()

func (*AddRangeResponse) String 

func (x *AddRangeResponse) String() string

type EgressClient 

type EgressClient interface {
	Read(ctx context.Context, in *ReadRequest, opts ...grpc.CallOption) (*ReadResponse, error)
	Meta(ctx context.Context, in *MetaRequest, opts ...grpc.CallOption) (*MetaResponse, error)
}

EgressClient is the client API for Egress 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 NewEgressClient 

func NewEgressClient(cc grpc.ClientConnInterface) EgressClient

type EgressServer 

type EgressServer interface {
	Read(context.Context, *ReadRequest) (*ReadResponse, error)
	Meta(context.Context, *MetaRequest) (*MetaResponse, error)
	// contains filtered or unexported methods
}

EgressServer is the server API for Egress service. All implementations must embed UnimplementedEgressServer for forward compatibility

type EnvelopeType 

type EnvelopeType int32
const (
	EnvelopeType_ANY     EnvelopeType = 0
	EnvelopeType_LOG     EnvelopeType = 1
	EnvelopeType_COUNTER EnvelopeType = 2
	EnvelopeType_GAUGE   EnvelopeType = 3
	EnvelopeType_TIMER   EnvelopeType = 4
	EnvelopeType_EVENT   EnvelopeType = 5
)

func (EnvelopeType) Descriptor 

func (EnvelopeType) Descriptor() protoreflect.EnumDescriptor

func (EnvelopeType) Enum 

func (x EnvelopeType) Enum() *EnvelopeType

func (EnvelopeType) EnumDescriptor deprecated 

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

Deprecated: Use EnvelopeType.Descriptor instead.

func (EnvelopeType) Number 

func (x EnvelopeType) Number() protoreflect.EnumNumber

func (EnvelopeType) String 

func (x EnvelopeType) String() string

func (EnvelopeType) Type 

func (EnvelopeType) Type() protoreflect.EnumType

type IngressClient 

type IngressClient interface {
	// Send is used to emit Envelopes batches into LogCache. The RPC function
	// will not return until the data has been stored.
	Send(ctx context.Context, in *SendRequest, opts ...grpc.CallOption) (*SendResponse, error)
}

IngressClient is the client API for Ingress 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 NewIngressClient 

func NewIngressClient(cc grpc.ClientConnInterface) IngressClient

type IngressServer 

type IngressServer interface {
	// Send is used to emit Envelopes batches into LogCache. The RPC function
	// will not return until the data has been stored.
	Send(context.Context, *SendRequest) (*SendResponse, error)
	// contains filtered or unexported methods
}

IngressServer is the server API for Ingress service. All implementations must embed UnimplementedIngressServer for forward compatibility

type ListRangesRequest 

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

func (*ListRangesRequest) Descriptor deprecated 

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

Deprecated: Use ListRangesRequest.ProtoReflect.Descriptor instead.

func (*ListRangesRequest) ProtoMessage 

func (*ListRangesRequest) ProtoMessage()

func (*ListRangesRequest) ProtoReflect 

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

func (*ListRangesRequest) Reset 

func (x *ListRangesRequest) Reset()

func (*ListRangesRequest) String 

func (x *ListRangesRequest) String() string

type ListRangesResponse 

type ListRangesResponse struct {
	Ranges []*Range `protobuf:"bytes,1,rep,name=ranges,proto3" json:"ranges,omitempty"`
	// contains filtered or unexported fields
}

func (*ListRangesResponse) Descriptor deprecated 

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

Deprecated: Use ListRangesResponse.ProtoReflect.Descriptor instead.

func (*ListRangesResponse) GetRanges 

func (x *ListRangesResponse) GetRanges() []*Range

func (*ListRangesResponse) ProtoMessage 

func (*ListRangesResponse) ProtoMessage()

func (*ListRangesResponse) ProtoReflect 

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

func (*ListRangesResponse) Reset 

func (x *ListRangesResponse) Reset()

func (*ListRangesResponse) String 

func (x *ListRangesResponse) String() string

type MetaInfo 

type MetaInfo struct {
	Count           int64 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	Expired         int64 `protobuf:"varint,2,opt,name=expired,proto3" json:"expired,omitempty"`
	OldestTimestamp int64 `protobuf:"varint,3,opt,name=oldest_timestamp,json=oldestTimestamp,proto3" json:"oldest_timestamp,omitempty"`
	NewestTimestamp int64 `protobuf:"varint,4,opt,name=newest_timestamp,json=newestTimestamp,proto3" json:"newest_timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*MetaInfo) Descriptor deprecated 

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

Deprecated: Use MetaInfo.ProtoReflect.Descriptor instead.

func (*MetaInfo) GetCount 

func (x *MetaInfo) GetCount() int64

func (*MetaInfo) GetExpired 

func (x *MetaInfo) GetExpired() int64

func (*MetaInfo) GetNewestTimestamp 

func (x *MetaInfo) GetNewestTimestamp() int64

func (*MetaInfo) GetOldestTimestamp 

func (x *MetaInfo) GetOldestTimestamp() int64

func (*MetaInfo) ProtoMessage 

func (*MetaInfo) ProtoMessage()

func (*MetaInfo) ProtoReflect 

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

func (*MetaInfo) Reset 

func (x *MetaInfo) Reset()

func (*MetaInfo) String 

func (x *MetaInfo) String() string

type MetaRequest 

type MetaRequest struct {
	LocalOnly bool `protobuf:"varint,1,opt,name=local_only,json=localOnly,proto3" json:"local_only,omitempty"`
	// contains filtered or unexported fields
}

func (*MetaRequest) Descriptor deprecated 

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

Deprecated: Use MetaRequest.ProtoReflect.Descriptor instead.

func (*MetaRequest) GetLocalOnly 

func (x *MetaRequest) GetLocalOnly() bool

func (*MetaRequest) ProtoMessage 

func (*MetaRequest) ProtoMessage()

func (*MetaRequest) ProtoReflect 

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

func (*MetaRequest) Reset 

func (x *MetaRequest) Reset()

func (*MetaRequest) String 

func (x *MetaRequest) String() string

type MetaResponse 

type MetaResponse struct {
	Meta map[string]*MetaInfo `` /* 149-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*MetaResponse) Descriptor deprecated 

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

Deprecated: Use MetaResponse.ProtoReflect.Descriptor instead.

func (*MetaResponse) GetMeta 

func (x *MetaResponse) GetMeta() map[string]*MetaInfo

func (*MetaResponse) ProtoMessage 

func (*MetaResponse) ProtoMessage()

func (*MetaResponse) ProtoReflect 

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

func (*MetaResponse) Reset 

func (x *MetaResponse) Reset()

func (*MetaResponse) String 

func (x *MetaResponse) String() string

type OrchestrationClient 

type OrchestrationClient interface {
	AddRange(ctx context.Context, in *AddRangeRequest, opts ...grpc.CallOption) (*AddRangeResponse, error)
	RemoveRange(ctx context.Context, in *RemoveRangeRequest, opts ...grpc.CallOption) (*RemoveRangeResponse, error)
	ListRanges(ctx context.Context, in *ListRangesRequest, opts ...grpc.CallOption) (*ListRangesResponse, error)
	SetRanges(ctx context.Context, in *SetRangesRequest, opts ...grpc.CallOption) (*SetRangesResponse, error)
}

OrchestrationClient is the client API for Orchestration 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 NewOrchestrationClient 

func NewOrchestrationClient(cc grpc.ClientConnInterface) OrchestrationClient

type OrchestrationServer 

type OrchestrationServer interface {
	AddRange(context.Context, *AddRangeRequest) (*AddRangeResponse, error)
	RemoveRange(context.Context, *RemoveRangeRequest) (*RemoveRangeResponse, error)
	ListRanges(context.Context, *ListRangesRequest) (*ListRangesResponse, error)
	SetRanges(context.Context, *SetRangesRequest) (*SetRangesResponse, error)
	// contains filtered or unexported methods
}

OrchestrationServer is the server API for Orchestration service. All implementations must embed UnimplementedOrchestrationServer for forward compatibility

type PromQL 

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

func (*PromQL) Descriptor deprecated 

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

Deprecated: Use PromQL.ProtoReflect.Descriptor instead.

func (*PromQL) ProtoMessage 

func (*PromQL) ProtoMessage()

func (*PromQL) ProtoReflect 

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

func (*PromQL) Reset 

func (x *PromQL) Reset()

func (*PromQL) String 

func (x *PromQL) String() string

type PromQLQuerierClient 

type PromQLQuerierClient interface {
	InstantQuery(ctx context.Context, in *PromQL_InstantQueryRequest, opts ...grpc.CallOption) (*PromQL_InstantQueryResult, error)
	RangeQuery(ctx context.Context, in *PromQL_RangeQueryRequest, opts ...grpc.CallOption) (*PromQL_RangeQueryResult, error)
}

PromQLQuerierClient is the client API for PromQLQuerier 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 NewPromQLQuerierClient 

func NewPromQLQuerierClient(cc grpc.ClientConnInterface) PromQLQuerierClient

type PromQLQuerierServer 

type PromQLQuerierServer interface {
	InstantQuery(context.Context, *PromQL_InstantQueryRequest) (*PromQL_InstantQueryResult, error)
	RangeQuery(context.Context, *PromQL_RangeQueryRequest) (*PromQL_RangeQueryResult, error)
	// contains filtered or unexported methods
}

PromQLQuerierServer is the server API for PromQLQuerier service. All implementations must embed UnimplementedPromQLQuerierServer for forward compatibility

type PromQL_InstantQueryRequest 

type PromQL_InstantQueryRequest struct {
	Query string `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
	Time  string `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*PromQL_InstantQueryRequest) Descriptor deprecated 

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

Deprecated: Use PromQL_InstantQueryRequest.ProtoReflect.Descriptor instead.

func (*PromQL_InstantQueryRequest) GetQuery 

func (x *PromQL_InstantQueryRequest) GetQuery() string

func (*PromQL_InstantQueryRequest) GetTime 

func (x *PromQL_InstantQueryRequest) GetTime() string

func (*PromQL_InstantQueryRequest) ProtoMessage 

func (*PromQL_InstantQueryRequest) ProtoMessage()

func (*PromQL_InstantQueryRequest) ProtoReflect 

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

func (*PromQL_InstantQueryRequest) Reset 

func (x *PromQL_InstantQueryRequest) Reset()

func (*PromQL_InstantQueryRequest) String 

func (x *PromQL_InstantQueryRequest) String() string

type PromQL_InstantQueryResult 

type PromQL_InstantQueryResult struct {

	// Types that are assignable to Result:
	//
	//	*PromQL_InstantQueryResult_Scalar
	//	*PromQL_InstantQueryResult_Vector
	//	*PromQL_InstantQueryResult_Matrix
	Result isPromQL_InstantQueryResult_Result `protobuf_oneof:"Result"`
	// contains filtered or unexported fields
}

func (*PromQL_InstantQueryResult) Descriptor deprecated 

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

Deprecated: Use PromQL_InstantQueryResult.ProtoReflect.Descriptor instead.

func (*PromQL_InstantQueryResult) GetMatrix 

func (x *PromQL_InstantQueryResult) GetMatrix() *PromQL_Matrix

func (*PromQL_InstantQueryResult) GetResult 

func (m *PromQL_InstantQueryResult) GetResult() isPromQL_InstantQueryResult_Result

func (*PromQL_InstantQueryResult) GetScalar 

func (x *PromQL_InstantQueryResult) GetScalar() *PromQL_Scalar

func (*PromQL_InstantQueryResult) GetVector 

func (x *PromQL_InstantQueryResult) GetVector() *PromQL_Vector

func (*PromQL_InstantQueryResult) ProtoMessage 

func (*PromQL_InstantQueryResult) ProtoMessage()

func (*PromQL_InstantQueryResult) ProtoReflect 

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

func (*PromQL_InstantQueryResult) Reset 

func (x *PromQL_InstantQueryResult) Reset()

func (*PromQL_InstantQueryResult) String 

func (x *PromQL_InstantQueryResult) String() string

type PromQL_InstantQueryResult_Matrix 

type PromQL_InstantQueryResult_Matrix struct {
	Matrix *PromQL_Matrix `protobuf:"bytes,3,opt,name=matrix,proto3,oneof"`
}

type PromQL_InstantQueryResult_Scalar 

type PromQL_InstantQueryResult_Scalar struct {
	Scalar *PromQL_Scalar `protobuf:"bytes,1,opt,name=scalar,proto3,oneof"`
}

type PromQL_InstantQueryResult_Vector 

type PromQL_InstantQueryResult_Vector struct {
	Vector *PromQL_Vector `protobuf:"bytes,2,opt,name=vector,proto3,oneof"`
}

type PromQL_Matrix 

type PromQL_Matrix struct {
	Series []*PromQL_Series `protobuf:"bytes,1,rep,name=series,proto3" json:"series,omitempty"`
	// contains filtered or unexported fields
}

func (*PromQL_Matrix) Descriptor deprecated 

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

Deprecated: Use PromQL_Matrix.ProtoReflect.Descriptor instead.

func (*PromQL_Matrix) GetSeries 

func (x *PromQL_Matrix) GetSeries() []*PromQL_Series

func (*PromQL_Matrix) ProtoMessage 

func (*PromQL_Matrix) ProtoMessage()

func (*PromQL_Matrix) ProtoReflect 

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

func (*PromQL_Matrix) Reset 

func (x *PromQL_Matrix) Reset()

func (*PromQL_Matrix) String 

func (x *PromQL_Matrix) String() string

type PromQL_Point 

type PromQL_Point struct {
	Time  string  `protobuf:"bytes,1,opt,name=time,proto3" json:"time,omitempty"`
	Value float64 `protobuf:"fixed64,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*PromQL_Point) Descriptor deprecated 

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

Deprecated: Use PromQL_Point.ProtoReflect.Descriptor instead.

func (*PromQL_Point) GetTime 

func (x *PromQL_Point) GetTime() string

func (*PromQL_Point) GetValue 

func (x *PromQL_Point) GetValue() float64

func (*PromQL_Point) ProtoMessage 

func (*PromQL_Point) ProtoMessage()

func (*PromQL_Point) ProtoReflect 

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

func (*PromQL_Point) Reset 

func (x *PromQL_Point) Reset()

func (*PromQL_Point) String 

func (x *PromQL_Point) String() string

type PromQL_RangeQueryRequest 

type PromQL_RangeQueryRequest struct {
	Query string `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
	Start string `protobuf:"bytes,2,opt,name=start,proto3" json:"start,omitempty"`
	End   string `protobuf:"bytes,3,opt,name=end,proto3" json:"end,omitempty"`
	Step  string `protobuf:"bytes,4,opt,name=step,proto3" json:"step,omitempty"`
	// contains filtered or unexported fields
}

func (*PromQL_RangeQueryRequest) Descriptor deprecated 

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

Deprecated: Use PromQL_RangeQueryRequest.ProtoReflect.Descriptor instead.

func (*PromQL_RangeQueryRequest) GetEnd 

func (x *PromQL_RangeQueryRequest) GetEnd() string

func (*PromQL_RangeQueryRequest) GetQuery 

func (x *PromQL_RangeQueryRequest) GetQuery() string

func (*PromQL_RangeQueryRequest) GetStart 

func (x *PromQL_RangeQueryRequest) GetStart() string

func (*PromQL_RangeQueryRequest) GetStep 

func (x *PromQL_RangeQueryRequest) GetStep() string

func (*PromQL_RangeQueryRequest) ProtoMessage 

func (*PromQL_RangeQueryRequest) ProtoMessage()

func (*PromQL_RangeQueryRequest) ProtoReflect 

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

func (*PromQL_RangeQueryRequest) Reset 

func (x *PromQL_RangeQueryRequest) Reset()

func (*PromQL_RangeQueryRequest) String 

func (x *PromQL_RangeQueryRequest) String() string

type PromQL_RangeQueryResult 

type PromQL_RangeQueryResult struct {

	// Types that are assignable to Result:
	//
	//	*PromQL_RangeQueryResult_Matrix
	Result isPromQL_RangeQueryResult_Result `protobuf_oneof:"Result"`
	// contains filtered or unexported fields
}

func (*PromQL_RangeQueryResult) Descriptor deprecated 

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

Deprecated: Use PromQL_RangeQueryResult.ProtoReflect.Descriptor instead.

func (*PromQL_RangeQueryResult) GetMatrix 

func (x *PromQL_RangeQueryResult) GetMatrix() *PromQL_Matrix

func (*PromQL_RangeQueryResult) GetResult 

func (m *PromQL_RangeQueryResult) GetResult() isPromQL_RangeQueryResult_Result

func (*PromQL_RangeQueryResult) ProtoMessage 

func (*PromQL_RangeQueryResult) ProtoMessage()

func (*PromQL_RangeQueryResult) ProtoReflect 

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

func (*PromQL_RangeQueryResult) Reset 

func (x *PromQL_RangeQueryResult) Reset()

func (*PromQL_RangeQueryResult) String 

func (x *PromQL_RangeQueryResult) String() string

type PromQL_RangeQueryResult_Matrix 

type PromQL_RangeQueryResult_Matrix struct {
	Matrix *PromQL_Matrix `protobuf:"bytes,1,opt,name=matrix,proto3,oneof"`
}

type PromQL_Sample 

type PromQL_Sample struct {
	Metric map[string]string `` /* 153-byte string literal not displayed */
	Point  *PromQL_Point     `protobuf:"bytes,2,opt,name=point,proto3" json:"point,omitempty"`
	// contains filtered or unexported fields
}

func (*PromQL_Sample) Descriptor deprecated 

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

Deprecated: Use PromQL_Sample.ProtoReflect.Descriptor instead.

func (*PromQL_Sample) GetMetric 

func (x *PromQL_Sample) GetMetric() map[string]string

func (*PromQL_Sample) GetPoint 

func (x *PromQL_Sample) GetPoint() *PromQL_Point

func (*PromQL_Sample) ProtoMessage 

func (*PromQL_Sample) ProtoMessage()

func (*PromQL_Sample) ProtoReflect 

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

func (*PromQL_Sample) Reset 

func (x *PromQL_Sample) Reset()

func (*PromQL_Sample) String 

func (x *PromQL_Sample) String() string

type PromQL_Scalar 

type PromQL_Scalar struct {
	Time  string  `protobuf:"bytes,1,opt,name=time,proto3" json:"time,omitempty"`
	Value float64 `protobuf:"fixed64,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*PromQL_Scalar) Descriptor deprecated 

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

Deprecated: Use PromQL_Scalar.ProtoReflect.Descriptor instead.

func (*PromQL_Scalar) GetTime 

func (x *PromQL_Scalar) GetTime() string

func (*PromQL_Scalar) GetValue 

func (x *PromQL_Scalar) GetValue() float64

func (*PromQL_Scalar) ProtoMessage 

func (*PromQL_Scalar) ProtoMessage()

func (*PromQL_Scalar) ProtoReflect 

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

func (*PromQL_Scalar) Reset 

func (x *PromQL_Scalar) Reset()

func (*PromQL_Scalar) String 

func (x *PromQL_Scalar) String() string

type PromQL_Series 

type PromQL_Series struct {
	Metric map[string]string `` /* 153-byte string literal not displayed */
	Points []*PromQL_Point   `protobuf:"bytes,2,rep,name=points,proto3" json:"points,omitempty"`
	// contains filtered or unexported fields
}

func (*PromQL_Series) Descriptor deprecated 

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

Deprecated: Use PromQL_Series.ProtoReflect.Descriptor instead.

func (*PromQL_Series) GetMetric 

func (x *PromQL_Series) GetMetric() map[string]string

func (*PromQL_Series) GetPoints 

func (x *PromQL_Series) GetPoints() []*PromQL_Point

func (*PromQL_Series) ProtoMessage 

func (*PromQL_Series) ProtoMessage()

func (*PromQL_Series) ProtoReflect 

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

func (*PromQL_Series) Reset 

func (x *PromQL_Series) Reset()

func (*PromQL_Series) String 

func (x *PromQL_Series) String() string

type PromQL_Vector 

type PromQL_Vector struct {
	Samples []*PromQL_Sample `protobuf:"bytes,1,rep,name=samples,proto3" json:"samples,omitempty"`
	// contains filtered or unexported fields
}

func (*PromQL_Vector) Descriptor deprecated 

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

Deprecated: Use PromQL_Vector.ProtoReflect.Descriptor instead.

func (*PromQL_Vector) GetSamples 

func (x *PromQL_Vector) GetSamples() []*PromQL_Sample

func (*PromQL_Vector) ProtoMessage 

func (*PromQL_Vector) ProtoMessage()

func (*PromQL_Vector) ProtoReflect 

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

func (*PromQL_Vector) Reset 

func (x *PromQL_Vector) Reset()

func (*PromQL_Vector) String 

func (x *PromQL_Vector) String() string

type Range 

type Range struct {

	// start is the first hash within the given range. [start..end]
	Start uint64 `protobuf:"varint,1,opt,name=start,proto3" json:"start,omitempty"`
	// end is the last hash within the given range. [start..end]
	End uint64 `protobuf:"varint,2,opt,name=end,proto3" json:"end,omitempty"`
	// contains filtered or unexported fields
}

func (*Range) Descriptor deprecated 

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

Deprecated: Use Range.ProtoReflect.Descriptor instead.

func (*Range) GetEnd 

func (x *Range) GetEnd() uint64

func (*Range) GetStart 

func (x *Range) GetStart() uint64

func (*Range) ProtoMessage 

func (*Range) ProtoMessage()

func (*Range) ProtoReflect 

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

func (*Range) Reset 

func (x *Range) Reset()

func (*Range) String 

func (x *Range) String() string

type Ranges 

type Ranges struct {
	Ranges []*Range `protobuf:"bytes,1,rep,name=ranges,proto3" json:"ranges,omitempty"`
	// contains filtered or unexported fields
}

func (*Ranges) Descriptor deprecated 

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

Deprecated: Use Ranges.ProtoReflect.Descriptor instead.

func (*Ranges) GetRanges 

func (x *Ranges) GetRanges() []*Range

func (*Ranges) ProtoMessage 

func (*Ranges) ProtoMessage()

func (*Ranges) ProtoReflect 

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

func (*Ranges) Reset 

func (x *Ranges) Reset()

func (*Ranges) String 

func (x *Ranges) String() string

type ReadRequest 

type ReadRequest struct {
	SourceId      string         `protobuf:"bytes,1,opt,name=source_id,json=sourceId,proto3" json:"source_id,omitempty"`
	StartTime     int64          `protobuf:"varint,2,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	EndTime       int64          `protobuf:"varint,3,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	Limit         int64          `protobuf:"varint,4,opt,name=limit,proto3" json:"limit,omitempty"`
	EnvelopeTypes []EnvelopeType `` /* 138-byte string literal not displayed */
	Descending    bool           `protobuf:"varint,6,opt,name=descending,proto3" json:"descending,omitempty"`
	NameFilter    string         `protobuf:"bytes,7,opt,name=name_filter,json=nameFilter,proto3" json:"name_filter,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadRequest) Descriptor deprecated 

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

Deprecated: Use ReadRequest.ProtoReflect.Descriptor instead.

func (*ReadRequest) GetDescending 

func (x *ReadRequest) GetDescending() bool

func (*ReadRequest) GetEndTime 

func (x *ReadRequest) GetEndTime() int64

func (*ReadRequest) GetEnvelopeTypes 

func (x *ReadRequest) GetEnvelopeTypes() []EnvelopeType

func (*ReadRequest) GetLimit 

func (x *ReadRequest) GetLimit() int64

func (*ReadRequest) GetNameFilter 

func (x *ReadRequest) GetNameFilter() string

func (*ReadRequest) GetSourceId 

func (x *ReadRequest) GetSourceId() string

func (*ReadRequest) GetStartTime 

func (x *ReadRequest) GetStartTime() int64

func (*ReadRequest) ProtoMessage 

func (*ReadRequest) ProtoMessage()

func (*ReadRequest) ProtoReflect 

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

func (*ReadRequest) Reset 

func (x *ReadRequest) Reset()

func (*ReadRequest) String 

func (x *ReadRequest) String() string

type ReadResponse 

type ReadResponse struct {
	Envelopes *loggregator_v2.EnvelopeBatch `protobuf:"bytes,1,opt,name=envelopes,proto3" json:"envelopes,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadResponse) Descriptor deprecated 

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

Deprecated: Use ReadResponse.ProtoReflect.Descriptor instead.

func (*ReadResponse) GetEnvelopes 

func (x *ReadResponse) GetEnvelopes() *loggregator_v2.EnvelopeBatch

func (*ReadResponse) ProtoMessage 

func (*ReadResponse) ProtoMessage()

func (*ReadResponse) ProtoReflect 

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

func (*ReadResponse) Reset 

func (x *ReadResponse) Reset()

func (*ReadResponse) String 

func (x *ReadResponse) String() string

type RemoveRangeRequest 

type RemoveRangeRequest struct {
	Range *Range `protobuf:"bytes,1,opt,name=range,proto3" json:"range,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveRangeRequest) Descriptor deprecated 

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

Deprecated: Use RemoveRangeRequest.ProtoReflect.Descriptor instead.

func (*RemoveRangeRequest) GetRange 

func (x *RemoveRangeRequest) GetRange() *Range

func (*RemoveRangeRequest) ProtoMessage 

func (*RemoveRangeRequest) ProtoMessage()

func (*RemoveRangeRequest) ProtoReflect 

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

func (*RemoveRangeRequest) Reset 

func (x *RemoveRangeRequest) Reset()

func (*RemoveRangeRequest) String 

func (x *RemoveRangeRequest) String() string

type RemoveRangeResponse 

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

func (*RemoveRangeResponse) Descriptor deprecated 

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

Deprecated: Use RemoveRangeResponse.ProtoReflect.Descriptor instead.

func (*RemoveRangeResponse) ProtoMessage 

func (*RemoveRangeResponse) ProtoMessage()

func (*RemoveRangeResponse) ProtoReflect 

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

func (*RemoveRangeResponse) Reset 

func (x *RemoveRangeResponse) Reset()

func (*RemoveRangeResponse) String 

func (x *RemoveRangeResponse) String() string

type SendRequest 

type SendRequest struct {
	Envelopes *loggregator_v2.EnvelopeBatch `protobuf:"bytes,1,opt,name=envelopes,proto3" json:"envelopes,omitempty"`
	LocalOnly bool                          `protobuf:"varint,2,opt,name=local_only,json=localOnly,proto3" json:"local_only,omitempty"`
	// contains filtered or unexported fields
}

func (*SendRequest) Descriptor deprecated 

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

Deprecated: Use SendRequest.ProtoReflect.Descriptor instead.

func (*SendRequest) GetEnvelopes 

func (x *SendRequest) GetEnvelopes() *loggregator_v2.EnvelopeBatch

func (*SendRequest) GetLocalOnly 

func (x *SendRequest) GetLocalOnly() bool

func (*SendRequest) ProtoMessage 

func (*SendRequest) ProtoMessage()

func (*SendRequest) ProtoReflect 

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

func (*SendRequest) Reset 

func (x *SendRequest) Reset()

func (*SendRequest) String 

func (x *SendRequest) String() string

type SendResponse 

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

func (*SendResponse) Descriptor deprecated 

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

Deprecated: Use SendResponse.ProtoReflect.Descriptor instead.

func (*SendResponse) ProtoMessage 

func (*SendResponse) ProtoMessage()

func (*SendResponse) ProtoReflect 

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

func (*SendResponse) Reset 

func (x *SendResponse) Reset()

func (*SendResponse) String 

func (x *SendResponse) String() string

type SetRangesRequest 

type SetRangesRequest struct {

	// The key is the address of the Log Cache node.
	Ranges map[string]*Ranges `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*SetRangesRequest) Descriptor deprecated 

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

Deprecated: Use SetRangesRequest.ProtoReflect.Descriptor instead.

func (*SetRangesRequest) GetRanges 

func (x *SetRangesRequest) GetRanges() map[string]*Ranges

func (*SetRangesRequest) ProtoMessage 

func (*SetRangesRequest) ProtoMessage()

func (*SetRangesRequest) ProtoReflect 

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

func (*SetRangesRequest) Reset 

func (x *SetRangesRequest) Reset()

func (*SetRangesRequest) String 

func (x *SetRangesRequest) String() string

type SetRangesResponse 

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

func (*SetRangesResponse) Descriptor deprecated 

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

Deprecated: Use SetRangesResponse.ProtoReflect.Descriptor instead.

func (*SetRangesResponse) ProtoMessage 

func (*SetRangesResponse) ProtoMessage()

func (*SetRangesResponse) ProtoReflect 

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

func (*SetRangesResponse) Reset 

func (x *SetRangesResponse) Reset()

func (*SetRangesResponse) String 

func (x *SetRangesResponse) String() string

type UnimplementedEgressServer 

type UnimplementedEgressServer struct {
}

UnimplementedEgressServer must be embedded to have forward compatible implementations.

func (UnimplementedEgressServer) Meta 

func (UnimplementedEgressServer) Meta(context.Context, *MetaRequest) (*MetaResponse, error)

func (UnimplementedEgressServer) Read 

func (UnimplementedEgressServer) Read(context.Context, *ReadRequest) (*ReadResponse, error)

type UnimplementedIngressServer 

type UnimplementedIngressServer struct {
}

UnimplementedIngressServer must be embedded to have forward compatible implementations.

func (UnimplementedIngressServer) Send 

func (UnimplementedIngressServer) Send(context.Context, *SendRequest) (*SendResponse, error)

type UnimplementedOrchestrationServer 

type UnimplementedOrchestrationServer struct {
}

UnimplementedOrchestrationServer must be embedded to have forward compatible implementations.

func (UnimplementedOrchestrationServer) AddRange 

func (UnimplementedOrchestrationServer) AddRange(context.Context, *AddRangeRequest) (*AddRangeResponse, error)

func (UnimplementedOrchestrationServer) ListRanges 

func (UnimplementedOrchestrationServer) ListRanges(context.Context, *ListRangesRequest) (*ListRangesResponse, error)

func (UnimplementedOrchestrationServer) RemoveRange 

func (UnimplementedOrchestrationServer) RemoveRange(context.Context, *RemoveRangeRequest) (*RemoveRangeResponse, error)

func (UnimplementedOrchestrationServer) SetRanges 

func (UnimplementedOrchestrationServer) SetRanges(context.Context, *SetRangesRequest) (*SetRangesResponse, error)

type UnimplementedPromQLQuerierServer 

type UnimplementedPromQLQuerierServer struct {
}

UnimplementedPromQLQuerierServer must be embedded to have forward compatible implementations.

func (UnimplementedPromQLQuerierServer) InstantQuery 

func (UnimplementedPromQLQuerierServer) InstantQuery(context.Context, *PromQL_InstantQueryRequest) (*PromQL_InstantQueryResult, error)

func (UnimplementedPromQLQuerierServer) RangeQuery 

func (UnimplementedPromQLQuerierServer) RangeQuery(context.Context, *PromQL_RangeQueryRequest) (*PromQL_RangeQueryResult, error)

type UnsafeEgressServer 

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

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

type UnsafeIngressServer 

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

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

type UnsafeOrchestrationServer 

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

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

type UnsafePromQLQuerierServer 

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

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

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.