logcache_v1

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

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

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)
}

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

type EnvelopeType int32

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)
}

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
}

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

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

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
}

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

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

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)
}

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
}

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

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)
}

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

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
}

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
}

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

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

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

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

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
}

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
}

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
}

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

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
}

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
}

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
}

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

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
}

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

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
}

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

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

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

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
}

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

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
}

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

type UnimplementedEgressServer struct {
}

type UnimplementedIngressServer struct {
}

type UnimplementedOrchestrationServer struct {
}

type UnimplementedPromQLQuerierServer struct {
}

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

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

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

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