logcache_v1

package
v2.0.3+incompatible Latest Latest
Warning

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

 Go to latest Published: Mar 18, 2019 License: Apache-2.0 Imports: 14 Imported by: 16

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 

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

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 

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

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"`
	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) 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

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.