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",
    }
    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

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

              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 RegisterPromQLQuerierServer

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

                Types

                type AddRangeRequest

                type AddRangeRequest struct {
                	Range                *Range   `protobuf:"bytes,1,opt,name=range,proto3" json:"range,omitempty"`
                	XXX_NoUnkeyedLiteral struct{} `json:"-"`
                	XXX_unrecognized     []byte   `json:"-"`
                	XXX_sizecache        int32    `json:"-"`
                }

                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

                func (*AddRangeRequest) XXX_DiscardUnknown

                func (m *AddRangeRequest) XXX_DiscardUnknown()

                func (*AddRangeRequest) XXX_Marshal

                func (m *AddRangeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                func (*AddRangeRequest) XXX_Merge

                func (dst *AddRangeRequest) XXX_Merge(src proto.Message)

                func (*AddRangeRequest) XXX_Size

                func (m *AddRangeRequest) XXX_Size() int

                func (*AddRangeRequest) XXX_Unmarshal

                func (m *AddRangeRequest) XXX_Unmarshal(b []byte) error

                type AddRangeResponse

                type AddRangeResponse struct {
                	XXX_NoUnkeyedLiteral struct{} `json:"-"`
                	XXX_unrecognized     []byte   `json:"-"`
                	XXX_sizecache        int32    `json:"-"`
                }

                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

                func (*AddRangeResponse) XXX_DiscardUnknown

                func (m *AddRangeResponse) XXX_DiscardUnknown()

                func (*AddRangeResponse) XXX_Marshal

                func (m *AddRangeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                func (*AddRangeResponse) XXX_Merge

                func (dst *AddRangeResponse) XXX_Merge(src proto.Message)

                func (*AddRangeResponse) XXX_Size

                func (m *AddRangeResponse) XXX_Size() int

                func (*AddRangeResponse) XXX_Unmarshal

                func (m *AddRangeResponse) XXX_Unmarshal(b []byte) error

                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://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

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

                    EgressServer is the server API for Egress service.

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

                      IngressClient is the client API for Ingress service.

                      For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

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

                        IngressServer is the server API for Ingress service.

                        type ListRangesRequest

                        type ListRangesRequest struct {
                        	XXX_NoUnkeyedLiteral struct{} `json:"-"`
                        	XXX_unrecognized     []byte   `json:"-"`
                        	XXX_sizecache        int32    `json:"-"`
                        }

                        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

                        func (*ListRangesRequest) XXX_DiscardUnknown

                        func (m *ListRangesRequest) XXX_DiscardUnknown()

                        func (*ListRangesRequest) XXX_Marshal

                        func (m *ListRangesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                        func (*ListRangesRequest) XXX_Merge

                        func (dst *ListRangesRequest) XXX_Merge(src proto.Message)

                        func (*ListRangesRequest) XXX_Size

                        func (m *ListRangesRequest) XXX_Size() int

                        func (*ListRangesRequest) XXX_Unmarshal

                        func (m *ListRangesRequest) XXX_Unmarshal(b []byte) error

                        type ListRangesResponse

                        type ListRangesResponse struct {
                        	Ranges               []*Range `protobuf:"bytes,1,rep,name=ranges,proto3" json:"ranges,omitempty"`
                        	XXX_NoUnkeyedLiteral struct{} `json:"-"`
                        	XXX_unrecognized     []byte   `json:"-"`
                        	XXX_sizecache        int32    `json:"-"`
                        }

                        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

                        func (*ListRangesResponse) XXX_DiscardUnknown

                        func (m *ListRangesResponse) XXX_DiscardUnknown()

                        func (*ListRangesResponse) XXX_Marshal

                        func (m *ListRangesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                        func (*ListRangesResponse) XXX_Merge

                        func (dst *ListRangesResponse) XXX_Merge(src proto.Message)

                        func (*ListRangesResponse) XXX_Size

                        func (m *ListRangesResponse) XXX_Size() int

                        func (*ListRangesResponse) XXX_Unmarshal

                        func (m *ListRangesResponse) XXX_Unmarshal(b []byte) error

                        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"`
                        	XXX_NoUnkeyedLiteral struct{} `json:"-"`
                        	XXX_unrecognized     []byte   `json:"-"`
                        	XXX_sizecache        int32    `json:"-"`
                        }

                        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

                        func (*MetaInfo) XXX_DiscardUnknown

                        func (m *MetaInfo) XXX_DiscardUnknown()

                        func (*MetaInfo) XXX_Marshal

                        func (m *MetaInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                        func (*MetaInfo) XXX_Merge

                        func (dst *MetaInfo) XXX_Merge(src proto.Message)

                        func (*MetaInfo) XXX_Size

                        func (m *MetaInfo) XXX_Size() int

                        func (*MetaInfo) XXX_Unmarshal

                        func (m *MetaInfo) XXX_Unmarshal(b []byte) error

                        type MetaRequest

                        type MetaRequest struct {
                        	LocalOnly            bool     `protobuf:"varint,1,opt,name=local_only,json=localOnly,proto3" json:"local_only,omitempty"`
                        	XXX_NoUnkeyedLiteral struct{} `json:"-"`
                        	XXX_unrecognized     []byte   `json:"-"`
                        	XXX_sizecache        int32    `json:"-"`
                        }

                        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

                        func (*MetaRequest) XXX_DiscardUnknown

                        func (m *MetaRequest) XXX_DiscardUnknown()

                        func (*MetaRequest) XXX_Marshal

                        func (m *MetaRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                        func (*MetaRequest) XXX_Merge

                        func (dst *MetaRequest) XXX_Merge(src proto.Message)

                        func (*MetaRequest) XXX_Size

                        func (m *MetaRequest) XXX_Size() int

                        func (*MetaRequest) XXX_Unmarshal

                        func (m *MetaRequest) XXX_Unmarshal(b []byte) error

                        type MetaResponse

                        type MetaResponse struct {
                        	Meta                 map[string]*MetaInfo `` /* 149-byte string literal not displayed */
                        	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
                        	XXX_unrecognized     []byte               `json:"-"`
                        	XXX_sizecache        int32                `json:"-"`
                        }

                        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

                        func (*MetaResponse) XXX_DiscardUnknown

                        func (m *MetaResponse) XXX_DiscardUnknown()

                        func (*MetaResponse) XXX_Marshal

                        func (m *MetaResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                        func (*MetaResponse) XXX_Merge

                        func (dst *MetaResponse) XXX_Merge(src proto.Message)

                        func (*MetaResponse) XXX_Size

                        func (m *MetaResponse) XXX_Size() int

                        func (*MetaResponse) XXX_Unmarshal

                        func (m *MetaResponse) XXX_Unmarshal(b []byte) error

                        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://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

                          func NewOrchestrationClient

                          func NewOrchestrationClient(cc *grpc.ClientConn) OrchestrationClient

                          type OrchestrationServer

                            OrchestrationServer is the server API for Orchestration service.

                            type PromQL

                            type PromQL struct {
                            	XXX_NoUnkeyedLiteral struct{} `json:"-"`
                            	XXX_unrecognized     []byte   `json:"-"`
                            	XXX_sizecache        int32    `json:"-"`
                            }

                            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

                            func (*PromQL) XXX_DiscardUnknown

                            func (m *PromQL) XXX_DiscardUnknown()

                            func (*PromQL) XXX_Marshal

                            func (m *PromQL) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                            func (*PromQL) XXX_Merge

                            func (dst *PromQL) XXX_Merge(src proto.Message)

                            func (*PromQL) XXX_Size

                            func (m *PromQL) XXX_Size() int

                            func (*PromQL) XXX_Unmarshal

                            func (m *PromQL) XXX_Unmarshal(b []byte) error

                            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://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

                              func NewPromQLQuerierClient

                              func NewPromQLQuerierClient(cc *grpc.ClientConn) PromQLQuerierClient

                              type PromQLQuerierServer

                                PromQLQuerierServer is the server API for PromQLQuerier service.

                                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"`
                                	XXX_NoUnkeyedLiteral struct{} `json:"-"`
                                	XXX_unrecognized     []byte   `json:"-"`
                                	XXX_sizecache        int32    `json:"-"`
                                }

                                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

                                func (*PromQL_InstantQueryRequest) XXX_DiscardUnknown

                                func (m *PromQL_InstantQueryRequest) XXX_DiscardUnknown()

                                func (*PromQL_InstantQueryRequest) XXX_Marshal

                                func (m *PromQL_InstantQueryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                func (*PromQL_InstantQueryRequest) XXX_Merge

                                func (dst *PromQL_InstantQueryRequest) XXX_Merge(src proto.Message)

                                func (*PromQL_InstantQueryRequest) XXX_Size

                                func (m *PromQL_InstantQueryRequest) XXX_Size() int

                                func (*PromQL_InstantQueryRequest) XXX_Unmarshal

                                func (m *PromQL_InstantQueryRequest) XXX_Unmarshal(b []byte) error

                                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"`
                                	XXX_NoUnkeyedLiteral struct{}                           `json:"-"`
                                	XXX_unrecognized     []byte                             `json:"-"`
                                	XXX_sizecache        int32                              `json:"-"`
                                }

                                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_DiscardUnknown

                                func (m *PromQL_InstantQueryResult) XXX_DiscardUnknown()

                                func (*PromQL_InstantQueryResult) XXX_Marshal

                                func (m *PromQL_InstantQueryResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                func (*PromQL_InstantQueryResult) XXX_Merge

                                func (dst *PromQL_InstantQueryResult) XXX_Merge(src proto.Message)

                                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.

                                  func (*PromQL_InstantQueryResult) XXX_Size

                                  func (m *PromQL_InstantQueryResult) XXX_Size() int

                                  func (*PromQL_InstantQueryResult) XXX_Unmarshal

                                  func (m *PromQL_InstantQueryResult) XXX_Unmarshal(b []byte) error

                                  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"`
                                  	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
                                  	XXX_unrecognized     []byte           `json:"-"`
                                  	XXX_sizecache        int32            `json:"-"`
                                  }

                                  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

                                  func (*PromQL_Matrix) XXX_DiscardUnknown

                                  func (m *PromQL_Matrix) XXX_DiscardUnknown()

                                  func (*PromQL_Matrix) XXX_Marshal

                                  func (m *PromQL_Matrix) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                  func (*PromQL_Matrix) XXX_Merge

                                  func (dst *PromQL_Matrix) XXX_Merge(src proto.Message)

                                  func (*PromQL_Matrix) XXX_Size

                                  func (m *PromQL_Matrix) XXX_Size() int

                                  func (*PromQL_Matrix) XXX_Unmarshal

                                  func (m *PromQL_Matrix) XXX_Unmarshal(b []byte) error

                                  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"`
                                  	XXX_NoUnkeyedLiteral struct{} `json:"-"`
                                  	XXX_unrecognized     []byte   `json:"-"`
                                  	XXX_sizecache        int32    `json:"-"`
                                  }

                                  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

                                  func (*PromQL_Point) XXX_DiscardUnknown

                                  func (m *PromQL_Point) XXX_DiscardUnknown()

                                  func (*PromQL_Point) XXX_Marshal

                                  func (m *PromQL_Point) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                  func (*PromQL_Point) XXX_Merge

                                  func (dst *PromQL_Point) XXX_Merge(src proto.Message)

                                  func (*PromQL_Point) XXX_Size

                                  func (m *PromQL_Point) XXX_Size() int

                                  func (*PromQL_Point) XXX_Unmarshal

                                  func (m *PromQL_Point) XXX_Unmarshal(b []byte) error

                                  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"`
                                  	XXX_NoUnkeyedLiteral struct{} `json:"-"`
                                  	XXX_unrecognized     []byte   `json:"-"`
                                  	XXX_sizecache        int32    `json:"-"`
                                  }

                                  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

                                  func (*PromQL_RangeQueryRequest) XXX_DiscardUnknown

                                  func (m *PromQL_RangeQueryRequest) XXX_DiscardUnknown()

                                  func (*PromQL_RangeQueryRequest) XXX_Marshal

                                  func (m *PromQL_RangeQueryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                  func (*PromQL_RangeQueryRequest) XXX_Merge

                                  func (dst *PromQL_RangeQueryRequest) XXX_Merge(src proto.Message)

                                  func (*PromQL_RangeQueryRequest) XXX_Size

                                  func (m *PromQL_RangeQueryRequest) XXX_Size() int

                                  func (*PromQL_RangeQueryRequest) XXX_Unmarshal

                                  func (m *PromQL_RangeQueryRequest) XXX_Unmarshal(b []byte) error

                                  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"`
                                  	XXX_NoUnkeyedLiteral struct{}                         `json:"-"`
                                  	XXX_unrecognized     []byte                           `json:"-"`
                                  	XXX_sizecache        int32                            `json:"-"`
                                  }

                                  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_DiscardUnknown

                                  func (m *PromQL_RangeQueryResult) XXX_DiscardUnknown()

                                  func (*PromQL_RangeQueryResult) XXX_Marshal

                                  func (m *PromQL_RangeQueryResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                  func (*PromQL_RangeQueryResult) XXX_Merge

                                  func (dst *PromQL_RangeQueryResult) XXX_Merge(src proto.Message)

                                  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.

                                    func (*PromQL_RangeQueryResult) XXX_Size

                                    func (m *PromQL_RangeQueryResult) XXX_Size() int

                                    func (*PromQL_RangeQueryResult) XXX_Unmarshal

                                    func (m *PromQL_RangeQueryResult) XXX_Unmarshal(b []byte) error

                                    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"`
                                    	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
                                    	XXX_unrecognized     []byte            `json:"-"`
                                    	XXX_sizecache        int32             `json:"-"`
                                    }

                                    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

                                    func (*PromQL_Sample) XXX_DiscardUnknown

                                    func (m *PromQL_Sample) XXX_DiscardUnknown()

                                    func (*PromQL_Sample) XXX_Marshal

                                    func (m *PromQL_Sample) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                    func (*PromQL_Sample) XXX_Merge

                                    func (dst *PromQL_Sample) XXX_Merge(src proto.Message)

                                    func (*PromQL_Sample) XXX_Size

                                    func (m *PromQL_Sample) XXX_Size() int

                                    func (*PromQL_Sample) XXX_Unmarshal

                                    func (m *PromQL_Sample) XXX_Unmarshal(b []byte) error

                                    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"`
                                    	XXX_NoUnkeyedLiteral struct{} `json:"-"`
                                    	XXX_unrecognized     []byte   `json:"-"`
                                    	XXX_sizecache        int32    `json:"-"`
                                    }

                                    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

                                    func (*PromQL_Scalar) XXX_DiscardUnknown

                                    func (m *PromQL_Scalar) XXX_DiscardUnknown()

                                    func (*PromQL_Scalar) XXX_Marshal

                                    func (m *PromQL_Scalar) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                    func (*PromQL_Scalar) XXX_Merge

                                    func (dst *PromQL_Scalar) XXX_Merge(src proto.Message)

                                    func (*PromQL_Scalar) XXX_Size

                                    func (m *PromQL_Scalar) XXX_Size() int

                                    func (*PromQL_Scalar) XXX_Unmarshal

                                    func (m *PromQL_Scalar) XXX_Unmarshal(b []byte) error

                                    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"`
                                    	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
                                    	XXX_unrecognized     []byte            `json:"-"`
                                    	XXX_sizecache        int32             `json:"-"`
                                    }

                                    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

                                    func (*PromQL_Series) XXX_DiscardUnknown

                                    func (m *PromQL_Series) XXX_DiscardUnknown()

                                    func (*PromQL_Series) XXX_Marshal

                                    func (m *PromQL_Series) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                    func (*PromQL_Series) XXX_Merge

                                    func (dst *PromQL_Series) XXX_Merge(src proto.Message)

                                    func (*PromQL_Series) XXX_Size

                                    func (m *PromQL_Series) XXX_Size() int

                                    func (*PromQL_Series) XXX_Unmarshal

                                    func (m *PromQL_Series) XXX_Unmarshal(b []byte) error

                                    type PromQL_Vector

                                    type PromQL_Vector struct {
                                    	Samples              []*PromQL_Sample `protobuf:"bytes,1,rep,name=samples,proto3" json:"samples,omitempty"`
                                    	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
                                    	XXX_unrecognized     []byte           `json:"-"`
                                    	XXX_sizecache        int32            `json:"-"`
                                    }

                                    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

                                    func (*PromQL_Vector) XXX_DiscardUnknown

                                    func (m *PromQL_Vector) XXX_DiscardUnknown()

                                    func (*PromQL_Vector) XXX_Marshal

                                    func (m *PromQL_Vector) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                    func (*PromQL_Vector) XXX_Merge

                                    func (dst *PromQL_Vector) XXX_Merge(src proto.Message)

                                    func (*PromQL_Vector) XXX_Size

                                    func (m *PromQL_Vector) XXX_Size() int

                                    func (*PromQL_Vector) XXX_Unmarshal

                                    func (m *PromQL_Vector) XXX_Unmarshal(b []byte) error

                                    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"`
                                    	XXX_NoUnkeyedLiteral struct{} `json:"-"`
                                    	XXX_unrecognized     []byte   `json:"-"`
                                    	XXX_sizecache        int32    `json:"-"`
                                    }

                                    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

                                    func (*Range) XXX_DiscardUnknown

                                    func (m *Range) XXX_DiscardUnknown()

                                    func (*Range) XXX_Marshal

                                    func (m *Range) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                    func (*Range) XXX_Merge

                                    func (dst *Range) XXX_Merge(src proto.Message)

                                    func (*Range) XXX_Size

                                    func (m *Range) XXX_Size() int

                                    func (*Range) XXX_Unmarshal

                                    func (m *Range) XXX_Unmarshal(b []byte) error

                                    type Ranges

                                    type Ranges struct {
                                    	Ranges               []*Range `protobuf:"bytes,1,rep,name=ranges,proto3" json:"ranges,omitempty"`
                                    	XXX_NoUnkeyedLiteral struct{} `json:"-"`
                                    	XXX_unrecognized     []byte   `json:"-"`
                                    	XXX_sizecache        int32    `json:"-"`
                                    }

                                    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

                                    func (*Ranges) XXX_DiscardUnknown

                                    func (m *Ranges) XXX_DiscardUnknown()

                                    func (*Ranges) XXX_Marshal

                                    func (m *Ranges) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                    func (*Ranges) XXX_Merge

                                    func (dst *Ranges) XXX_Merge(src proto.Message)

                                    func (*Ranges) XXX_Size

                                    func (m *Ranges) XXX_Size() int

                                    func (*Ranges) XXX_Unmarshal

                                    func (m *Ranges) XXX_Unmarshal(b []byte) error

                                    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"`
                                    	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
                                    	XXX_unrecognized     []byte         `json:"-"`
                                    	XXX_sizecache        int32          `json:"-"`
                                    }

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

                                    func (m *ReadRequest) GetNameFilter() string

                                    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

                                    func (*ReadRequest) XXX_DiscardUnknown

                                    func (m *ReadRequest) XXX_DiscardUnknown()

                                    func (*ReadRequest) XXX_Marshal

                                    func (m *ReadRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                    func (*ReadRequest) XXX_Merge

                                    func (dst *ReadRequest) XXX_Merge(src proto.Message)

                                    func (*ReadRequest) XXX_Size

                                    func (m *ReadRequest) XXX_Size() int

                                    func (*ReadRequest) XXX_Unmarshal

                                    func (m *ReadRequest) XXX_Unmarshal(b []byte) error

                                    type ReadResponse

                                    type ReadResponse struct {
                                    	Envelopes            *loggregator_v2.EnvelopeBatch `protobuf:"bytes,1,opt,name=envelopes,proto3" json:"envelopes,omitempty"`
                                    	XXX_NoUnkeyedLiteral struct{}                      `json:"-"`
                                    	XXX_unrecognized     []byte                        `json:"-"`
                                    	XXX_sizecache        int32                         `json:"-"`
                                    }

                                    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

                                    func (*ReadResponse) XXX_DiscardUnknown

                                    func (m *ReadResponse) XXX_DiscardUnknown()

                                    func (*ReadResponse) XXX_Marshal

                                    func (m *ReadResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                    func (*ReadResponse) XXX_Merge

                                    func (dst *ReadResponse) XXX_Merge(src proto.Message)

                                    func (*ReadResponse) XXX_Size

                                    func (m *ReadResponse) XXX_Size() int

                                    func (*ReadResponse) XXX_Unmarshal

                                    func (m *ReadResponse) XXX_Unmarshal(b []byte) error

                                    type RemoveRangeRequest

                                    type RemoveRangeRequest struct {
                                    	Range                *Range   `protobuf:"bytes,1,opt,name=range,proto3" json:"range,omitempty"`
                                    	XXX_NoUnkeyedLiteral struct{} `json:"-"`
                                    	XXX_unrecognized     []byte   `json:"-"`
                                    	XXX_sizecache        int32    `json:"-"`
                                    }

                                    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

                                    func (*RemoveRangeRequest) XXX_DiscardUnknown

                                    func (m *RemoveRangeRequest) XXX_DiscardUnknown()

                                    func (*RemoveRangeRequest) XXX_Marshal

                                    func (m *RemoveRangeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                    func (*RemoveRangeRequest) XXX_Merge

                                    func (dst *RemoveRangeRequest) XXX_Merge(src proto.Message)

                                    func (*RemoveRangeRequest) XXX_Size

                                    func (m *RemoveRangeRequest) XXX_Size() int

                                    func (*RemoveRangeRequest) XXX_Unmarshal

                                    func (m *RemoveRangeRequest) XXX_Unmarshal(b []byte) error

                                    type RemoveRangeResponse

                                    type RemoveRangeResponse struct {
                                    	XXX_NoUnkeyedLiteral struct{} `json:"-"`
                                    	XXX_unrecognized     []byte   `json:"-"`
                                    	XXX_sizecache        int32    `json:"-"`
                                    }

                                    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

                                    func (*RemoveRangeResponse) XXX_DiscardUnknown

                                    func (m *RemoveRangeResponse) XXX_DiscardUnknown()

                                    func (*RemoveRangeResponse) XXX_Marshal

                                    func (m *RemoveRangeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                    func (*RemoveRangeResponse) XXX_Merge

                                    func (dst *RemoveRangeResponse) XXX_Merge(src proto.Message)

                                    func (*RemoveRangeResponse) XXX_Size

                                    func (m *RemoveRangeResponse) XXX_Size() int

                                    func (*RemoveRangeResponse) XXX_Unmarshal

                                    func (m *RemoveRangeResponse) XXX_Unmarshal(b []byte) error

                                    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"`
                                    	XXX_NoUnkeyedLiteral struct{}                      `json:"-"`
                                    	XXX_unrecognized     []byte                        `json:"-"`
                                    	XXX_sizecache        int32                         `json:"-"`
                                    }

                                    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

                                    func (*SendRequest) XXX_DiscardUnknown

                                    func (m *SendRequest) XXX_DiscardUnknown()

                                    func (*SendRequest) XXX_Marshal

                                    func (m *SendRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                    func (*SendRequest) XXX_Merge

                                    func (dst *SendRequest) XXX_Merge(src proto.Message)

                                    func (*SendRequest) XXX_Size

                                    func (m *SendRequest) XXX_Size() int

                                    func (*SendRequest) XXX_Unmarshal

                                    func (m *SendRequest) XXX_Unmarshal(b []byte) error

                                    type SendResponse

                                    type SendResponse struct {
                                    	XXX_NoUnkeyedLiteral struct{} `json:"-"`
                                    	XXX_unrecognized     []byte   `json:"-"`
                                    	XXX_sizecache        int32    `json:"-"`
                                    }

                                    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

                                    func (*SendResponse) XXX_DiscardUnknown

                                    func (m *SendResponse) XXX_DiscardUnknown()

                                    func (*SendResponse) XXX_Marshal

                                    func (m *SendResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                    func (*SendResponse) XXX_Merge

                                    func (dst *SendResponse) XXX_Merge(src proto.Message)

                                    func (*SendResponse) XXX_Size

                                    func (m *SendResponse) XXX_Size() int

                                    func (*SendResponse) XXX_Unmarshal

                                    func (m *SendResponse) XXX_Unmarshal(b []byte) error

                                    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 */
                                    	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
                                    	XXX_unrecognized     []byte             `json:"-"`
                                    	XXX_sizecache        int32              `json:"-"`
                                    }

                                    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

                                    func (*SetRangesRequest) XXX_DiscardUnknown

                                    func (m *SetRangesRequest) XXX_DiscardUnknown()

                                    func (*SetRangesRequest) XXX_Marshal

                                    func (m *SetRangesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                    func (*SetRangesRequest) XXX_Merge

                                    func (dst *SetRangesRequest) XXX_Merge(src proto.Message)

                                    func (*SetRangesRequest) XXX_Size

                                    func (m *SetRangesRequest) XXX_Size() int

                                    func (*SetRangesRequest) XXX_Unmarshal

                                    func (m *SetRangesRequest) XXX_Unmarshal(b []byte) error

                                    type SetRangesResponse

                                    type SetRangesResponse struct {
                                    	XXX_NoUnkeyedLiteral struct{} `json:"-"`
                                    	XXX_unrecognized     []byte   `json:"-"`
                                    	XXX_sizecache        int32    `json:"-"`
                                    }

                                    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

                                    func (*SetRangesResponse) XXX_DiscardUnknown

                                    func (m *SetRangesResponse) XXX_DiscardUnknown()

                                    func (*SetRangesResponse) XXX_Marshal

                                    func (m *SetRangesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                    func (*SetRangesResponse) XXX_Merge

                                    func (dst *SetRangesResponse) XXX_Merge(src proto.Message)

                                    func (*SetRangesResponse) XXX_Size

                                    func (m *SetRangesResponse) XXX_Size() int

                                    func (*SetRangesResponse) XXX_Unmarshal

                                    func (m *SetRangesResponse) XXX_Unmarshal(b []byte) error