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 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)
	GetMetadataUsage(context.Context, *MetadataUsageParams) (*MetadataUsageResponse, error)
	GenerateCSV(*GenerateCSVParams, BTrDB_GenerateCSVServer) error
}

BTrDBServer is the server API for BTrDB service.

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 (m *GenerateCSVParams) GetQueryType() GenerateCSVParams_QueryType

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 

func (x GenerateCSVParams_QueryType) String() 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 (m *SetStreamAnnotationsResponse) String() 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

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.