logcache_v1

package
v1.0.1-0...-1693a70 Latest Latest
Warning

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

 Go to latest Published: Oct 30, 2018 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Overview

Package logcache_v1 is a generated protocol buffer package.

It is generated from these files: 

egress.proto
ingress.proto
orchestration.proto
promql.proto

It has these top-level messages: 

ReadRequest
ReadResponse
MetaRequest
MetaResponse
MetaInfo
SendRequest
SendResponse
Range
Ranges
AddRangeRequest
AddRangeResponse
RemoveRangeRequest
RemoveRangeResponse
ListRangesRequest
ListRangesResponse
SetRangesRequest
SetRangesResponse
PromQL

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",
}
View Source 
var EnvelopeType_value = map[string]int32{
	"ANY":     0,
	"LOG":     1,
	"COUNTER": 2,
	"GAUGE":   3,
	"TIMER":   4,
	"EVENT":   5,
}

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

RegisterEgressHandler 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 RegisterEgressServer 

func RegisterEgressServer(s *grpc.Server, srv EgressServer)

func RegisterIngressServer 

func RegisterIngressServer(s *grpc.Server, srv IngressServer)

func RegisterOrchestrationServer 

func RegisterOrchestrationServer(s *grpc.Server, 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

RegisterPromQLQuerierHandler 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 RegisterPromQLQuerierServer 

func RegisterPromQLQuerierServer(s *grpc.Server, srv PromQLQuerierServer)

Types

type AddRangeRequest 

type AddRangeRequest struct {
	Range *Range `protobuf:"bytes,1,opt,name=range" json:"range,omitempty"`
}

func (*AddRangeRequest) Descriptor 

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

func (*AddRangeRequest) GetRange 

func (m *AddRangeRequest) GetRange() *Range

func (*AddRangeRequest) ProtoMessage 

func (*AddRangeRequest) ProtoMessage()

func (*AddRangeRequest) Reset 

func (m *AddRangeRequest) Reset()

func (*AddRangeRequest) String 

func (m *AddRangeRequest) String() string

type AddRangeResponse 

type AddRangeResponse struct {
}

func (*AddRangeResponse) Descriptor 

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

func (*AddRangeResponse) ProtoMessage 

func (*AddRangeResponse) ProtoMessage()

func (*AddRangeResponse) Reset 

func (m *AddRangeResponse) Reset()

func (*AddRangeResponse) String 

func (m *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)
}

func NewEgressClient 

func NewEgressClient(cc *grpc.ClientConn) EgressClient

type EgressServer 

type EgressServer interface {
	Read(context.Context, *ReadRequest) (*ReadResponse, error)
	Meta(context.Context, *MetaRequest) (*MetaResponse, error)
}

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

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

func (EnvelopeType) String 

func (x EnvelopeType) String() string

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

func NewIngressClient 

func NewIngressClient(cc *grpc.ClientConn) 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)
}

type ListRangesRequest 

type ListRangesRequest struct {
}

func (*ListRangesRequest) Descriptor 

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

func (*ListRangesRequest) ProtoMessage 

func (*ListRangesRequest) ProtoMessage()

func (*ListRangesRequest) Reset 

func (m *ListRangesRequest) Reset()

func (*ListRangesRequest) String 

func (m *ListRangesRequest) String() string

type ListRangesResponse 

type ListRangesResponse struct {
	Ranges []*Range `protobuf:"bytes,1,rep,name=ranges" json:"ranges,omitempty"`
}

func (*ListRangesResponse) Descriptor 

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

func (*ListRangesResponse) GetRanges 

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

func (*ListRangesResponse) ProtoMessage 

func (*ListRangesResponse) ProtoMessage()

func (*ListRangesResponse) Reset 

func (m *ListRangesResponse) Reset()

func (*ListRangesResponse) String 

func (m *ListRangesResponse) String() string

type MetaInfo 

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

func (*MetaInfo) Descriptor 

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

func (*MetaInfo) GetCount 

func (m *MetaInfo) GetCount() int64

func (*MetaInfo) GetExpired 

func (m *MetaInfo) GetExpired() int64

func (*MetaInfo) GetNewestTimestamp 

func (m *MetaInfo) GetNewestTimestamp() int64

func (*MetaInfo) GetOldestTimestamp 

func (m *MetaInfo) GetOldestTimestamp() int64

func (*MetaInfo) ProtoMessage 

func (*MetaInfo) ProtoMessage()

func (*MetaInfo) Reset 

func (m *MetaInfo) Reset()

func (*MetaInfo) String 

func (m *MetaInfo) String() string

type MetaRequest 

type MetaRequest struct {
	LocalOnly bool `protobuf:"varint,1,opt,name=local_only,json=localOnly" json:"local_only,omitempty"`
}

func (*MetaRequest) Descriptor 

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

func (*MetaRequest) GetLocalOnly 

func (m *MetaRequest) GetLocalOnly() bool

func (*MetaRequest) ProtoMessage 

func (*MetaRequest) ProtoMessage()

func (*MetaRequest) Reset 

func (m *MetaRequest) Reset()

func (*MetaRequest) String 

func (m *MetaRequest) String() string

type MetaResponse 

type MetaResponse struct {
	Meta map[string]*MetaInfo `` /* 128-byte string literal not displayed */
}

func (*MetaResponse) Descriptor 

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

func (*MetaResponse) GetMeta 

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

func (*MetaResponse) ProtoMessage 

func (*MetaResponse) ProtoMessage()

func (*MetaResponse) Reset 

func (m *MetaResponse) Reset()

func (*MetaResponse) String 

func (m *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)
}

func NewOrchestrationClient 

func NewOrchestrationClient(cc *grpc.ClientConn) 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)
}

type PromQL 

type PromQL struct {
}

func (*PromQL) Descriptor 

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

func (*PromQL) ProtoMessage 

func (*PromQL) ProtoMessage()

func (*PromQL) Reset 

func (m *PromQL) Reset()

func (*PromQL) String 

func (m *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)
}

func NewPromQLQuerierClient 

func NewPromQLQuerierClient(cc *grpc.ClientConn) PromQLQuerierClient

type PromQLQuerierServer 

type PromQLQuerierServer interface {
	InstantQuery(context.Context, *PromQL_InstantQueryRequest) (*PromQL_InstantQueryResult, error)
	RangeQuery(context.Context, *PromQL_RangeQueryRequest) (*PromQL_RangeQueryResult, error)
}

type PromQL_InstantQueryRequest 

type PromQL_InstantQueryRequest struct {
	Query string `protobuf:"bytes,1,opt,name=query" json:"query,omitempty"`
	Time  string `protobuf:"bytes,2,opt,name=time" json:"time,omitempty"`
}

func (*PromQL_InstantQueryRequest) Descriptor 

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

func (*PromQL_InstantQueryRequest) GetQuery 

func (m *PromQL_InstantQueryRequest) GetQuery() string

func (*PromQL_InstantQueryRequest) GetTime 

func (m *PromQL_InstantQueryRequest) GetTime() string

func (*PromQL_InstantQueryRequest) ProtoMessage 

func (*PromQL_InstantQueryRequest) ProtoMessage()

func (*PromQL_InstantQueryRequest) Reset 

func (m *PromQL_InstantQueryRequest) Reset()

func (*PromQL_InstantQueryRequest) String 

func (m *PromQL_InstantQueryRequest) String() string

type PromQL_InstantQueryResult 

type PromQL_InstantQueryResult struct {
	// Types that are valid to be assigned to Result:
	//	*PromQL_InstantQueryResult_Scalar
	//	*PromQL_InstantQueryResult_Vector
	//	*PromQL_InstantQueryResult_Matrix
	Result isPromQL_InstantQueryResult_Result `protobuf_oneof:"Result"`
}

func (*PromQL_InstantQueryResult) Descriptor 

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

func (*PromQL_InstantQueryResult) GetMatrix 

func (m *PromQL_InstantQueryResult) GetMatrix() *PromQL_Matrix

func (*PromQL_InstantQueryResult) GetResult 

func (m *PromQL_InstantQueryResult) GetResult() isPromQL_InstantQueryResult_Result

func (*PromQL_InstantQueryResult) GetScalar 

func (m *PromQL_InstantQueryResult) GetScalar() *PromQL_Scalar

func (*PromQL_InstantQueryResult) GetVector 

func (m *PromQL_InstantQueryResult) GetVector() *PromQL_Vector

func (*PromQL_InstantQueryResult) ProtoMessage 

func (*PromQL_InstantQueryResult) ProtoMessage()

func (*PromQL_InstantQueryResult) Reset 

func (m *PromQL_InstantQueryResult) Reset()

func (*PromQL_InstantQueryResult) String 

func (m *PromQL_InstantQueryResult) String() string

func (*PromQL_InstantQueryResult) XXX_OneofFuncs 

func (*PromQL_InstantQueryResult) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

type PromQL_InstantQueryResult_Matrix 

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

type PromQL_InstantQueryResult_Scalar 

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

type PromQL_InstantQueryResult_Vector 

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

type PromQL_Matrix 

type PromQL_Matrix struct {
	Series []*PromQL_Series `protobuf:"bytes,1,rep,name=series" json:"series,omitempty"`
}

func (*PromQL_Matrix) Descriptor 

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

func (*PromQL_Matrix) GetSeries 

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

func (*PromQL_Matrix) ProtoMessage 

func (*PromQL_Matrix) ProtoMessage()

func (*PromQL_Matrix) Reset 

func (m *PromQL_Matrix) Reset()

func (*PromQL_Matrix) String 

func (m *PromQL_Matrix) String() string

type PromQL_Point 

type PromQL_Point struct {
	Time  string  `protobuf:"bytes,1,opt,name=time" json:"time,omitempty"`
	Value float64 `protobuf:"fixed64,2,opt,name=value" json:"value,omitempty"`
}

func (*PromQL_Point) Descriptor 

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

func (*PromQL_Point) GetTime 

func (m *PromQL_Point) GetTime() string

func (*PromQL_Point) GetValue 

func (m *PromQL_Point) GetValue() float64

func (*PromQL_Point) ProtoMessage 

func (*PromQL_Point) ProtoMessage()

func (*PromQL_Point) Reset 

func (m *PromQL_Point) Reset()

func (*PromQL_Point) String 

func (m *PromQL_Point) String() string

type PromQL_RangeQueryRequest 

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

func (*PromQL_RangeQueryRequest) Descriptor 

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

func (*PromQL_RangeQueryRequest) GetEnd 

func (m *PromQL_RangeQueryRequest) GetEnd() string

func (*PromQL_RangeQueryRequest) GetQuery 

func (m *PromQL_RangeQueryRequest) GetQuery() string

func (*PromQL_RangeQueryRequest) GetStart 

func (m *PromQL_RangeQueryRequest) GetStart() string

func (*PromQL_RangeQueryRequest) GetStep 

func (m *PromQL_RangeQueryRequest) GetStep() string

func (*PromQL_RangeQueryRequest) ProtoMessage 

func (*PromQL_RangeQueryRequest) ProtoMessage()

func (*PromQL_RangeQueryRequest) Reset 

func (m *PromQL_RangeQueryRequest) Reset()

func (*PromQL_RangeQueryRequest) String 

func (m *PromQL_RangeQueryRequest) String() string

type PromQL_RangeQueryResult 

type PromQL_RangeQueryResult struct {
	// Types that are valid to be assigned to Result:
	//	*PromQL_RangeQueryResult_Matrix
	Result isPromQL_RangeQueryResult_Result `protobuf_oneof:"Result"`
}

func (*PromQL_RangeQueryResult) Descriptor 

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

func (*PromQL_RangeQueryResult) GetMatrix 

func (m *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) Reset 

func (m *PromQL_RangeQueryResult) Reset()

func (*PromQL_RangeQueryResult) String 

func (m *PromQL_RangeQueryResult) String() string

func (*PromQL_RangeQueryResult) XXX_OneofFuncs 

func (*PromQL_RangeQueryResult) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

type PromQL_RangeQueryResult_Matrix 

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

type PromQL_Sample 

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

func (*PromQL_Sample) Descriptor 

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

func (*PromQL_Sample) GetMetric 

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

func (*PromQL_Sample) GetPoint 

func (m *PromQL_Sample) GetPoint() *PromQL_Point

func (*PromQL_Sample) ProtoMessage 

func (*PromQL_Sample) ProtoMessage()

func (*PromQL_Sample) Reset 

func (m *PromQL_Sample) Reset()

func (*PromQL_Sample) String 

func (m *PromQL_Sample) String() string

type PromQL_Scalar 

type PromQL_Scalar struct {
	Time  string  `protobuf:"bytes,1,opt,name=time" json:"time,omitempty"`
	Value float64 `protobuf:"fixed64,2,opt,name=value" json:"value,omitempty"`
}

func (*PromQL_Scalar) Descriptor 

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

func (*PromQL_Scalar) GetTime 

func (m *PromQL_Scalar) GetTime() string

func (*PromQL_Scalar) GetValue 

func (m *PromQL_Scalar) GetValue() float64

func (*PromQL_Scalar) ProtoMessage 

func (*PromQL_Scalar) ProtoMessage()

func (*PromQL_Scalar) Reset 

func (m *PromQL_Scalar) Reset()

func (*PromQL_Scalar) String 

func (m *PromQL_Scalar) String() string

type PromQL_Series 

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

func (*PromQL_Series) Descriptor 

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

func (*PromQL_Series) GetMetric 

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

func (*PromQL_Series) GetPoints 

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

func (*PromQL_Series) ProtoMessage 

func (*PromQL_Series) ProtoMessage()

func (*PromQL_Series) Reset 

func (m *PromQL_Series) Reset()

func (*PromQL_Series) String 

func (m *PromQL_Series) String() string

type PromQL_Vector 

type PromQL_Vector struct {
	Samples []*PromQL_Sample `protobuf:"bytes,1,rep,name=samples" json:"samples,omitempty"`
}

func (*PromQL_Vector) Descriptor 

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

func (*PromQL_Vector) GetSamples 

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

func (*PromQL_Vector) ProtoMessage 

func (*PromQL_Vector) ProtoMessage()

func (*PromQL_Vector) Reset 

func (m *PromQL_Vector) Reset()

func (*PromQL_Vector) String 

func (m *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" json:"start,omitempty"`
	// end is the last hash within the given range. [start..end]
	End uint64 `protobuf:"varint,2,opt,name=end" json:"end,omitempty"`
}

func (*Range) Descriptor 

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

func (*Range) GetEnd 

func (m *Range) GetEnd() uint64

func (*Range) GetStart 

func (m *Range) GetStart() uint64

func (*Range) ProtoMessage 

func (*Range) ProtoMessage()

func (*Range) Reset 

func (m *Range) Reset()

func (*Range) String 

func (m *Range) String() string

type Ranges 

type Ranges struct {
	Ranges []*Range `protobuf:"bytes,1,rep,name=ranges" json:"ranges,omitempty"`
}

func (*Ranges) Descriptor 

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

func (*Ranges) GetRanges 

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

func (*Ranges) ProtoMessage 

func (*Ranges) ProtoMessage()

func (*Ranges) Reset 

func (m *Ranges) Reset()

func (*Ranges) String 

func (m *Ranges) String() string

type ReadRequest 

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

func (*ReadRequest) Descriptor 

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

func (*ReadRequest) GetDescending 

func (m *ReadRequest) GetDescending() bool

func (*ReadRequest) GetEndTime 

func (m *ReadRequest) GetEndTime() int64

func (*ReadRequest) GetEnvelopeTypes 

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

func (*ReadRequest) GetLimit 

func (m *ReadRequest) GetLimit() int64

func (*ReadRequest) GetSourceId 

func (m *ReadRequest) GetSourceId() string

func (*ReadRequest) GetStartTime 

func (m *ReadRequest) GetStartTime() int64

func (*ReadRequest) ProtoMessage 

func (*ReadRequest) ProtoMessage()

func (*ReadRequest) Reset 

func (m *ReadRequest) Reset()

func (*ReadRequest) String 

func (m *ReadRequest) String() string

type ReadResponse 

type ReadResponse struct {
	Envelopes *loggregator_v2.EnvelopeBatch `protobuf:"bytes,1,opt,name=envelopes" json:"envelopes,omitempty"`
}

func (*ReadResponse) Descriptor 

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

func (*ReadResponse) GetEnvelopes 

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

func (*ReadResponse) ProtoMessage 

func (*ReadResponse) ProtoMessage()

func (*ReadResponse) Reset 

func (m *ReadResponse) Reset()

func (*ReadResponse) String 

func (m *ReadResponse) String() string

type RemoveRangeRequest 

type RemoveRangeRequest struct {
	Range *Range `protobuf:"bytes,1,opt,name=range" json:"range,omitempty"`
}

func (*RemoveRangeRequest) Descriptor 

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

func (*RemoveRangeRequest) GetRange 

func (m *RemoveRangeRequest) GetRange() *Range

func (*RemoveRangeRequest) ProtoMessage 

func (*RemoveRangeRequest) ProtoMessage()

func (*RemoveRangeRequest) Reset 

func (m *RemoveRangeRequest) Reset()

func (*RemoveRangeRequest) String 

func (m *RemoveRangeRequest) String() string

type RemoveRangeResponse 

type RemoveRangeResponse struct {
}

func (*RemoveRangeResponse) Descriptor 

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

func (*RemoveRangeResponse) ProtoMessage 

func (*RemoveRangeResponse) ProtoMessage()

func (*RemoveRangeResponse) Reset 

func (m *RemoveRangeResponse) Reset()

func (*RemoveRangeResponse) String 

func (m *RemoveRangeResponse) String() string

type SendRequest 

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

func (*SendRequest) Descriptor 

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

func (*SendRequest) GetEnvelopes 

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

func (*SendRequest) GetLocalOnly 

func (m *SendRequest) GetLocalOnly() bool

func (*SendRequest) ProtoMessage 

func (*SendRequest) ProtoMessage()

func (*SendRequest) Reset 

func (m *SendRequest) Reset()

func (*SendRequest) String 

func (m *SendRequest) String() string

type SendResponse 

type SendResponse struct {
}

func (*SendResponse) Descriptor 

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

func (*SendResponse) ProtoMessage 

func (*SendResponse) ProtoMessage()

func (*SendResponse) Reset 

func (m *SendResponse) Reset()

func (*SendResponse) String 

func (m *SendResponse) String() string

type SetRangesRequest 

type SetRangesRequest struct {
	// The key is the address of the Log Cache node.
	Ranges map[string]*Ranges `` /* 132-byte string literal not displayed */
}

func (*SetRangesRequest) Descriptor 

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

func (*SetRangesRequest) GetRanges 

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

func (*SetRangesRequest) ProtoMessage 

func (*SetRangesRequest) ProtoMessage()

func (*SetRangesRequest) Reset 

func (m *SetRangesRequest) Reset()

func (*SetRangesRequest) String 

func (m *SetRangesRequest) String() string

type SetRangesResponse 

type SetRangesResponse struct {
}

func (*SetRangesResponse) Descriptor 

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

func (*SetRangesResponse) ProtoMessage 

func (*SetRangesResponse) ProtoMessage()

func (*SetRangesResponse) Reset 

func (m *SetRangesResponse) Reset()

func (*SetRangesResponse) String 

func (m *SetRangesResponse) String() string

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.