logcache_v1

package
v2.3.1+incompatible Latest Latest
Warning

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

Go to latest
Published: Jul 11, 2019 License: Apache-2.0 Imports: 14 Imported by: 0

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL