grpcinterface

package
v4.9.4+incompatible Latest Latest
Warning

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

 Go to latest Published: Mar 8, 2018 License: GPL-3.0 Imports: 21 Imported by: 0

Documentation

Overview

Package grpcinterface is a generated protocol buffer package.

Version 4.2

It is generated from these files: 

btrdb.proto

It has these top-level messages: 

RawValuesParams
RawValuesResponse
AlignedWindowsParams
AlignedWindowsResponse
WindowsParams
WindowsResponse
StreamInfoParams
StreamInfoResponse
StreamDescriptor
SetStreamAnnotationsParams
SetStreamAnnotationsResponse
CreateParams
CreateResponse
ListCollectionsParams
ListCollectionsResponse
LookupStreamsParams
LookupStreamsResponse
NearestParams
NearestResponse
ChangesParams
ChangesResponse
InsertParams
InsertResponse
DeleteParams
DeleteResponse
InfoParams
InfoResponse
ProxyInfo
FaultInjectParams
FaultInjectResponse
FlushParams
FlushResponse
ObliterateParams
ObliterateResponse
RawPoint
StatPoint
ChangedRange
Status
Mash
Member
KeyOptValue
OptValue
KeyValue

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

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

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

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

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

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

func NewBTrDBClient 

func NewBTrDBClient(cc *grpc.ClientConn) BTrDBClient

type BTrDBServer 

type BTrDBServer interface {
	RawValues(*RawValuesParams, BTrDB_RawValuesServer) error
	AlignedWindows(*AlignedWindowsParams, BTrDB_AlignedWindowsServer) error
	Windows(*WindowsParams, BTrDB_WindowsServer) error
	StreamInfo(context.Context, *StreamInfoParams) (*StreamInfoResponse, error)
	SetStreamAnnotations(context.Context, *SetStreamAnnotationsParams) (*SetStreamAnnotationsResponse, error)
	Create(context.Context, *CreateParams) (*CreateResponse, error)
	ListCollections(context.Context, *ListCollectionsParams) (*ListCollectionsResponse, error)
	LookupStreams(*LookupStreamsParams, BTrDB_LookupStreamsServer) error
	Nearest(context.Context, *NearestParams) (*NearestResponse, error)
	Changes(*ChangesParams, BTrDB_ChangesServer) error
	Insert(context.Context, *InsertParams) (*InsertResponse, error)
	Delete(context.Context, *DeleteParams) (*DeleteResponse, error)
	Info(context.Context, *InfoParams) (*InfoResponse, error)
	FaultInject(context.Context, *FaultInjectParams) (*FaultInjectResponse, error)
	Flush(context.Context, *FlushParams) (*FlushResponse, error)
	Obliterate(context.Context, *ObliterateParams) (*ObliterateResponse, error)
}

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_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"`
}

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

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

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

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

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

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

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

type CreateResponse 

type CreateResponse struct {
	Stat *Status `protobuf:"bytes,1,opt,name=stat" json:"stat,omitempty"`
}

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

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

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

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

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

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

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

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

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

type FlushParams 

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

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

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

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

type GRPCInterface 

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

func ServeGRPC 

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

type InfoParams 

type InfoParams struct {
}

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

type ObliterateParams 

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

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

type ObliterateResponse 

type ObliterateResponse struct {
	Stat *Status `protobuf:"bytes,1,opt,name=stat" json:"stat,omitempty"`
}

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

type OptValue 

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

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

type ProxyInfo 

type ProxyInfo struct {
	ProxyEndpoints []string `protobuf:"bytes,1,rep,name=proxyEndpoints" json:"proxyEndpoints,omitempty"`
}

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

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

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

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

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

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

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

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

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

type SetStreamAnnotationsResponse 

type SetStreamAnnotationsResponse struct {
	Stat *Status `protobuf:"bytes,1,opt,name=stat" json:"stat,omitempty"`
}

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 (m *SetStreamAnnotationsResponse) String() string

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

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

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

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

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

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

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

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

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

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

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

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

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

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.