grpcinterface

package
v4.15.0+incompatible Latest Latest
Warning

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

Go to latest
Published: Sep 17, 2018 License: GPL-3.0 Imports: 21 Imported by: 2

Documentation

Index

Constants

View Source
const ChangedRangeBatchSize = 1000
View Source
const LookupStreamsBatchSize = 200
View Source
const MaxInsertSize = 25000
View Source
const MaximumTime = (48 << 56)
View Source
const MinimumTime = -(16 << 56)
View Source
const RawBatchSize = 5000
View Source
const StatBatchSize = 5000

Variables

View Source
var ErrBadPW = &Status{
	Code: bte.InvalidPointWidth,
	Msg:  "Bad point width",
}
View Source
var ErrBadTimes = &Status{
	Code: bte.InvalidTimeRange,
	Msg:  "Invalid time range",
}
View Source
var ErrInsertTooBig = &Status{
	Code: bte.InsertTooBig,
	Msg:  "Insert too big",
}
View Source
var ErrNotImplemented = &Status{
	Code: bte.NotImplemented,
	Msg:  "Not implemented",
}
View Source
var GenerateCSVParams_QueryType_name = map[int32]string{
	0: "ALIGNED_WINDOWS_QUERY",
	1: "WINDOWS_QUERY",
	2: "RAW_QUERY",
}
View Source
var GenerateCSVParams_QueryType_value = map[string]int32{
	"ALIGNED_WINDOWS_QUERY": 0,
	"WINDOWS_QUERY":         1,
	"RAW_QUERY":             2,
}

Functions

func RegisterBTrDBServer

func RegisterBTrDBServer(s *grpc.Server, srv BTrDBServer)

Types

type AlignedWindowsParams

type AlignedWindowsParams struct {
	Uuid                 []byte   `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	Start                int64    `protobuf:"fixed64,2,opt,name=start" json:"start,omitempty"`
	End                  int64    `protobuf:"fixed64,3,opt,name=end" json:"end,omitempty"`
	VersionMajor         uint64   `protobuf:"varint,4,opt,name=versionMajor" json:"versionMajor,omitempty"`
	PointWidth           uint32   `protobuf:"varint,5,opt,name=pointWidth" json:"pointWidth,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AlignedWindowsParams) Descriptor

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

func (*AlignedWindowsParams) GetEnd

func (m *AlignedWindowsParams) GetEnd() int64

func (*AlignedWindowsParams) GetPointWidth

func (m *AlignedWindowsParams) GetPointWidth() uint32

func (*AlignedWindowsParams) GetStart

func (m *AlignedWindowsParams) GetStart() int64

func (*AlignedWindowsParams) GetUuid

func (m *AlignedWindowsParams) GetUuid() []byte

func (*AlignedWindowsParams) GetVersionMajor

func (m *AlignedWindowsParams) GetVersionMajor() uint64

func (*AlignedWindowsParams) ProtoMessage

func (*AlignedWindowsParams) ProtoMessage()

func (*AlignedWindowsParams) Reset

func (m *AlignedWindowsParams) Reset()

func (*AlignedWindowsParams) String

func (m *AlignedWindowsParams) String() string

func (*AlignedWindowsParams) XXX_DiscardUnknown

func (m *AlignedWindowsParams) XXX_DiscardUnknown()

func (*AlignedWindowsParams) XXX_Marshal

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

func (*AlignedWindowsParams) XXX_Merge

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

func (*AlignedWindowsParams) XXX_Size

func (m *AlignedWindowsParams) XXX_Size() int

func (*AlignedWindowsParams) XXX_Unmarshal

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

type AlignedWindowsResponse

type AlignedWindowsResponse struct {
	Stat                 *Status      `protobuf:"bytes,1,opt,name=stat" json:"stat,omitempty"`
	VersionMajor         uint64       `protobuf:"varint,2,opt,name=versionMajor" json:"versionMajor,omitempty"`
	VersionMinor         uint64       `protobuf:"varint,3,opt,name=versionMinor" json:"versionMinor,omitempty"`
	Values               []*StatPoint `protobuf:"bytes,4,rep,name=values" json:"values,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*AlignedWindowsResponse) Descriptor

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

func (*AlignedWindowsResponse) GetStat

func (m *AlignedWindowsResponse) GetStat() *Status

func (*AlignedWindowsResponse) GetValues

func (m *AlignedWindowsResponse) GetValues() []*StatPoint

func (*AlignedWindowsResponse) GetVersionMajor

func (m *AlignedWindowsResponse) GetVersionMajor() uint64

func (*AlignedWindowsResponse) GetVersionMinor

func (m *AlignedWindowsResponse) GetVersionMinor() uint64

func (*AlignedWindowsResponse) ProtoMessage

func (*AlignedWindowsResponse) ProtoMessage()

func (*AlignedWindowsResponse) Reset

func (m *AlignedWindowsResponse) Reset()

func (*AlignedWindowsResponse) String

func (m *AlignedWindowsResponse) String() string

func (*AlignedWindowsResponse) XXX_DiscardUnknown

func (m *AlignedWindowsResponse) XXX_DiscardUnknown()

func (*AlignedWindowsResponse) XXX_Marshal

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

func (*AlignedWindowsResponse) XXX_Merge

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

func (*AlignedWindowsResponse) XXX_Size

func (m *AlignedWindowsResponse) XXX_Size() int

func (*AlignedWindowsResponse) XXX_Unmarshal

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

type BTrDBClient

type BTrDBClient interface {
	RawValues(ctx context.Context, in *RawValuesParams, opts ...grpc.CallOption) (BTrDB_RawValuesClient, error)
	AlignedWindows(ctx context.Context, in *AlignedWindowsParams, opts ...grpc.CallOption) (BTrDB_AlignedWindowsClient, error)
	Windows(ctx context.Context, in *WindowsParams, opts ...grpc.CallOption) (BTrDB_WindowsClient, error)
	StreamInfo(ctx context.Context, in *StreamInfoParams, opts ...grpc.CallOption) (*StreamInfoResponse, error)
	SetStreamAnnotations(ctx context.Context, in *SetStreamAnnotationsParams, opts ...grpc.CallOption) (*SetStreamAnnotationsResponse, error)
	Create(ctx context.Context, in *CreateParams, opts ...grpc.CallOption) (*CreateResponse, error)
	ListCollections(ctx context.Context, in *ListCollectionsParams, opts ...grpc.CallOption) (*ListCollectionsResponse, error)
	LookupStreams(ctx context.Context, in *LookupStreamsParams, opts ...grpc.CallOption) (BTrDB_LookupStreamsClient, error)
	Nearest(ctx context.Context, in *NearestParams, opts ...grpc.CallOption) (*NearestResponse, error)
	Changes(ctx context.Context, in *ChangesParams, opts ...grpc.CallOption) (BTrDB_ChangesClient, error)
	Insert(ctx context.Context, in *InsertParams, opts ...grpc.CallOption) (*InsertResponse, error)
	Delete(ctx context.Context, in *DeleteParams, opts ...grpc.CallOption) (*DeleteResponse, error)
	Info(ctx context.Context, in *InfoParams, opts ...grpc.CallOption) (*InfoResponse, error)
	FaultInject(ctx context.Context, in *FaultInjectParams, opts ...grpc.CallOption) (*FaultInjectResponse, error)
	Flush(ctx context.Context, in *FlushParams, opts ...grpc.CallOption) (*FlushResponse, error)
	Obliterate(ctx context.Context, in *ObliterateParams, opts ...grpc.CallOption) (*ObliterateResponse, error)
	GetMetadataUsage(ctx context.Context, in *MetadataUsageParams, opts ...grpc.CallOption) (*MetadataUsageResponse, error)
	GenerateCSV(ctx context.Context, in *GenerateCSVParams, opts ...grpc.CallOption) (BTrDB_GenerateCSVClient, error)
}

BTrDBClient is the client API for BTrDB service.

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

func NewBTrDBClient

func NewBTrDBClient(cc *grpc.ClientConn) BTrDBClient

type BTrDB_AlignedWindowsClient

type BTrDB_AlignedWindowsClient interface {
	Recv() (*AlignedWindowsResponse, error)
	grpc.ClientStream
}

type BTrDB_AlignedWindowsServer

type BTrDB_AlignedWindowsServer interface {
	Send(*AlignedWindowsResponse) error
	grpc.ServerStream
}

type BTrDB_ChangesClient

type BTrDB_ChangesClient interface {
	Recv() (*ChangesResponse, error)
	grpc.ClientStream
}

type BTrDB_ChangesServer

type BTrDB_ChangesServer interface {
	Send(*ChangesResponse) error
	grpc.ServerStream
}

type BTrDB_GenerateCSVClient

type BTrDB_GenerateCSVClient interface {
	Recv() (*GenerateCSVResponse, error)
	grpc.ClientStream
}

type BTrDB_GenerateCSVServer

type BTrDB_GenerateCSVServer interface {
	Send(*GenerateCSVResponse) error
	grpc.ServerStream
}

type BTrDB_LookupStreamsClient

type BTrDB_LookupStreamsClient interface {
	Recv() (*LookupStreamsResponse, error)
	grpc.ClientStream
}

type BTrDB_LookupStreamsServer

type BTrDB_LookupStreamsServer interface {
	Send(*LookupStreamsResponse) error
	grpc.ServerStream
}

type BTrDB_RawValuesClient

type BTrDB_RawValuesClient interface {
	Recv() (*RawValuesResponse, error)
	grpc.ClientStream
}

type BTrDB_RawValuesServer

type BTrDB_RawValuesServer interface {
	Send(*RawValuesResponse) error
	grpc.ServerStream
}

type BTrDB_WindowsClient

type BTrDB_WindowsClient interface {
	Recv() (*WindowsResponse, error)
	grpc.ClientStream
}

type BTrDB_WindowsServer

type BTrDB_WindowsServer interface {
	Send(*WindowsResponse) error
	grpc.ServerStream
}

type ChangedRange

type ChangedRange struct {
	Start                int64    `protobuf:"fixed64,1,opt,name=start" json:"start,omitempty"`
	End                  int64    `protobuf:"fixed64,2,opt,name=end" json:"end,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ChangedRange) Descriptor

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

func (*ChangedRange) GetEnd

func (m *ChangedRange) GetEnd() int64

func (*ChangedRange) GetStart

func (m *ChangedRange) GetStart() int64

func (*ChangedRange) ProtoMessage

func (*ChangedRange) ProtoMessage()

func (*ChangedRange) Reset

func (m *ChangedRange) Reset()

func (*ChangedRange) String

func (m *ChangedRange) String() string

func (*ChangedRange) XXX_DiscardUnknown

func (m *ChangedRange) XXX_DiscardUnknown()

func (*ChangedRange) XXX_Marshal

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

func (*ChangedRange) XXX_Merge

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

func (*ChangedRange) XXX_Size

func (m *ChangedRange) XXX_Size() int

func (*ChangedRange) XXX_Unmarshal

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

type ChangesParams

type ChangesParams struct {
	Uuid                 []byte   `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	FromMajor            uint64   `protobuf:"varint,2,opt,name=fromMajor" json:"fromMajor,omitempty"`
	ToMajor              uint64   `protobuf:"varint,3,opt,name=toMajor" json:"toMajor,omitempty"`
	Resolution           uint32   `protobuf:"varint,4,opt,name=resolution" json:"resolution,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ChangesParams) Descriptor

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

func (*ChangesParams) GetFromMajor

func (m *ChangesParams) GetFromMajor() uint64

func (*ChangesParams) GetResolution

func (m *ChangesParams) GetResolution() uint32

func (*ChangesParams) GetToMajor

func (m *ChangesParams) GetToMajor() uint64

func (*ChangesParams) GetUuid

func (m *ChangesParams) GetUuid() []byte

func (*ChangesParams) ProtoMessage

func (*ChangesParams) ProtoMessage()

func (*ChangesParams) Reset

func (m *ChangesParams) Reset()

func (*ChangesParams) String

func (m *ChangesParams) String() string

func (*ChangesParams) XXX_DiscardUnknown

func (m *ChangesParams) XXX_DiscardUnknown()

func (*ChangesParams) XXX_Marshal

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

func (*ChangesParams) XXX_Merge

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

func (*ChangesParams) XXX_Size

func (m *ChangesParams) XXX_Size() int

func (*ChangesParams) XXX_Unmarshal

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

type ChangesResponse

type ChangesResponse struct {
	Stat                 *Status         `protobuf:"bytes,1,opt,name=stat" json:"stat,omitempty"`
	VersionMajor         uint64          `protobuf:"varint,2,opt,name=versionMajor" json:"versionMajor,omitempty"`
	VersionMinor         uint64          `protobuf:"varint,3,opt,name=versionMinor" json:"versionMinor,omitempty"`
	Ranges               []*ChangedRange `protobuf:"bytes,4,rep,name=ranges" json:"ranges,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*ChangesResponse) Descriptor

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

func (*ChangesResponse) GetRanges

func (m *ChangesResponse) GetRanges() []*ChangedRange

func (*ChangesResponse) GetStat

func (m *ChangesResponse) GetStat() *Status

func (*ChangesResponse) GetVersionMajor

func (m *ChangesResponse) GetVersionMajor() uint64

func (*ChangesResponse) GetVersionMinor

func (m *ChangesResponse) GetVersionMinor() uint64

func (*ChangesResponse) ProtoMessage

func (*ChangesResponse) ProtoMessage()

func (*ChangesResponse) Reset

func (m *ChangesResponse) Reset()

func (*ChangesResponse) String

func (m *ChangesResponse) String() string

func (*ChangesResponse) XXX_DiscardUnknown

func (m *ChangesResponse) XXX_DiscardUnknown()

func (*ChangesResponse) XXX_Marshal

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

func (*ChangesResponse) XXX_Merge

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

func (*ChangesResponse) XXX_Size

func (m *ChangesResponse) XXX_Size() int

func (*ChangesResponse) XXX_Unmarshal

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

type CreateParams

type CreateParams struct {
	Uuid                 []byte      `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	Collection           string      `protobuf:"bytes,2,opt,name=collection" json:"collection,omitempty"`
	Tags                 []*KeyValue `protobuf:"bytes,3,rep,name=tags" json:"tags,omitempty"`
	Annotations          []*KeyValue `protobuf:"bytes,4,rep,name=annotations" json:"annotations,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*CreateParams) Descriptor

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

func (*CreateParams) GetAnnotations

func (m *CreateParams) GetAnnotations() []*KeyValue

func (*CreateParams) GetCollection

func (m *CreateParams) GetCollection() string

func (*CreateParams) GetTags

func (m *CreateParams) GetTags() []*KeyValue

func (*CreateParams) GetUuid

func (m *CreateParams) GetUuid() []byte

func (*CreateParams) ProtoMessage

func (*CreateParams) ProtoMessage()

func (*CreateParams) Reset

func (m *CreateParams) Reset()

func (*CreateParams) String

func (m *CreateParams) String() string

func (*CreateParams) XXX_DiscardUnknown

func (m *CreateParams) XXX_DiscardUnknown()

func (*CreateParams) XXX_Marshal

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

func (*CreateParams) XXX_Merge

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

func (*CreateParams) XXX_Size

func (m *CreateParams) XXX_Size() int

func (*CreateParams) XXX_Unmarshal

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

type CreateResponse

type CreateResponse struct {
	Stat                 *Status  `protobuf:"bytes,1,opt,name=stat" json:"stat,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateResponse) Descriptor

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

func (*CreateResponse) GetStat

func (m *CreateResponse) GetStat() *Status

func (*CreateResponse) ProtoMessage

func (*CreateResponse) ProtoMessage()

func (*CreateResponse) Reset

func (m *CreateResponse) Reset()

func (*CreateResponse) String

func (m *CreateResponse) String() string

func (*CreateResponse) XXX_DiscardUnknown

func (m *CreateResponse) XXX_DiscardUnknown()

func (*CreateResponse) XXX_Marshal

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

func (*CreateResponse) XXX_Merge

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

func (*CreateResponse) XXX_Size

func (m *CreateResponse) XXX_Size() int

func (*CreateResponse) XXX_Unmarshal

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

type DeleteParams

type DeleteParams struct {
	Uuid                 []byte   `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	Start                int64    `protobuf:"fixed64,2,opt,name=start" json:"start,omitempty"`
	End                  int64    `protobuf:"fixed64,3,opt,name=end" json:"end,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteParams) Descriptor

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

func (*DeleteParams) GetEnd

func (m *DeleteParams) GetEnd() int64

func (*DeleteParams) GetStart

func (m *DeleteParams) GetStart() int64

func (*DeleteParams) GetUuid

func (m *DeleteParams) GetUuid() []byte

func (*DeleteParams) ProtoMessage

func (*DeleteParams) ProtoMessage()

func (*DeleteParams) Reset

func (m *DeleteParams) Reset()

func (*DeleteParams) String

func (m *DeleteParams) String() string

func (*DeleteParams) XXX_DiscardUnknown

func (m *DeleteParams) XXX_DiscardUnknown()

func (*DeleteParams) XXX_Marshal

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

func (*DeleteParams) XXX_Merge

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

func (*DeleteParams) XXX_Size

func (m *DeleteParams) XXX_Size() int

func (*DeleteParams) XXX_Unmarshal

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

type DeleteResponse

type DeleteResponse struct {
	Stat                 *Status  `protobuf:"bytes,1,opt,name=stat" json:"stat,omitempty"`
	VersionMajor         uint64   `protobuf:"varint,2,opt,name=versionMajor" json:"versionMajor,omitempty"`
	VersionMinor         uint64   `protobuf:"varint,3,opt,name=versionMinor" json:"versionMinor,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteResponse) Descriptor

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

func (*DeleteResponse) GetStat

func (m *DeleteResponse) GetStat() *Status

func (*DeleteResponse) GetVersionMajor

func (m *DeleteResponse) GetVersionMajor() uint64

func (*DeleteResponse) GetVersionMinor

func (m *DeleteResponse) GetVersionMinor() uint64

func (*DeleteResponse) ProtoMessage

func (*DeleteResponse) ProtoMessage()

func (*DeleteResponse) Reset

func (m *DeleteResponse) Reset()

func (*DeleteResponse) String

func (m *DeleteResponse) String() string

func (*DeleteResponse) XXX_DiscardUnknown

func (m *DeleteResponse) XXX_DiscardUnknown()

func (*DeleteResponse) XXX_Marshal

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

func (*DeleteResponse) XXX_Merge

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

func (*DeleteResponse) XXX_Size

func (m *DeleteResponse) XXX_Size() int

func (*DeleteResponse) XXX_Unmarshal

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

type FaultInjectParams

type FaultInjectParams struct {
	Type                 uint64   `protobuf:"varint,1,opt,name=type" json:"type,omitempty"`
	Params               []byte   `protobuf:"bytes,2,opt,name=params,proto3" json:"params,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FaultInjectParams) Descriptor

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

func (*FaultInjectParams) GetParams

func (m *FaultInjectParams) GetParams() []byte

func (*FaultInjectParams) GetType

func (m *FaultInjectParams) GetType() uint64

func (*FaultInjectParams) ProtoMessage

func (*FaultInjectParams) ProtoMessage()

func (*FaultInjectParams) Reset

func (m *FaultInjectParams) Reset()

func (*FaultInjectParams) String

func (m *FaultInjectParams) String() string

func (*FaultInjectParams) XXX_DiscardUnknown

func (m *FaultInjectParams) XXX_DiscardUnknown()

func (*FaultInjectParams) XXX_Marshal

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

func (*FaultInjectParams) XXX_Merge

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

func (*FaultInjectParams) XXX_Size

func (m *FaultInjectParams) XXX_Size() int

func (*FaultInjectParams) XXX_Unmarshal

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

type FaultInjectResponse

type FaultInjectResponse struct {
	Stat                 *Status  `protobuf:"bytes,1,opt,name=stat" json:"stat,omitempty"`
	Rv                   []byte   `protobuf:"bytes,2,opt,name=rv,proto3" json:"rv,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FaultInjectResponse) Descriptor

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

func (*FaultInjectResponse) GetRv

func (m *FaultInjectResponse) GetRv() []byte

func (*FaultInjectResponse) GetStat

func (m *FaultInjectResponse) GetStat() *Status

func (*FaultInjectResponse) ProtoMessage

func (*FaultInjectResponse) ProtoMessage()

func (*FaultInjectResponse) Reset

func (m *FaultInjectResponse) Reset()

func (*FaultInjectResponse) String

func (m *FaultInjectResponse) String() string

func (*FaultInjectResponse) XXX_DiscardUnknown

func (m *FaultInjectResponse) XXX_DiscardUnknown()

func (*FaultInjectResponse) XXX_Marshal

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

func (*FaultInjectResponse) XXX_Merge

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

func (*FaultInjectResponse) XXX_Size

func (m *FaultInjectResponse) XXX_Size() int

func (*FaultInjectResponse) XXX_Unmarshal

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

type FlushParams

type FlushParams struct {
	Uuid                 []byte   `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FlushParams) Descriptor

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

func (*FlushParams) GetUuid

func (m *FlushParams) GetUuid() []byte

func (*FlushParams) ProtoMessage

func (*FlushParams) ProtoMessage()

func (*FlushParams) Reset

func (m *FlushParams) Reset()

func (*FlushParams) String

func (m *FlushParams) String() string

func (*FlushParams) XXX_DiscardUnknown

func (m *FlushParams) XXX_DiscardUnknown()

func (*FlushParams) XXX_Marshal

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

func (*FlushParams) XXX_Merge

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

func (*FlushParams) XXX_Size

func (m *FlushParams) XXX_Size() int

func (*FlushParams) XXX_Unmarshal

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

type FlushResponse

type FlushResponse struct {
	Stat                 *Status  `protobuf:"bytes,1,opt,name=stat" json:"stat,omitempty"`
	VersionMajor         uint64   `protobuf:"varint,2,opt,name=versionMajor" json:"versionMajor,omitempty"`
	VersionMinor         uint64   `protobuf:"varint,3,opt,name=versionMinor" json:"versionMinor,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FlushResponse) Descriptor

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

func (*FlushResponse) GetStat

func (m *FlushResponse) GetStat() *Status

func (*FlushResponse) GetVersionMajor

func (m *FlushResponse) GetVersionMajor() uint64

func (*FlushResponse) GetVersionMinor

func (m *FlushResponse) GetVersionMinor() uint64

func (*FlushResponse) ProtoMessage

func (*FlushResponse) ProtoMessage()

func (*FlushResponse) Reset

func (m *FlushResponse) Reset()

func (*FlushResponse) String

func (m *FlushResponse) String() string

func (*FlushResponse) XXX_DiscardUnknown

func (m *FlushResponse) XXX_DiscardUnknown()

func (*FlushResponse) XXX_Marshal

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

func (*FlushResponse) XXX_Merge

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

func (*FlushResponse) XXX_Size

func (m *FlushResponse) XXX_Size() int

func (*FlushResponse) XXX_Unmarshal

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

type GRPCInterface

type GRPCInterface interface {
	InitiateShutdown() chan struct{}
}

func ServeGRPC

func ServeGRPC(q *btrdb.Quasar, laddr string) GRPCInterface

type GenerateCSVParams

type GenerateCSVParams struct {
	QueryType            GenerateCSVParams_QueryType `protobuf:"varint,1,opt,name=queryType,enum=grpcinterface.GenerateCSVParams_QueryType" json:"queryType,omitempty"`
	StartTime            int64                       `protobuf:"varint,2,opt,name=startTime" json:"startTime,omitempty"`
	EndTime              int64                       `protobuf:"varint,3,opt,name=endTime" json:"endTime,omitempty"`
	WindowSize           uint64                      `protobuf:"varint,4,opt,name=windowSize" json:"windowSize,omitempty"`
	Depth                uint32                      `protobuf:"varint,5,opt,name=depth" json:"depth,omitempty"`
	IncludeVersions      bool                        `protobuf:"varint,6,opt,name=includeVersions" json:"includeVersions,omitempty"`
	Streams              []*StreamCSVConfig          `protobuf:"bytes,7,rep,name=streams" json:"streams,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

func (*GenerateCSVParams) Descriptor

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

func (*GenerateCSVParams) GetDepth

func (m *GenerateCSVParams) GetDepth() uint32

func (*GenerateCSVParams) GetEndTime

func (m *GenerateCSVParams) GetEndTime() int64

func (*GenerateCSVParams) GetIncludeVersions

func (m *GenerateCSVParams) GetIncludeVersions() bool

func (*GenerateCSVParams) GetQueryType

func (*GenerateCSVParams) GetStartTime

func (m *GenerateCSVParams) GetStartTime() int64

func (*GenerateCSVParams) GetStreams

func (m *GenerateCSVParams) GetStreams() []*StreamCSVConfig

func (*GenerateCSVParams) GetWindowSize

func (m *GenerateCSVParams) GetWindowSize() uint64

func (*GenerateCSVParams) ProtoMessage

func (*GenerateCSVParams) ProtoMessage()

func (*GenerateCSVParams) Reset

func (m *GenerateCSVParams) Reset()

func (*GenerateCSVParams) String

func (m *GenerateCSVParams) String() string

func (*GenerateCSVParams) XXX_DiscardUnknown

func (m *GenerateCSVParams) XXX_DiscardUnknown()

func (*GenerateCSVParams) XXX_Marshal

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

func (*GenerateCSVParams) XXX_Merge

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

func (*GenerateCSVParams) XXX_Size

func (m *GenerateCSVParams) XXX_Size() int

func (*GenerateCSVParams) XXX_Unmarshal

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

type GenerateCSVParams_QueryType

type GenerateCSVParams_QueryType int32
const (
	GenerateCSVParams_ALIGNED_WINDOWS_QUERY GenerateCSVParams_QueryType = 0
	GenerateCSVParams_WINDOWS_QUERY         GenerateCSVParams_QueryType = 1
	GenerateCSVParams_RAW_QUERY             GenerateCSVParams_QueryType = 2
)

func (GenerateCSVParams_QueryType) EnumDescriptor

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

func (GenerateCSVParams_QueryType) String

type GenerateCSVResponse

type GenerateCSVResponse struct {
	Stat                 *Status  `protobuf:"bytes,1,opt,name=stat" json:"stat,omitempty"`
	IsHeader             bool     `protobuf:"varint,2,opt,name=isHeader" json:"isHeader,omitempty"`
	Row                  []string `protobuf:"bytes,3,rep,name=row" json:"row,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GenerateCSVResponse) Descriptor

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

func (*GenerateCSVResponse) GetIsHeader

func (m *GenerateCSVResponse) GetIsHeader() bool

func (*GenerateCSVResponse) GetRow

func (m *GenerateCSVResponse) GetRow() []string

func (*GenerateCSVResponse) GetStat

func (m *GenerateCSVResponse) GetStat() *Status

func (*GenerateCSVResponse) ProtoMessage

func (*GenerateCSVResponse) ProtoMessage()

func (*GenerateCSVResponse) Reset

func (m *GenerateCSVResponse) Reset()

func (*GenerateCSVResponse) String

func (m *GenerateCSVResponse) String() string

func (*GenerateCSVResponse) XXX_DiscardUnknown

func (m *GenerateCSVResponse) XXX_DiscardUnknown()

func (*GenerateCSVResponse) XXX_Marshal

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

func (*GenerateCSVResponse) XXX_Merge

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

func (*GenerateCSVResponse) XXX_Size

func (m *GenerateCSVResponse) XXX_Size() int

func (*GenerateCSVResponse) XXX_Unmarshal

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

type InfoParams

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

func (*InfoParams) Descriptor

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

func (*InfoParams) ProtoMessage

func (*InfoParams) ProtoMessage()

func (*InfoParams) Reset

func (m *InfoParams) Reset()

func (*InfoParams) String

func (m *InfoParams) String() string

func (*InfoParams) XXX_DiscardUnknown

func (m *InfoParams) XXX_DiscardUnknown()

func (*InfoParams) XXX_Marshal

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

func (*InfoParams) XXX_Merge

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

func (*InfoParams) XXX_Size

func (m *InfoParams) XXX_Size() int

func (*InfoParams) XXX_Unmarshal

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

type InfoResponse

type InfoResponse struct {
	Stat                 *Status    `protobuf:"bytes,1,opt,name=stat" json:"stat,omitempty"`
	Mash                 *Mash      `protobuf:"bytes,2,opt,name=mash" json:"mash,omitempty"`
	MajorVersion         uint32     `protobuf:"varint,3,opt,name=majorVersion" json:"majorVersion,omitempty"`
	MinorVersion         uint32     `protobuf:"varint,4,opt,name=minorVersion" json:"minorVersion,omitempty"`
	Build                string     `protobuf:"bytes,5,opt,name=build" json:"build,omitempty"`
	Proxy                *ProxyInfo `protobuf:"bytes,6,opt,name=proxy" json:"proxy,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*InfoResponse) Descriptor

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

func (*InfoResponse) GetBuild

func (m *InfoResponse) GetBuild() string

func (*InfoResponse) GetMajorVersion

func (m *InfoResponse) GetMajorVersion() uint32

func (*InfoResponse) GetMash

func (m *InfoResponse) GetMash() *Mash

func (*InfoResponse) GetMinorVersion

func (m *InfoResponse) GetMinorVersion() uint32

func (*InfoResponse) GetProxy

func (m *InfoResponse) GetProxy() *ProxyInfo

func (*InfoResponse) GetStat

func (m *InfoResponse) GetStat() *Status

func (*InfoResponse) ProtoMessage

func (*InfoResponse) ProtoMessage()

func (*InfoResponse) Reset

func (m *InfoResponse) Reset()

func (*InfoResponse) String

func (m *InfoResponse) String() string

func (*InfoResponse) XXX_DiscardUnknown

func (m *InfoResponse) XXX_DiscardUnknown()

func (*InfoResponse) XXX_Marshal

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

func (*InfoResponse) XXX_Merge

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

func (*InfoResponse) XXX_Size

func (m *InfoResponse) XXX_Size() int

func (*InfoResponse) XXX_Unmarshal

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

type InsertParams

type InsertParams struct {
	Uuid                 []byte      `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	Sync                 bool        `protobuf:"varint,2,opt,name=sync" json:"sync,omitempty"`
	Values               []*RawPoint `protobuf:"bytes,3,rep,name=values" json:"values,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*InsertParams) Descriptor

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

func (*InsertParams) GetSync

func (m *InsertParams) GetSync() bool

func (*InsertParams) GetUuid

func (m *InsertParams) GetUuid() []byte

func (*InsertParams) GetValues

func (m *InsertParams) GetValues() []*RawPoint

func (*InsertParams) ProtoMessage

func (*InsertParams) ProtoMessage()

func (*InsertParams) Reset

func (m *InsertParams) Reset()

func (*InsertParams) String

func (m *InsertParams) String() string

func (*InsertParams) XXX_DiscardUnknown

func (m *InsertParams) XXX_DiscardUnknown()

func (*InsertParams) XXX_Marshal

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

func (*InsertParams) XXX_Merge

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

func (*InsertParams) XXX_Size

func (m *InsertParams) XXX_Size() int

func (*InsertParams) XXX_Unmarshal

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

type InsertResponse

type InsertResponse struct {
	Stat                 *Status  `protobuf:"bytes,1,opt,name=stat" json:"stat,omitempty"`
	VersionMajor         uint64   `protobuf:"varint,2,opt,name=versionMajor" json:"versionMajor,omitempty"`
	VersionMinor         uint64   `protobuf:"varint,3,opt,name=versionMinor" json:"versionMinor,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*InsertResponse) Descriptor

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

func (*InsertResponse) GetStat

func (m *InsertResponse) GetStat() *Status

func (*InsertResponse) GetVersionMajor

func (m *InsertResponse) GetVersionMajor() uint64

func (*InsertResponse) GetVersionMinor

func (m *InsertResponse) GetVersionMinor() uint64

func (*InsertResponse) ProtoMessage

func (*InsertResponse) ProtoMessage()

func (*InsertResponse) Reset

func (m *InsertResponse) Reset()

func (*InsertResponse) String

func (m *InsertResponse) String() string

func (*InsertResponse) XXX_DiscardUnknown

func (m *InsertResponse) XXX_DiscardUnknown()

func (*InsertResponse) XXX_Marshal

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

func (*InsertResponse) XXX_Merge

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

func (*InsertResponse) XXX_Size

func (m *InsertResponse) XXX_Size() int

func (*InsertResponse) XXX_Unmarshal

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

type KeyCount

type KeyCount struct {
	Key                  string   `protobuf:"bytes,1,opt,name=key" json:"key,omitempty"`
	Count                uint64   `protobuf:"varint,2,opt,name=count" json:"count,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*KeyCount) Descriptor

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

func (*KeyCount) GetCount

func (m *KeyCount) GetCount() uint64

func (*KeyCount) GetKey

func (m *KeyCount) GetKey() string

func (*KeyCount) ProtoMessage

func (*KeyCount) ProtoMessage()

func (*KeyCount) Reset

func (m *KeyCount) Reset()

func (*KeyCount) String

func (m *KeyCount) String() string

func (*KeyCount) XXX_DiscardUnknown

func (m *KeyCount) XXX_DiscardUnknown()

func (*KeyCount) XXX_Marshal

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

func (*KeyCount) XXX_Merge

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

func (*KeyCount) XXX_Size

func (m *KeyCount) XXX_Size() int

func (*KeyCount) XXX_Unmarshal

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

type KeyOptValue

type KeyOptValue struct {
	Key                  string    `protobuf:"bytes,1,opt,name=key" json:"key,omitempty"`
	Val                  *OptValue `protobuf:"bytes,2,opt,name=val" json:"val,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*KeyOptValue) Descriptor

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

func (*KeyOptValue) GetKey

func (m *KeyOptValue) GetKey() string

func (*KeyOptValue) GetVal

func (m *KeyOptValue) GetVal() *OptValue

func (*KeyOptValue) ProtoMessage

func (*KeyOptValue) ProtoMessage()

func (*KeyOptValue) Reset

func (m *KeyOptValue) Reset()

func (*KeyOptValue) String

func (m *KeyOptValue) String() string

func (*KeyOptValue) XXX_DiscardUnknown

func (m *KeyOptValue) XXX_DiscardUnknown()

func (*KeyOptValue) XXX_Marshal

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

func (*KeyOptValue) XXX_Merge

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

func (*KeyOptValue) XXX_Size

func (m *KeyOptValue) XXX_Size() int

func (*KeyOptValue) XXX_Unmarshal

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

type KeyValue

type KeyValue struct {
	Key                  string   `protobuf:"bytes,1,opt,name=key" json:"key,omitempty"`
	Value                []byte   `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*KeyValue) Descriptor

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

func (*KeyValue) GetKey

func (m *KeyValue) GetKey() string

func (*KeyValue) GetValue

func (m *KeyValue) GetValue() []byte

func (*KeyValue) ProtoMessage

func (*KeyValue) ProtoMessage()

func (*KeyValue) Reset

func (m *KeyValue) Reset()

func (*KeyValue) String

func (m *KeyValue) String() string

func (*KeyValue) XXX_DiscardUnknown

func (m *KeyValue) XXX_DiscardUnknown()

func (*KeyValue) XXX_Marshal

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

func (*KeyValue) XXX_Merge

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

func (*KeyValue) XXX_Size

func (m *KeyValue) XXX_Size() int

func (*KeyValue) XXX_Unmarshal

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

type ListCollectionsParams

type ListCollectionsParams struct {
	Prefix               string   `protobuf:"bytes,1,opt,name=prefix" json:"prefix,omitempty"`
	StartWith            string   `protobuf:"bytes,2,opt,name=startWith" json:"startWith,omitempty"`
	Limit                uint64   `protobuf:"varint,3,opt,name=limit" json:"limit,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListCollectionsParams) Descriptor

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

func (*ListCollectionsParams) GetLimit

func (m *ListCollectionsParams) GetLimit() uint64

func (*ListCollectionsParams) GetPrefix

func (m *ListCollectionsParams) GetPrefix() string

func (*ListCollectionsParams) GetStartWith

func (m *ListCollectionsParams) GetStartWith() string

func (*ListCollectionsParams) ProtoMessage

func (*ListCollectionsParams) ProtoMessage()

func (*ListCollectionsParams) Reset

func (m *ListCollectionsParams) Reset()

func (*ListCollectionsParams) String

func (m *ListCollectionsParams) String() string

func (*ListCollectionsParams) XXX_DiscardUnknown

func (m *ListCollectionsParams) XXX_DiscardUnknown()

func (*ListCollectionsParams) XXX_Marshal

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

func (*ListCollectionsParams) XXX_Merge

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

func (*ListCollectionsParams) XXX_Size

func (m *ListCollectionsParams) XXX_Size() int

func (*ListCollectionsParams) XXX_Unmarshal

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

type ListCollectionsResponse

type ListCollectionsResponse struct {
	Stat                 *Status  `protobuf:"bytes,1,opt,name=stat" json:"stat,omitempty"`
	Collections          []string `protobuf:"bytes,2,rep,name=collections" json:"collections,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListCollectionsResponse) Descriptor

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

func (*ListCollectionsResponse) GetCollections

func (m *ListCollectionsResponse) GetCollections() []string

func (*ListCollectionsResponse) GetStat

func (m *ListCollectionsResponse) GetStat() *Status

func (*ListCollectionsResponse) ProtoMessage

func (*ListCollectionsResponse) ProtoMessage()

func (*ListCollectionsResponse) Reset

func (m *ListCollectionsResponse) Reset()

func (*ListCollectionsResponse) String

func (m *ListCollectionsResponse) String() string

func (*ListCollectionsResponse) XXX_DiscardUnknown

func (m *ListCollectionsResponse) XXX_DiscardUnknown()

func (*ListCollectionsResponse) XXX_Marshal

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

func (*ListCollectionsResponse) XXX_Merge

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

func (*ListCollectionsResponse) XXX_Size

func (m *ListCollectionsResponse) XXX_Size() int

func (*ListCollectionsResponse) XXX_Unmarshal

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

type LookupStreamsParams

type LookupStreamsParams struct {
	Collection           string         `protobuf:"bytes,1,opt,name=collection" json:"collection,omitempty"`
	IsCollectionPrefix   bool           `protobuf:"varint,2,opt,name=isCollectionPrefix" json:"isCollectionPrefix,omitempty"`
	Tags                 []*KeyOptValue `protobuf:"bytes,3,rep,name=tags" json:"tags,omitempty"`
	Annotations          []*KeyOptValue `protobuf:"bytes,4,rep,name=annotations" json:"annotations,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*LookupStreamsParams) Descriptor

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

func (*LookupStreamsParams) GetAnnotations

func (m *LookupStreamsParams) GetAnnotations() []*KeyOptValue

func (*LookupStreamsParams) GetCollection

func (m *LookupStreamsParams) GetCollection() string

func (*LookupStreamsParams) GetIsCollectionPrefix

func (m *LookupStreamsParams) GetIsCollectionPrefix() bool

func (*LookupStreamsParams) GetTags

func (m *LookupStreamsParams) GetTags() []*KeyOptValue

func (*LookupStreamsParams) ProtoMessage

func (*LookupStreamsParams) ProtoMessage()

func (*LookupStreamsParams) Reset

func (m *LookupStreamsParams) Reset()

func (*LookupStreamsParams) String

func (m *LookupStreamsParams) String() string

func (*LookupStreamsParams) XXX_DiscardUnknown

func (m *LookupStreamsParams) XXX_DiscardUnknown()

func (*LookupStreamsParams) XXX_Marshal

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

func (*LookupStreamsParams) XXX_Merge

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

func (*LookupStreamsParams) XXX_Size

func (m *LookupStreamsParams) XXX_Size() int

func (*LookupStreamsParams) XXX_Unmarshal

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

type LookupStreamsResponse

type LookupStreamsResponse struct {
	Stat                 *Status             `protobuf:"bytes,1,opt,name=stat" json:"stat,omitempty"`
	Results              []*StreamDescriptor `protobuf:"bytes,2,rep,name=results" json:"results,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*LookupStreamsResponse) Descriptor

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

func (*LookupStreamsResponse) GetResults

func (m *LookupStreamsResponse) GetResults() []*StreamDescriptor

func (*LookupStreamsResponse) GetStat

func (m *LookupStreamsResponse) GetStat() *Status

func (*LookupStreamsResponse) ProtoMessage

func (*LookupStreamsResponse) ProtoMessage()

func (*LookupStreamsResponse) Reset

func (m *LookupStreamsResponse) Reset()

func (*LookupStreamsResponse) String

func (m *LookupStreamsResponse) String() string

func (*LookupStreamsResponse) XXX_DiscardUnknown

func (m *LookupStreamsResponse) XXX_DiscardUnknown()

func (*LookupStreamsResponse) XXX_Marshal

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

func (*LookupStreamsResponse) XXX_Merge

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

func (*LookupStreamsResponse) XXX_Size

func (m *LookupStreamsResponse) XXX_Size() int

func (*LookupStreamsResponse) XXX_Unmarshal

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

type Mash

type Mash struct {
	Revision             int64     `protobuf:"varint,1,opt,name=revision" json:"revision,omitempty"`
	Leader               string    `protobuf:"bytes,2,opt,name=leader" json:"leader,omitempty"`
	LeaderRevision       int64     `protobuf:"varint,3,opt,name=leaderRevision" json:"leaderRevision,omitempty"`
	TotalWeight          int64     `protobuf:"varint,4,opt,name=totalWeight" json:"totalWeight,omitempty"`
	Healthy              bool      `protobuf:"varint,5,opt,name=healthy" json:"healthy,omitempty"`
	Unmapped             float64   `protobuf:"fixed64,6,opt,name=unmapped" json:"unmapped,omitempty"`
	Members              []*Member `protobuf:"bytes,7,rep,name=members" json:"members,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*Mash) Descriptor

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

func (*Mash) GetHealthy

func (m *Mash) GetHealthy() bool

func (*Mash) GetLeader

func (m *Mash) GetLeader() string

func (*Mash) GetLeaderRevision

func (m *Mash) GetLeaderRevision() int64

func (*Mash) GetMembers

func (m *Mash) GetMembers() []*Member

func (*Mash) GetRevision

func (m *Mash) GetRevision() int64

func (*Mash) GetTotalWeight

func (m *Mash) GetTotalWeight() int64

func (*Mash) GetUnmapped

func (m *Mash) GetUnmapped() float64

func (*Mash) ProtoMessage

func (*Mash) ProtoMessage()

func (*Mash) Reset

func (m *Mash) Reset()

func (*Mash) String

func (m *Mash) String() string

func (*Mash) XXX_DiscardUnknown

func (m *Mash) XXX_DiscardUnknown()

func (*Mash) XXX_Marshal

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

func (*Mash) XXX_Merge

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

func (*Mash) XXX_Size

func (m *Mash) XXX_Size() int

func (*Mash) XXX_Unmarshal

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

type Member

type Member struct {
	Hash                 uint32   `protobuf:"varint,1,opt,name=hash" json:"hash,omitempty"`
	Nodename             string   `protobuf:"bytes,2,opt,name=nodename" json:"nodename,omitempty"`
	Up                   bool     `protobuf:"varint,3,opt,name=up" json:"up,omitempty"`
	In                   bool     `protobuf:"varint,4,opt,name=in" json:"in,omitempty"`
	Enabled              bool     `protobuf:"varint,5,opt,name=enabled" json:"enabled,omitempty"`
	Start                int64    `protobuf:"varint,6,opt,name=start" json:"start,omitempty"`
	End                  int64    `protobuf:"varint,7,opt,name=end" json:"end,omitempty"`
	Weight               int64    `protobuf:"varint,8,opt,name=weight" json:"weight,omitempty"`
	ReadPreference       float64  `protobuf:"fixed64,9,opt,name=readPreference" json:"readPreference,omitempty"`
	HttpEndpoints        string   `protobuf:"bytes,10,opt,name=httpEndpoints" json:"httpEndpoints,omitempty"`
	GrpcEndpoints        string   `protobuf:"bytes,11,opt,name=grpcEndpoints" json:"grpcEndpoints,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Member) Descriptor

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

func (*Member) GetEnabled

func (m *Member) GetEnabled() bool

func (*Member) GetEnd

func (m *Member) GetEnd() int64

func (*Member) GetGrpcEndpoints

func (m *Member) GetGrpcEndpoints() string

func (*Member) GetHash

func (m *Member) GetHash() uint32

func (*Member) GetHttpEndpoints

func (m *Member) GetHttpEndpoints() string

func (*Member) GetIn

func (m *Member) GetIn() bool

func (*Member) GetNodename

func (m *Member) GetNodename() string

func (*Member) GetReadPreference

func (m *Member) GetReadPreference() float64

func (*Member) GetStart

func (m *Member) GetStart() int64

func (*Member) GetUp

func (m *Member) GetUp() bool

func (*Member) GetWeight

func (m *Member) GetWeight() int64

func (*Member) ProtoMessage

func (*Member) ProtoMessage()

func (*Member) Reset

func (m *Member) Reset()

func (*Member) String

func (m *Member) String() string

func (*Member) XXX_DiscardUnknown

func (m *Member) XXX_DiscardUnknown()

func (*Member) XXX_Marshal

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

func (*Member) XXX_Merge

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

func (*Member) XXX_Size

func (m *Member) XXX_Size() int

func (*Member) XXX_Unmarshal

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

type MetadataUsageParams

type MetadataUsageParams struct {
	Prefix               string   `protobuf:"bytes,1,opt,name=prefix" json:"prefix,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MetadataUsageParams) Descriptor

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

func (*MetadataUsageParams) GetPrefix

func (m *MetadataUsageParams) GetPrefix() string

func (*MetadataUsageParams) ProtoMessage

func (*MetadataUsageParams) ProtoMessage()

func (*MetadataUsageParams) Reset

func (m *MetadataUsageParams) Reset()

func (*MetadataUsageParams) String

func (m *MetadataUsageParams) String() string

func (*MetadataUsageParams) XXX_DiscardUnknown

func (m *MetadataUsageParams) XXX_DiscardUnknown()

func (*MetadataUsageParams) XXX_Marshal

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

func (*MetadataUsageParams) XXX_Merge

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

func (*MetadataUsageParams) XXX_Size

func (m *MetadataUsageParams) XXX_Size() int

func (*MetadataUsageParams) XXX_Unmarshal

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

type MetadataUsageResponse

type MetadataUsageResponse struct {
	Stat                 *Status     `protobuf:"bytes,1,opt,name=stat" json:"stat,omitempty"`
	Tags                 []*KeyCount `protobuf:"bytes,2,rep,name=tags" json:"tags,omitempty"`
	Annotations          []*KeyCount `protobuf:"bytes,3,rep,name=annotations" json:"annotations,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*MetadataUsageResponse) Descriptor

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

func (*MetadataUsageResponse) GetAnnotations

func (m *MetadataUsageResponse) GetAnnotations() []*KeyCount

func (*MetadataUsageResponse) GetStat

func (m *MetadataUsageResponse) GetStat() *Status

func (*MetadataUsageResponse) GetTags

func (m *MetadataUsageResponse) GetTags() []*KeyCount

func (*MetadataUsageResponse) ProtoMessage

func (*MetadataUsageResponse) ProtoMessage()

func (*MetadataUsageResponse) Reset

func (m *MetadataUsageResponse) Reset()

func (*MetadataUsageResponse) String

func (m *MetadataUsageResponse) String() string

func (*MetadataUsageResponse) XXX_DiscardUnknown

func (m *MetadataUsageResponse) XXX_DiscardUnknown()

func (*MetadataUsageResponse) XXX_Marshal

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

func (*MetadataUsageResponse) XXX_Merge

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

func (*MetadataUsageResponse) XXX_Size

func (m *MetadataUsageResponse) XXX_Size() int

func (*MetadataUsageResponse) XXX_Unmarshal

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

type NearestParams

type NearestParams struct {
	Uuid                 []byte   `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	Time                 int64    `protobuf:"fixed64,2,opt,name=time" json:"time,omitempty"`
	VersionMajor         uint64   `protobuf:"varint,3,opt,name=versionMajor" json:"versionMajor,omitempty"`
	Backward             bool     `protobuf:"varint,4,opt,name=backward" json:"backward,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NearestParams) Descriptor

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

func (*NearestParams) GetBackward

func (m *NearestParams) GetBackward() bool

func (*NearestParams) GetTime

func (m *NearestParams) GetTime() int64

func (*NearestParams) GetUuid

func (m *NearestParams) GetUuid() []byte

func (*NearestParams) GetVersionMajor

func (m *NearestParams) GetVersionMajor() uint64

func (*NearestParams) ProtoMessage

func (*NearestParams) ProtoMessage()

func (*NearestParams) Reset

func (m *NearestParams) Reset()

func (*NearestParams) String

func (m *NearestParams) String() string

func (*NearestParams) XXX_DiscardUnknown

func (m *NearestParams) XXX_DiscardUnknown()

func (*NearestParams) XXX_Marshal

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

func (*NearestParams) XXX_Merge

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

func (*NearestParams) XXX_Size

func (m *NearestParams) XXX_Size() int

func (*NearestParams) XXX_Unmarshal

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

type NearestResponse

type NearestResponse struct {
	Stat                 *Status   `protobuf:"bytes,1,opt,name=stat" json:"stat,omitempty"`
	VersionMajor         uint64    `protobuf:"varint,2,opt,name=versionMajor" json:"versionMajor,omitempty"`
	VersionMinor         uint64    `protobuf:"varint,3,opt,name=versionMinor" json:"versionMinor,omitempty"`
	Value                *RawPoint `protobuf:"bytes,4,opt,name=value" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*NearestResponse) Descriptor

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

func (*NearestResponse) GetStat

func (m *NearestResponse) GetStat() *Status

func (*NearestResponse) GetValue

func (m *NearestResponse) GetValue() *RawPoint

func (*NearestResponse) GetVersionMajor

func (m *NearestResponse) GetVersionMajor() uint64

func (*NearestResponse) GetVersionMinor

func (m *NearestResponse) GetVersionMinor() uint64

func (*NearestResponse) ProtoMessage

func (*NearestResponse) ProtoMessage()

func (*NearestResponse) Reset

func (m *NearestResponse) Reset()

func (*NearestResponse) String

func (m *NearestResponse) String() string

func (*NearestResponse) XXX_DiscardUnknown

func (m *NearestResponse) XXX_DiscardUnknown()

func (*NearestResponse) XXX_Marshal

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

func (*NearestResponse) XXX_Merge

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

func (*NearestResponse) XXX_Size

func (m *NearestResponse) XXX_Size() int

func (*NearestResponse) XXX_Unmarshal

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

type ObliterateParams

type ObliterateParams struct {
	Uuid                 []byte   `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ObliterateParams) Descriptor

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

func (*ObliterateParams) GetUuid

func (m *ObliterateParams) GetUuid() []byte

func (*ObliterateParams) ProtoMessage

func (*ObliterateParams) ProtoMessage()

func (*ObliterateParams) Reset

func (m *ObliterateParams) Reset()

func (*ObliterateParams) String

func (m *ObliterateParams) String() string

func (*ObliterateParams) XXX_DiscardUnknown

func (m *ObliterateParams) XXX_DiscardUnknown()

func (*ObliterateParams) XXX_Marshal

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

func (*ObliterateParams) XXX_Merge

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

func (*ObliterateParams) XXX_Size

func (m *ObliterateParams) XXX_Size() int

func (*ObliterateParams) XXX_Unmarshal

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

type ObliterateResponse

type ObliterateResponse struct {
	Stat                 *Status  `protobuf:"bytes,1,opt,name=stat" json:"stat,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ObliterateResponse) Descriptor

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

func (*ObliterateResponse) GetStat

func (m *ObliterateResponse) GetStat() *Status

func (*ObliterateResponse) ProtoMessage

func (*ObliterateResponse) ProtoMessage()

func (*ObliterateResponse) Reset

func (m *ObliterateResponse) Reset()

func (*ObliterateResponse) String

func (m *ObliterateResponse) String() string

func (*ObliterateResponse) XXX_DiscardUnknown

func (m *ObliterateResponse) XXX_DiscardUnknown()

func (*ObliterateResponse) XXX_Marshal

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

func (*ObliterateResponse) XXX_Merge

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

func (*ObliterateResponse) XXX_Size

func (m *ObliterateResponse) XXX_Size() int

func (*ObliterateResponse) XXX_Unmarshal

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

type OptValue

type OptValue struct {
	Value                []byte   `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*OptValue) Descriptor

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

func (*OptValue) GetValue

func (m *OptValue) GetValue() []byte

func (*OptValue) ProtoMessage

func (*OptValue) ProtoMessage()

func (*OptValue) Reset

func (m *OptValue) Reset()

func (*OptValue) String

func (m *OptValue) String() string

func (*OptValue) XXX_DiscardUnknown

func (m *OptValue) XXX_DiscardUnknown()

func (*OptValue) XXX_Marshal

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

func (*OptValue) XXX_Merge

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

func (*OptValue) XXX_Size

func (m *OptValue) XXX_Size() int

func (*OptValue) XXX_Unmarshal

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

type ProxyInfo

type ProxyInfo struct {
	ProxyEndpoints       []string `protobuf:"bytes,1,rep,name=proxyEndpoints" json:"proxyEndpoints,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ProxyInfo) Descriptor

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

func (*ProxyInfo) GetProxyEndpoints

func (m *ProxyInfo) GetProxyEndpoints() []string

func (*ProxyInfo) ProtoMessage

func (*ProxyInfo) ProtoMessage()

func (*ProxyInfo) Reset

func (m *ProxyInfo) Reset()

func (*ProxyInfo) String

func (m *ProxyInfo) String() string

func (*ProxyInfo) XXX_DiscardUnknown

func (m *ProxyInfo) XXX_DiscardUnknown()

func (*ProxyInfo) XXX_Marshal

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

func (*ProxyInfo) XXX_Merge

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

func (*ProxyInfo) XXX_Size

func (m *ProxyInfo) XXX_Size() int

func (*ProxyInfo) XXX_Unmarshal

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

type RawPoint

type RawPoint struct {
	Time                 int64    `protobuf:"fixed64,1,opt,name=time" json:"time,omitempty"`
	Value                float64  `protobuf:"fixed64,2,opt,name=value" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RawPoint) Descriptor

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

func (*RawPoint) GetTime

func (m *RawPoint) GetTime() int64

func (*RawPoint) GetValue

func (m *RawPoint) GetValue() float64

func (*RawPoint) ProtoMessage

func (*RawPoint) ProtoMessage()

func (*RawPoint) Reset

func (m *RawPoint) Reset()

func (*RawPoint) String

func (m *RawPoint) String() string

func (*RawPoint) XXX_DiscardUnknown

func (m *RawPoint) XXX_DiscardUnknown()

func (*RawPoint) XXX_Marshal

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

func (*RawPoint) XXX_Merge

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

func (*RawPoint) XXX_Size

func (m *RawPoint) XXX_Size() int

func (*RawPoint) XXX_Unmarshal

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

type RawValuesParams

type RawValuesParams struct {
	Uuid                 []byte   `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	Start                int64    `protobuf:"fixed64,2,opt,name=start" json:"start,omitempty"`
	End                  int64    `protobuf:"fixed64,3,opt,name=end" json:"end,omitempty"`
	VersionMajor         uint64   `protobuf:"varint,4,opt,name=versionMajor" json:"versionMajor,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RawValuesParams) Descriptor

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

func (*RawValuesParams) GetEnd

func (m *RawValuesParams) GetEnd() int64

func (*RawValuesParams) GetStart

func (m *RawValuesParams) GetStart() int64

func (*RawValuesParams) GetUuid

func (m *RawValuesParams) GetUuid() []byte

func (*RawValuesParams) GetVersionMajor

func (m *RawValuesParams) GetVersionMajor() uint64

func (*RawValuesParams) ProtoMessage

func (*RawValuesParams) ProtoMessage()

func (*RawValuesParams) Reset

func (m *RawValuesParams) Reset()

func (*RawValuesParams) String

func (m *RawValuesParams) String() string

func (*RawValuesParams) XXX_DiscardUnknown

func (m *RawValuesParams) XXX_DiscardUnknown()

func (*RawValuesParams) XXX_Marshal

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

func (*RawValuesParams) XXX_Merge

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

func (*RawValuesParams) XXX_Size

func (m *RawValuesParams) XXX_Size() int

func (*RawValuesParams) XXX_Unmarshal

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

type RawValuesResponse

type RawValuesResponse struct {
	Stat                 *Status     `protobuf:"bytes,1,opt,name=stat" json:"stat,omitempty"`
	VersionMajor         uint64      `protobuf:"varint,2,opt,name=versionMajor" json:"versionMajor,omitempty"`
	VersionMinor         uint64      `protobuf:"varint,3,opt,name=versionMinor" json:"versionMinor,omitempty"`
	Values               []*RawPoint `protobuf:"bytes,4,rep,name=values" json:"values,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*RawValuesResponse) Descriptor

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

func (*RawValuesResponse) GetStat

func (m *RawValuesResponse) GetStat() *Status

func (*RawValuesResponse) GetValues

func (m *RawValuesResponse) GetValues() []*RawPoint

func (*RawValuesResponse) GetVersionMajor

func (m *RawValuesResponse) GetVersionMajor() uint64

func (*RawValuesResponse) GetVersionMinor

func (m *RawValuesResponse) GetVersionMinor() uint64

func (*RawValuesResponse) ProtoMessage

func (*RawValuesResponse) ProtoMessage()

func (*RawValuesResponse) Reset

func (m *RawValuesResponse) Reset()

func (*RawValuesResponse) String

func (m *RawValuesResponse) String() string

func (*RawValuesResponse) XXX_DiscardUnknown

func (m *RawValuesResponse) XXX_DiscardUnknown()

func (*RawValuesResponse) XXX_Marshal

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

func (*RawValuesResponse) XXX_Merge

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

func (*RawValuesResponse) XXX_Size

func (m *RawValuesResponse) XXX_Size() int

func (*RawValuesResponse) XXX_Unmarshal

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

type SetStreamAnnotationsParams

type SetStreamAnnotationsParams struct {
	Uuid                      []byte         `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	ExpectedAnnotationVersion uint64         `protobuf:"varint,2,opt,name=expectedAnnotationVersion" json:"expectedAnnotationVersion,omitempty"`
	Annotations               []*KeyOptValue `protobuf:"bytes,3,rep,name=annotations" json:"annotations,omitempty"`
	XXX_NoUnkeyedLiteral      struct{}       `json:"-"`
	XXX_unrecognized          []byte         `json:"-"`
	XXX_sizecache             int32          `json:"-"`
}

func (*SetStreamAnnotationsParams) Descriptor

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

func (*SetStreamAnnotationsParams) GetAnnotations

func (m *SetStreamAnnotationsParams) GetAnnotations() []*KeyOptValue

func (*SetStreamAnnotationsParams) GetExpectedAnnotationVersion

func (m *SetStreamAnnotationsParams) GetExpectedAnnotationVersion() uint64

func (*SetStreamAnnotationsParams) GetUuid

func (m *SetStreamAnnotationsParams) GetUuid() []byte

func (*SetStreamAnnotationsParams) ProtoMessage

func (*SetStreamAnnotationsParams) ProtoMessage()

func (*SetStreamAnnotationsParams) Reset

func (m *SetStreamAnnotationsParams) Reset()

func (*SetStreamAnnotationsParams) String

func (m *SetStreamAnnotationsParams) String() string

func (*SetStreamAnnotationsParams) XXX_DiscardUnknown

func (m *SetStreamAnnotationsParams) XXX_DiscardUnknown()

func (*SetStreamAnnotationsParams) XXX_Marshal

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

func (*SetStreamAnnotationsParams) XXX_Merge

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

func (*SetStreamAnnotationsParams) XXX_Size

func (m *SetStreamAnnotationsParams) XXX_Size() int

func (*SetStreamAnnotationsParams) XXX_Unmarshal

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

type SetStreamAnnotationsResponse

type SetStreamAnnotationsResponse struct {
	Stat                 *Status  `protobuf:"bytes,1,opt,name=stat" json:"stat,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SetStreamAnnotationsResponse) Descriptor

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

func (*SetStreamAnnotationsResponse) GetStat

func (m *SetStreamAnnotationsResponse) GetStat() *Status

func (*SetStreamAnnotationsResponse) ProtoMessage

func (*SetStreamAnnotationsResponse) ProtoMessage()

func (*SetStreamAnnotationsResponse) Reset

func (m *SetStreamAnnotationsResponse) Reset()

func (*SetStreamAnnotationsResponse) String

func (*SetStreamAnnotationsResponse) XXX_DiscardUnknown

func (m *SetStreamAnnotationsResponse) XXX_DiscardUnknown()

func (*SetStreamAnnotationsResponse) XXX_Marshal

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

func (*SetStreamAnnotationsResponse) XXX_Merge

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

func (*SetStreamAnnotationsResponse) XXX_Size

func (m *SetStreamAnnotationsResponse) XXX_Size() int

func (*SetStreamAnnotationsResponse) XXX_Unmarshal

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

type StatPoint

type StatPoint struct {
	Time                 int64    `protobuf:"fixed64,1,opt,name=time" json:"time,omitempty"`
	Min                  float64  `protobuf:"fixed64,2,opt,name=min" json:"min,omitempty"`
	Mean                 float64  `protobuf:"fixed64,3,opt,name=mean" json:"mean,omitempty"`
	Max                  float64  `protobuf:"fixed64,4,opt,name=max" json:"max,omitempty"`
	Count                uint64   `protobuf:"fixed64,5,opt,name=count" json:"count,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StatPoint) Descriptor

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

func (*StatPoint) GetCount

func (m *StatPoint) GetCount() uint64

func (*StatPoint) GetMax

func (m *StatPoint) GetMax() float64

func (*StatPoint) GetMean

func (m *StatPoint) GetMean() float64

func (*StatPoint) GetMin

func (m *StatPoint) GetMin() float64

func (*StatPoint) GetTime

func (m *StatPoint) GetTime() int64

func (*StatPoint) ProtoMessage

func (*StatPoint) ProtoMessage()

func (*StatPoint) Reset

func (m *StatPoint) Reset()

func (*StatPoint) String

func (m *StatPoint) String() string

func (*StatPoint) XXX_DiscardUnknown

func (m *StatPoint) XXX_DiscardUnknown()

func (*StatPoint) XXX_Marshal

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

func (*StatPoint) XXX_Merge

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

func (*StatPoint) XXX_Size

func (m *StatPoint) XXX_Size() int

func (*StatPoint) XXX_Unmarshal

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

type Status

type Status struct {
	Code                 uint32   `protobuf:"varint,1,opt,name=code" json:"code,omitempty"`
	Msg                  string   `protobuf:"bytes,2,opt,name=msg" json:"msg,omitempty"`
	Mash                 *Mash    `protobuf:"bytes,3,opt,name=mash" json:"mash,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Status) Descriptor

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

func (*Status) GetCode

func (m *Status) GetCode() uint32

func (*Status) GetMash

func (m *Status) GetMash() *Mash

func (*Status) GetMsg

func (m *Status) GetMsg() string

func (*Status) ProtoMessage

func (*Status) ProtoMessage()

func (*Status) Reset

func (m *Status) Reset()

func (*Status) String

func (m *Status) String() string

func (*Status) XXX_DiscardUnknown

func (m *Status) XXX_DiscardUnknown()

func (*Status) XXX_Marshal

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

func (*Status) XXX_Merge

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

func (*Status) XXX_Size

func (m *Status) XXX_Size() int

func (*Status) XXX_Unmarshal

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

type StreamCSVConfig

type StreamCSVConfig struct {
	Version              uint64   `protobuf:"varint,1,opt,name=version" json:"version,omitempty"`
	Label                string   `protobuf:"bytes,2,opt,name=label" json:"label,omitempty"`
	Uuid                 []byte   `protobuf:"bytes,3,opt,name=uuid,proto3" json:"uuid,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StreamCSVConfig) Descriptor

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

func (*StreamCSVConfig) GetLabel

func (m *StreamCSVConfig) GetLabel() string

func (*StreamCSVConfig) GetUuid

func (m *StreamCSVConfig) GetUuid() []byte

func (*StreamCSVConfig) GetVersion

func (m *StreamCSVConfig) GetVersion() uint64

func (*StreamCSVConfig) ProtoMessage

func (*StreamCSVConfig) ProtoMessage()

func (*StreamCSVConfig) Reset

func (m *StreamCSVConfig) Reset()

func (*StreamCSVConfig) String

func (m *StreamCSVConfig) String() string

func (*StreamCSVConfig) XXX_DiscardUnknown

func (m *StreamCSVConfig) XXX_DiscardUnknown()

func (*StreamCSVConfig) XXX_Marshal

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

func (*StreamCSVConfig) XXX_Merge

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

func (*StreamCSVConfig) XXX_Size

func (m *StreamCSVConfig) XXX_Size() int

func (*StreamCSVConfig) XXX_Unmarshal

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

type StreamDescriptor

type StreamDescriptor struct {
	Uuid                 []byte      `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	Collection           string      `protobuf:"bytes,2,opt,name=collection" json:"collection,omitempty"`
	Tags                 []*KeyValue `protobuf:"bytes,3,rep,name=tags" json:"tags,omitempty"`
	Annotations          []*KeyValue `protobuf:"bytes,4,rep,name=annotations" json:"annotations,omitempty"`
	AnnotationVersion    uint64      `protobuf:"varint,5,opt,name=annotationVersion" json:"annotationVersion,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*StreamDescriptor) Descriptor

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

func (*StreamDescriptor) GetAnnotationVersion

func (m *StreamDescriptor) GetAnnotationVersion() uint64

func (*StreamDescriptor) GetAnnotations

func (m *StreamDescriptor) GetAnnotations() []*KeyValue

func (*StreamDescriptor) GetCollection

func (m *StreamDescriptor) GetCollection() string

func (*StreamDescriptor) GetTags

func (m *StreamDescriptor) GetTags() []*KeyValue

func (*StreamDescriptor) GetUuid

func (m *StreamDescriptor) GetUuid() []byte

func (*StreamDescriptor) ProtoMessage

func (*StreamDescriptor) ProtoMessage()

func (*StreamDescriptor) Reset

func (m *StreamDescriptor) Reset()

func (*StreamDescriptor) String

func (m *StreamDescriptor) String() string

func (*StreamDescriptor) XXX_DiscardUnknown

func (m *StreamDescriptor) XXX_DiscardUnknown()

func (*StreamDescriptor) XXX_Marshal

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

func (*StreamDescriptor) XXX_Merge

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

func (*StreamDescriptor) XXX_Size

func (m *StreamDescriptor) XXX_Size() int

func (*StreamDescriptor) XXX_Unmarshal

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

type StreamInfoParams

type StreamInfoParams struct {
	Uuid                 []byte   `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	OmitVersion          bool     `protobuf:"varint,2,opt,name=omitVersion" json:"omitVersion,omitempty"`
	OmitDescriptor       bool     `protobuf:"varint,3,opt,name=omitDescriptor" json:"omitDescriptor,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StreamInfoParams) Descriptor

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

func (*StreamInfoParams) GetOmitDescriptor

func (m *StreamInfoParams) GetOmitDescriptor() bool

func (*StreamInfoParams) GetOmitVersion

func (m *StreamInfoParams) GetOmitVersion() bool

func (*StreamInfoParams) GetUuid

func (m *StreamInfoParams) GetUuid() []byte

func (*StreamInfoParams) ProtoMessage

func (*StreamInfoParams) ProtoMessage()

func (*StreamInfoParams) Reset

func (m *StreamInfoParams) Reset()

func (*StreamInfoParams) String

func (m *StreamInfoParams) String() string

func (*StreamInfoParams) XXX_DiscardUnknown

func (m *StreamInfoParams) XXX_DiscardUnknown()

func (*StreamInfoParams) XXX_Marshal

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

func (*StreamInfoParams) XXX_Merge

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

func (*StreamInfoParams) XXX_Size

func (m *StreamInfoParams) XXX_Size() int

func (*StreamInfoParams) XXX_Unmarshal

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

type StreamInfoResponse

type StreamInfoResponse struct {
	Stat                 *Status           `protobuf:"bytes,1,opt,name=stat" json:"stat,omitempty"`
	VersionMajor         uint64            `protobuf:"varint,2,opt,name=versionMajor" json:"versionMajor,omitempty"`
	VersionMinor         uint64            `protobuf:"varint,3,opt,name=versionMinor" json:"versionMinor,omitempty"`
	Descriptor_          *StreamDescriptor `protobuf:"bytes,4,opt,name=descriptor" json:"descriptor,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*StreamInfoResponse) Descriptor

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

func (*StreamInfoResponse) GetDescriptor_

func (m *StreamInfoResponse) GetDescriptor_() *StreamDescriptor

func (*StreamInfoResponse) GetStat

func (m *StreamInfoResponse) GetStat() *Status

func (*StreamInfoResponse) GetVersionMajor

func (m *StreamInfoResponse) GetVersionMajor() uint64

func (*StreamInfoResponse) GetVersionMinor

func (m *StreamInfoResponse) GetVersionMinor() uint64

func (*StreamInfoResponse) ProtoMessage

func (*StreamInfoResponse) ProtoMessage()

func (*StreamInfoResponse) Reset

func (m *StreamInfoResponse) Reset()

func (*StreamInfoResponse) String

func (m *StreamInfoResponse) String() string

func (*StreamInfoResponse) XXX_DiscardUnknown

func (m *StreamInfoResponse) XXX_DiscardUnknown()

func (*StreamInfoResponse) XXX_Marshal

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

func (*StreamInfoResponse) XXX_Merge

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

func (*StreamInfoResponse) XXX_Size

func (m *StreamInfoResponse) XXX_Size() int

func (*StreamInfoResponse) XXX_Unmarshal

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

type TimeParam

type TimeParam interface {
	Start() int64
	End() int64
}

type WindowsParams

type WindowsParams struct {
	Uuid                 []byte   `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	Start                int64    `protobuf:"fixed64,2,opt,name=start" json:"start,omitempty"`
	End                  int64    `protobuf:"fixed64,3,opt,name=end" json:"end,omitempty"`
	VersionMajor         uint64   `protobuf:"varint,4,opt,name=versionMajor" json:"versionMajor,omitempty"`
	Width                uint64   `protobuf:"varint,5,opt,name=width" json:"width,omitempty"`
	Depth                uint32   `protobuf:"varint,6,opt,name=depth" json:"depth,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*WindowsParams) Descriptor

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

func (*WindowsParams) GetDepth

func (m *WindowsParams) GetDepth() uint32

func (*WindowsParams) GetEnd

func (m *WindowsParams) GetEnd() int64

func (*WindowsParams) GetStart

func (m *WindowsParams) GetStart() int64

func (*WindowsParams) GetUuid

func (m *WindowsParams) GetUuid() []byte

func (*WindowsParams) GetVersionMajor

func (m *WindowsParams) GetVersionMajor() uint64

func (*WindowsParams) GetWidth

func (m *WindowsParams) GetWidth() uint64

func (*WindowsParams) ProtoMessage

func (*WindowsParams) ProtoMessage()

func (*WindowsParams) Reset

func (m *WindowsParams) Reset()

func (*WindowsParams) String

func (m *WindowsParams) String() string

func (*WindowsParams) XXX_DiscardUnknown

func (m *WindowsParams) XXX_DiscardUnknown()

func (*WindowsParams) XXX_Marshal

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

func (*WindowsParams) XXX_Merge

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

func (*WindowsParams) XXX_Size

func (m *WindowsParams) XXX_Size() int

func (*WindowsParams) XXX_Unmarshal

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

type WindowsResponse

type WindowsResponse struct {
	Stat                 *Status      `protobuf:"bytes,1,opt,name=stat" json:"stat,omitempty"`
	VersionMajor         uint64       `protobuf:"varint,2,opt,name=versionMajor" json:"versionMajor,omitempty"`
	VersionMinor         uint64       `protobuf:"varint,3,opt,name=versionMinor" json:"versionMinor,omitempty"`
	Values               []*StatPoint `protobuf:"bytes,4,rep,name=values" json:"values,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*WindowsResponse) Descriptor

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

func (*WindowsResponse) GetStat

func (m *WindowsResponse) GetStat() *Status

func (*WindowsResponse) GetValues

func (m *WindowsResponse) GetValues() []*StatPoint

func (*WindowsResponse) GetVersionMajor

func (m *WindowsResponse) GetVersionMajor() uint64

func (*WindowsResponse) GetVersionMinor

func (m *WindowsResponse) GetVersionMinor() uint64

func (*WindowsResponse) ProtoMessage

func (*WindowsResponse) ProtoMessage()

func (*WindowsResponse) Reset

func (m *WindowsResponse) Reset()

func (*WindowsResponse) String

func (m *WindowsResponse) String() string

func (*WindowsResponse) XXX_DiscardUnknown

func (m *WindowsResponse) XXX_DiscardUnknown()

func (*WindowsResponse) XXX_Marshal

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

func (*WindowsResponse) XXX_Merge

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

func (*WindowsResponse) XXX_Size

func (m *WindowsResponse) XXX_Size() int

func (*WindowsResponse) XXX_Unmarshal

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

Jump to

Keyboard shortcuts

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