v5api

package
v5.9.1+incompatible Latest Latest
Warning

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

 Go to latest Published: Mar 20, 2020 License: BSD-2-Clause Imports: 13 Imported by: 0

Documentation

Overview

Package v5api is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

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 RegisterBTrDBHandler 

func RegisterBTrDBHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterBTrDBHandler registers the http handlers for service BTrDB to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterBTrDBHandlerClient 

func RegisterBTrDBHandlerClient(ctx context.Context, mux *runtime.ServeMux, client BTrDBClient) error

RegisterBTrDBHandlerClient registers the http handlers for service BTrDB to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "BTrDBClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "BTrDBClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "BTrDBClient" to call the correct interceptors.

func RegisterBTrDBHandlerFromEndpoint 

func RegisterBTrDBHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterBTrDBHandlerFromEndpoint is same as RegisterBTrDBHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

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,proto3" json:"start,omitempty"`
	End                  int64    `protobuf:"fixed64,3,opt,name=end,proto3" json:"end,omitempty"`
	VersionMajor         uint64   `protobuf:"varint,4,opt,name=versionMajor,proto3" json:"versionMajor,omitempty"`
	PointWidth           uint32   `protobuf:"varint,5,opt,name=pointWidth,proto3" 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,proto3" json:"stat,omitempty"`
	VersionMajor         uint64       `protobuf:"varint,2,opt,name=versionMajor,proto3" json:"versionMajor,omitempty"`
	VersionMinor         uint64       `protobuf:"varint,3,opt,name=versionMinor,proto3" json:"versionMinor,omitempty"`
	Values               []*StatPoint `protobuf:"bytes,4,rep,name=values,proto3" 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)
	SetStreamTags(ctx context.Context, in *SetStreamTagsParams, opts ...grpc.CallOption) (*SetStreamTagsResponse, error)
	Create(ctx context.Context, in *CreateParams, opts ...grpc.CallOption) (*CreateResponse, error)
	ListCollections(ctx context.Context, in *ListCollectionsParams, opts ...grpc.CallOption) (BTrDB_ListCollectionsClient, 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)
	SQLQuery(ctx context.Context, in *SQLQueryParams, opts ...grpc.CallOption) (BTrDB_SQLQueryClient, error)
	SetCompactionConfig(ctx context.Context, in *SetCompactionConfigParams, opts ...grpc.CallOption) (*SetCompactionConfigResponse, error)
	GetCompactionConfig(ctx context.Context, in *GetCompactionConfigParams, opts ...grpc.CallOption) (*GetCompactionConfigResponse, 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)
	SetStreamTags(context.Context, *SetStreamTagsParams) (*SetStreamTagsResponse, error)
	Create(context.Context, *CreateParams) (*CreateResponse, error)
	ListCollections(*ListCollectionsParams, BTrDB_ListCollectionsServer) 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
	SQLQuery(*SQLQueryParams, BTrDB_SQLQueryServer) error
	SetCompactionConfig(context.Context, *SetCompactionConfigParams) (*SetCompactionConfigResponse, error)
	GetCompactionConfig(context.Context, *GetCompactionConfigParams) (*GetCompactionConfigResponse, 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_ListCollectionsClient 

type BTrDB_ListCollectionsClient interface {
	Recv() (*ListCollectionsResponse, error)
	grpc.ClientStream
}

type BTrDB_ListCollectionsServer 

type BTrDB_ListCollectionsServer interface {
	Send(*ListCollectionsResponse) 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_SQLQueryClient 

type BTrDB_SQLQueryClient interface {
	Recv() (*SQLQueryResponse, error)
	grpc.ClientStream
}

type BTrDB_SQLQueryServer 

type BTrDB_SQLQueryServer interface {
	Send(*SQLQueryResponse) 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,proto3" json:"start,omitempty"`
	End                  int64    `protobuf:"fixed64,2,opt,name=end,proto3" 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,proto3" json:"fromMajor,omitempty"`
	ToMajor              uint64   `protobuf:"varint,3,opt,name=toMajor,proto3" json:"toMajor,omitempty"`
	Resolution           uint32   `protobuf:"varint,4,opt,name=resolution,proto3" 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,proto3" json:"stat,omitempty"`
	VersionMajor         uint64          `protobuf:"varint,2,opt,name=versionMajor,proto3" json:"versionMajor,omitempty"`
	VersionMinor         uint64          `protobuf:"varint,3,opt,name=versionMinor,proto3" json:"versionMinor,omitempty"`
	Ranges               []*ChangedRange `protobuf:"bytes,4,rep,name=ranges,proto3" 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,proto3" json:"collection,omitempty"`
	Tags                 []*KeyOptValue `protobuf:"bytes,3,rep,name=tags,proto3" json:"tags,omitempty"`
	Annotations          []*KeyOptValue `protobuf:"bytes,4,rep,name=annotations,proto3" 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() []*KeyOptValue

func (*CreateParams) GetCollection 

func (m *CreateParams) GetCollection() string

func (*CreateParams) GetTags 

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

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,proto3" 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,proto3" json:"start,omitempty"`
	End                  int64    `protobuf:"fixed64,3,opt,name=end,proto3" 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,proto3" json:"stat,omitempty"`
	VersionMajor         uint64   `protobuf:"varint,2,opt,name=versionMajor,proto3" json:"versionMajor,omitempty"`
	VersionMinor         uint64   `protobuf:"varint,3,opt,name=versionMinor,proto3" 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,proto3" 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,proto3" 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,proto3" json:"stat,omitempty"`
	VersionMajor         uint64   `protobuf:"varint,2,opt,name=versionMajor,proto3" json:"versionMajor,omitempty"`
	VersionMinor         uint64   `protobuf:"varint,3,opt,name=versionMinor,proto3" 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 GenerateCSVParams 

type GenerateCSVParams struct {
	QueryType            GenerateCSVParams_QueryType `protobuf:"varint,1,opt,name=queryType,proto3,enum=v5api.GenerateCSVParams_QueryType" json:"queryType,omitempty"`
	StartTime            int64                       `protobuf:"varint,2,opt,name=startTime,proto3" json:"startTime,omitempty"`
	EndTime              int64                       `protobuf:"varint,3,opt,name=endTime,proto3" json:"endTime,omitempty"`
	WindowSize           uint64                      `protobuf:"varint,4,opt,name=windowSize,proto3" json:"windowSize,omitempty"`
	Depth                uint32                      `protobuf:"varint,5,opt,name=depth,proto3" json:"depth,omitempty"`
	IncludeVersions      bool                        `protobuf:"varint,6,opt,name=includeVersions,proto3" json:"includeVersions,omitempty"`
	Streams              []*StreamCSVConfig          `protobuf:"bytes,7,rep,name=streams,proto3" 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,proto3" json:"stat,omitempty"`
	IsHeader             bool     `protobuf:"varint,2,opt,name=isHeader,proto3" json:"isHeader,omitempty"`
	Row                  []string `protobuf:"bytes,3,rep,name=row,proto3" 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 GetCompactionConfigParams 

type GetCompactionConfigParams struct {
	// Which stream to query
	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 (*GetCompactionConfigParams) Descriptor 

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

func (*GetCompactionConfigParams) GetUuid 

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

func (*GetCompactionConfigParams) ProtoMessage 

func (*GetCompactionConfigParams) ProtoMessage()

func (*GetCompactionConfigParams) Reset 

func (m *GetCompactionConfigParams) Reset()

func (*GetCompactionConfigParams) String 

func (m *GetCompactionConfigParams) String() string

func (*GetCompactionConfigParams) XXX_DiscardUnknown 

func (m *GetCompactionConfigParams) XXX_DiscardUnknown()

func (*GetCompactionConfigParams) XXX_Marshal 

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

func (*GetCompactionConfigParams) XXX_Merge 

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

func (*GetCompactionConfigParams) XXX_Size 

func (m *GetCompactionConfigParams) XXX_Size() int

func (*GetCompactionConfigParams) XXX_Unmarshal 

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

type GetCompactionConfigResponse 

type GetCompactionConfigResponse struct {
	Stat *Status `protobuf:"bytes,1,opt,name=stat,proto3" json:"stat,omitempty"`
	// The latest version of the stream, as returned by StreamInfo
	LatestMajorVersion uint64 `protobuf:"varint,2,opt,name=LatestMajorVersion,proto3" json:"LatestMajorVersion,omitempty"`
	// Accessing versions LESS than this is not allowed
	CompactedVersion uint64 `protobuf:"varint,3,opt,name=CompactedVersion,proto3" json:"CompactedVersion,omitempty"`
	// For every timestamp >= Start and < End in this list,
	// we cannot traverse the tree < Resolution.
	ReducedResolutionRanges []*ReducedResolutionRange `protobuf:"bytes,4,rep,name=reducedResolutionRanges,proto3" json:"reducedResolutionRanges,omitempty"`
	// Addresses less than this will be moved to the archive storage soon
	TargetArchiveHorizon uint64   `protobuf:"varint,5,opt,name=targetArchiveHorizon,proto3" json:"targetArchiveHorizon,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetCompactionConfigResponse) Descriptor 

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

func (*GetCompactionConfigResponse) GetCompactedVersion 

func (m *GetCompactionConfigResponse) GetCompactedVersion() uint64

func (*GetCompactionConfigResponse) GetLatestMajorVersion 

func (m *GetCompactionConfigResponse) GetLatestMajorVersion() uint64

func (*GetCompactionConfigResponse) GetReducedResolutionRanges 

func (m *GetCompactionConfigResponse) GetReducedResolutionRanges() []*ReducedResolutionRange

func (*GetCompactionConfigResponse) GetStat 

func (m *GetCompactionConfigResponse) GetStat() *Status

func (*GetCompactionConfigResponse) GetTargetArchiveHorizon 

func (m *GetCompactionConfigResponse) GetTargetArchiveHorizon() uint64

func (*GetCompactionConfigResponse) ProtoMessage 

func (*GetCompactionConfigResponse) ProtoMessage()

func (*GetCompactionConfigResponse) Reset 

func (m *GetCompactionConfigResponse) Reset()

func (*GetCompactionConfigResponse) String 

func (m *GetCompactionConfigResponse) String() string

func (*GetCompactionConfigResponse) XXX_DiscardUnknown 

func (m *GetCompactionConfigResponse) XXX_DiscardUnknown()

func (*GetCompactionConfigResponse) XXX_Marshal 

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

func (*GetCompactionConfigResponse) XXX_Merge 

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

func (*GetCompactionConfigResponse) XXX_Size 

func (m *GetCompactionConfigResponse) XXX_Size() int

func (*GetCompactionConfigResponse) XXX_Unmarshal 

func (m *GetCompactionConfigResponse) 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,proto3" json:"stat,omitempty"`
	Mash                 *Mash      `protobuf:"bytes,2,opt,name=mash,proto3" json:"mash,omitempty"`
	MajorVersion         uint32     `protobuf:"varint,3,opt,name=majorVersion,proto3" json:"majorVersion,omitempty"`
	MinorVersion         uint32     `protobuf:"varint,4,opt,name=minorVersion,proto3" json:"minorVersion,omitempty"`
	Build                string     `protobuf:"bytes,5,opt,name=build,proto3" json:"build,omitempty"`
	Proxy                *ProxyInfo `protobuf:"bytes,6,opt,name=proxy,proto3" 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,proto3" json:"sync,omitempty"`
	Values               []*RawPoint `protobuf:"bytes,3,rep,name=values,proto3" 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,proto3" json:"stat,omitempty"`
	VersionMajor         uint64   `protobuf:"varint,2,opt,name=versionMajor,proto3" json:"versionMajor,omitempty"`
	VersionMinor         uint64   `protobuf:"varint,3,opt,name=versionMinor,proto3" 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,proto3" json:"key,omitempty"`
	Count                uint64   `protobuf:"varint,2,opt,name=count,proto3" 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,proto3" json:"key,omitempty"`
	Val                  *OptValue `protobuf:"bytes,2,opt,name=val,proto3" 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,proto3" json:"key,omitempty"`
	Value                string   `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() string

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,proto3" json:"prefix,omitempty"`
	Role                 *Role    `protobuf:"bytes,100,opt,name=role,proto3" json:"role,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListCollectionsParams) Descriptor 

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

func (*ListCollectionsParams) GetPrefix 

func (m *ListCollectionsParams) GetPrefix() string

func (*ListCollectionsParams) GetRole 

func (m *ListCollectionsParams) GetRole() *Role

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,proto3" json:"stat,omitempty"`
	Collections          []string `protobuf:"bytes,2,rep,name=collections,proto3" 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,proto3" json:"collection,omitempty"`
	IsCollectionPrefix   bool           `protobuf:"varint,2,opt,name=isCollectionPrefix,proto3" json:"isCollectionPrefix,omitempty"`
	Tags                 []*KeyOptValue `protobuf:"bytes,3,rep,name=tags,proto3" json:"tags,omitempty"`
	Annotations          []*KeyOptValue `protobuf:"bytes,4,rep,name=annotations,proto3" json:"annotations,omitempty"`
	Role                 *Role          `protobuf:"bytes,100,opt,name=role,proto3" json:"role,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) GetRole 

func (m *LookupStreamsParams) GetRole() *Role

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,proto3" json:"stat,omitempty"`
	Results              []*StreamDescriptor `protobuf:"bytes,2,rep,name=results,proto3" 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,proto3" json:"revision,omitempty"`
	Leader               string    `protobuf:"bytes,2,opt,name=leader,proto3" json:"leader,omitempty"`
	LeaderRevision       int64     `protobuf:"varint,3,opt,name=leaderRevision,proto3" json:"leaderRevision,omitempty"`
	TotalWeight          int64     `protobuf:"varint,4,opt,name=totalWeight,proto3" json:"totalWeight,omitempty"`
	Healthy              bool      `protobuf:"varint,5,opt,name=healthy,proto3" json:"healthy,omitempty"`
	Unmapped             float64   `protobuf:"fixed64,6,opt,name=unmapped,proto3" json:"unmapped,omitempty"`
	Members              []*Member `protobuf:"bytes,7,rep,name=members,proto3" 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,proto3" json:"hash,omitempty"`
	Nodename             string   `protobuf:"bytes,2,opt,name=nodename,proto3" json:"nodename,omitempty"`
	Up                   bool     `protobuf:"varint,3,opt,name=up,proto3" json:"up,omitempty"`
	In                   bool     `protobuf:"varint,4,opt,name=in,proto3" json:"in,omitempty"`
	Enabled              bool     `protobuf:"varint,5,opt,name=enabled,proto3" json:"enabled,omitempty"`
	Start                int64    `protobuf:"varint,6,opt,name=start,proto3" json:"start,omitempty"`
	End                  int64    `protobuf:"varint,7,opt,name=end,proto3" json:"end,omitempty"`
	Weight               int64    `protobuf:"varint,8,opt,name=weight,proto3" json:"weight,omitempty"`
	ReadPreference       float64  `protobuf:"fixed64,9,opt,name=readPreference,proto3" json:"readPreference,omitempty"`
	HttpEndpoints        string   `protobuf:"bytes,10,opt,name=httpEndpoints,proto3" json:"httpEndpoints,omitempty"`
	GrpcEndpoints        string   `protobuf:"bytes,11,opt,name=grpcEndpoints,proto3" 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,proto3" json:"prefix,omitempty"`
	Role                 *Role    `protobuf:"bytes,100,opt,name=role,proto3" json:"role,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) GetRole 

func (m *MetadataUsageParams) GetRole() *Role

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,proto3" json:"stat,omitempty"`
	Tags                 []*KeyCount `protobuf:"bytes,2,rep,name=tags,proto3" json:"tags,omitempty"`
	Annotations          []*KeyCount `protobuf:"bytes,3,rep,name=annotations,proto3" 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,proto3" json:"time,omitempty"`
	VersionMajor         uint64   `protobuf:"varint,3,opt,name=versionMajor,proto3" json:"versionMajor,omitempty"`
	Backward             bool     `protobuf:"varint,4,opt,name=backward,proto3" 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,proto3" json:"stat,omitempty"`
	VersionMajor         uint64    `protobuf:"varint,2,opt,name=versionMajor,proto3" json:"versionMajor,omitempty"`
	VersionMinor         uint64    `protobuf:"varint,3,opt,name=versionMinor,proto3" json:"versionMinor,omitempty"`
	Value                *RawPoint `protobuf:"bytes,4,opt,name=value,proto3" 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,proto3" 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                string   `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() string

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,proto3" 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,proto3" json:"time,omitempty"`
	Value                float64  `protobuf:"fixed64,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*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,proto3" json:"start,omitempty"`
	End                  int64    `protobuf:"fixed64,3,opt,name=end,proto3" json:"end,omitempty"`
	VersionMajor         uint64   `protobuf:"varint,4,opt,name=versionMajor,proto3" 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,proto3" json:"stat,omitempty"`
	VersionMajor         uint64      `protobuf:"varint,2,opt,name=versionMajor,proto3" json:"versionMajor,omitempty"`
	VersionMinor         uint64      `protobuf:"varint,3,opt,name=versionMinor,proto3" json:"versionMinor,omitempty"`
	Values               []*RawPoint `protobuf:"bytes,4,rep,name=values,proto3" 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 ReducedResolutionRange 

type ReducedResolutionRange struct {
	Start                int64    `protobuf:"varint,1,opt,name=Start,proto3" json:"Start,omitempty"`
	End                  int64    `protobuf:"varint,2,opt,name=End,proto3" json:"End,omitempty"`
	Resolution           uint32   `protobuf:"varint,3,opt,name=Resolution,proto3" json:"Resolution,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ReducedResolutionRange) Descriptor 

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

func (*ReducedResolutionRange) GetEnd 

func (m *ReducedResolutionRange) GetEnd() int64

func (*ReducedResolutionRange) GetResolution 

func (m *ReducedResolutionRange) GetResolution() uint32

func (*ReducedResolutionRange) GetStart 

func (m *ReducedResolutionRange) GetStart() int64

func (*ReducedResolutionRange) ProtoMessage 

func (*ReducedResolutionRange) ProtoMessage()

func (*ReducedResolutionRange) Reset 

func (m *ReducedResolutionRange) Reset()

func (*ReducedResolutionRange) String 

func (m *ReducedResolutionRange) String() string

func (*ReducedResolutionRange) XXX_DiscardUnknown 

func (m *ReducedResolutionRange) XXX_DiscardUnknown()

func (*ReducedResolutionRange) XXX_Marshal 

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

func (*ReducedResolutionRange) XXX_Merge 

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

func (*ReducedResolutionRange) XXX_Size 

func (m *ReducedResolutionRange) XXX_Size() int

func (*ReducedResolutionRange) XXX_Unmarshal 

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

type Role 

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

func (*Role) Descriptor 

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

func (*Role) GetName 

func (m *Role) GetName() string

func (*Role) ProtoMessage 

func (*Role) ProtoMessage()

func (*Role) Reset 

func (m *Role) Reset()

func (*Role) String 

func (m *Role) String() string

func (*Role) XXX_DiscardUnknown 

func (m *Role) XXX_DiscardUnknown()

func (*Role) XXX_Marshal 

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

func (*Role) XXX_Merge 

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

func (*Role) XXX_Size 

func (m *Role) XXX_Size() int

func (*Role) XXX_Unmarshal 

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

type SQLQueryParams 

type SQLQueryParams struct {
	Query                string   `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
	Params               []string `protobuf:"bytes,2,rep,name=params,proto3" json:"params,omitempty"`
	Role                 *Role    `protobuf:"bytes,100,opt,name=role,proto3" json:"role,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SQLQueryParams) Descriptor 

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

func (*SQLQueryParams) GetParams 

func (m *SQLQueryParams) GetParams() []string

func (*SQLQueryParams) GetQuery 

func (m *SQLQueryParams) GetQuery() string

func (*SQLQueryParams) GetRole 

func (m *SQLQueryParams) GetRole() *Role

func (*SQLQueryParams) ProtoMessage 

func (*SQLQueryParams) ProtoMessage()

func (*SQLQueryParams) Reset 

func (m *SQLQueryParams) Reset()

func (*SQLQueryParams) String 

func (m *SQLQueryParams) String() string

func (*SQLQueryParams) XXX_DiscardUnknown 

func (m *SQLQueryParams) XXX_DiscardUnknown()

func (*SQLQueryParams) XXX_Marshal 

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

func (*SQLQueryParams) XXX_Merge 

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

func (*SQLQueryParams) XXX_Size 

func (m *SQLQueryParams) XXX_Size() int

func (*SQLQueryParams) XXX_Unmarshal 

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

type SQLQueryResponse 

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

func (*SQLQueryResponse) Descriptor 

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

func (*SQLQueryResponse) GetSQLQueryRow 

func (m *SQLQueryResponse) GetSQLQueryRow() [][]byte

func (*SQLQueryResponse) GetStat 

func (m *SQLQueryResponse) GetStat() *Status

func (*SQLQueryResponse) ProtoMessage 

func (*SQLQueryResponse) ProtoMessage()

func (*SQLQueryResponse) Reset 

func (m *SQLQueryResponse) Reset()

func (*SQLQueryResponse) String 

func (m *SQLQueryResponse) String() string

func (*SQLQueryResponse) XXX_DiscardUnknown 

func (m *SQLQueryResponse) XXX_DiscardUnknown()

func (*SQLQueryResponse) XXX_Marshal 

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

func (*SQLQueryResponse) XXX_Merge 

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

func (*SQLQueryResponse) XXX_Size 

func (m *SQLQueryResponse) XXX_Size() int

func (*SQLQueryResponse) XXX_Unmarshal 

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

type SetCompactionConfigParams 

type SetCompactionConfigParams struct {
	// Which stream to configure
	Uuid []byte `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	// Accessing versions LESS than this is not allowed
	CompactedVersion uint64 `protobuf:"varint,2,opt,name=CompactedVersion,proto3" json:"CompactedVersion,omitempty"`
	// For every timestamp >= Start and < End in this list,
	// we cannot traverse the tree < Resolution.
	// These ranges are the new ones you want to add, not the full list
	ReducedResolutionRanges []*ReducedResolutionRange `protobuf:"bytes,3,rep,name=reducedResolutionRanges,proto3" json:"reducedResolutionRanges,omitempty"`
	// Addresses less than this will be moved to the archive storage soon
	// You can't set this to less than it is, so zero means leave as is
	TargetArchiveHorizon uint64   `protobuf:"varint,4,opt,name=targetArchiveHorizon,proto3" json:"targetArchiveHorizon,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SetCompactionConfigParams) Descriptor 

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

func (*SetCompactionConfigParams) GetCompactedVersion 

func (m *SetCompactionConfigParams) GetCompactedVersion() uint64

func (*SetCompactionConfigParams) GetReducedResolutionRanges 

func (m *SetCompactionConfigParams) GetReducedResolutionRanges() []*ReducedResolutionRange

func (*SetCompactionConfigParams) GetTargetArchiveHorizon 

func (m *SetCompactionConfigParams) GetTargetArchiveHorizon() uint64

func (*SetCompactionConfigParams) GetUuid 

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

func (*SetCompactionConfigParams) ProtoMessage 

func (*SetCompactionConfigParams) ProtoMessage()

func (*SetCompactionConfigParams) Reset 

func (m *SetCompactionConfigParams) Reset()

func (*SetCompactionConfigParams) String 

func (m *SetCompactionConfigParams) String() string

func (*SetCompactionConfigParams) XXX_DiscardUnknown 

func (m *SetCompactionConfigParams) XXX_DiscardUnknown()

func (*SetCompactionConfigParams) XXX_Marshal 

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

func (*SetCompactionConfigParams) XXX_Merge 

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

func (*SetCompactionConfigParams) XXX_Size 

func (m *SetCompactionConfigParams) XXX_Size() int

func (*SetCompactionConfigParams) XXX_Unmarshal 

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

type SetCompactionConfigResponse 

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

func (*SetCompactionConfigResponse) Descriptor 

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

func (*SetCompactionConfigResponse) GetStat 

func (m *SetCompactionConfigResponse) GetStat() *Status

func (*SetCompactionConfigResponse) ProtoMessage 

func (*SetCompactionConfigResponse) ProtoMessage()

func (*SetCompactionConfigResponse) Reset 

func (m *SetCompactionConfigResponse) Reset()

func (*SetCompactionConfigResponse) String 

func (m *SetCompactionConfigResponse) String() string

func (*SetCompactionConfigResponse) XXX_DiscardUnknown 

func (m *SetCompactionConfigResponse) XXX_DiscardUnknown()

func (*SetCompactionConfigResponse) XXX_Marshal 

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

func (*SetCompactionConfigResponse) XXX_Merge 

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

func (*SetCompactionConfigResponse) XXX_Size 

func (m *SetCompactionConfigResponse) XXX_Size() int

func (*SetCompactionConfigResponse) XXX_Unmarshal 

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

type SetStreamAnnotationsParams 

type SetStreamAnnotationsParams struct {
	Uuid                    []byte         `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	ExpectedPropertyVersion uint64         `protobuf:"varint,2,opt,name=expectedPropertyVersion,proto3" json:"expectedPropertyVersion,omitempty"`
	Changes                 []*KeyOptValue `protobuf:"bytes,3,rep,name=changes,proto3" json:"changes,omitempty"`
	Removals                []string       `protobuf:"bytes,4,rep,name=removals,proto3" json:"removals,omitempty"`
	XXX_NoUnkeyedLiteral    struct{}       `json:"-"`
	XXX_unrecognized        []byte         `json:"-"`
	XXX_sizecache           int32          `json:"-"`
}

func (*SetStreamAnnotationsParams) Descriptor 

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

func (*SetStreamAnnotationsParams) GetChanges 

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

func (*SetStreamAnnotationsParams) GetExpectedPropertyVersion 

func (m *SetStreamAnnotationsParams) GetExpectedPropertyVersion() uint64

func (*SetStreamAnnotationsParams) GetRemovals 

func (m *SetStreamAnnotationsParams) GetRemovals() []string

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,proto3" 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 SetStreamTagsParams 

type SetStreamTagsParams struct {
	Uuid                    []byte         `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	ExpectedPropertyVersion uint64         `protobuf:"varint,2,opt,name=expectedPropertyVersion,proto3" json:"expectedPropertyVersion,omitempty"`
	Tags                    []*KeyOptValue `protobuf:"bytes,3,rep,name=tags,proto3" json:"tags,omitempty"`
	Collection              string         `protobuf:"bytes,4,opt,name=collection,proto3" json:"collection,omitempty"`
	Remove                  []string       `protobuf:"bytes,5,rep,name=remove,proto3" json:"remove,omitempty"`
	XXX_NoUnkeyedLiteral    struct{}       `json:"-"`
	XXX_unrecognized        []byte         `json:"-"`
	XXX_sizecache           int32          `json:"-"`
}

func (*SetStreamTagsParams) Descriptor 

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

func (*SetStreamTagsParams) GetCollection 

func (m *SetStreamTagsParams) GetCollection() string

func (*SetStreamTagsParams) GetExpectedPropertyVersion 

func (m *SetStreamTagsParams) GetExpectedPropertyVersion() uint64

func (*SetStreamTagsParams) GetRemove 

func (m *SetStreamTagsParams) GetRemove() []string

func (*SetStreamTagsParams) GetTags 

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

func (*SetStreamTagsParams) GetUuid 

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

func (*SetStreamTagsParams) ProtoMessage 

func (*SetStreamTagsParams) ProtoMessage()

func (*SetStreamTagsParams) Reset 

func (m *SetStreamTagsParams) Reset()

func (*SetStreamTagsParams) String 

func (m *SetStreamTagsParams) String() string

func (*SetStreamTagsParams) XXX_DiscardUnknown 

func (m *SetStreamTagsParams) XXX_DiscardUnknown()

func (*SetStreamTagsParams) XXX_Marshal 

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

func (*SetStreamTagsParams) XXX_Merge 

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

func (*SetStreamTagsParams) XXX_Size 

func (m *SetStreamTagsParams) XXX_Size() int

func (*SetStreamTagsParams) XXX_Unmarshal 

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

type SetStreamTagsResponse 

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

func (*SetStreamTagsResponse) Descriptor 

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

func (*SetStreamTagsResponse) GetStat 

func (m *SetStreamTagsResponse) GetStat() *Status

func (*SetStreamTagsResponse) ProtoMessage 

func (*SetStreamTagsResponse) ProtoMessage()

func (*SetStreamTagsResponse) Reset 

func (m *SetStreamTagsResponse) Reset()

func (*SetStreamTagsResponse) String 

func (m *SetStreamTagsResponse) String() string

func (*SetStreamTagsResponse) XXX_DiscardUnknown 

func (m *SetStreamTagsResponse) XXX_DiscardUnknown()

func (*SetStreamTagsResponse) XXX_Marshal 

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

func (*SetStreamTagsResponse) XXX_Merge 

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

func (*SetStreamTagsResponse) XXX_Size 

func (m *SetStreamTagsResponse) XXX_Size() int

func (*SetStreamTagsResponse) XXX_Unmarshal 

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

type StatPoint 

type StatPoint struct {
	Time                 int64    `protobuf:"fixed64,1,opt,name=time,proto3" json:"time,omitempty"`
	Min                  float64  `protobuf:"fixed64,2,opt,name=min,proto3" json:"min,omitempty"`
	Mean                 float64  `protobuf:"fixed64,3,opt,name=mean,proto3" json:"mean,omitempty"`
	Max                  float64  `protobuf:"fixed64,4,opt,name=max,proto3" json:"max,omitempty"`
	Count                uint64   `protobuf:"fixed64,5,opt,name=count,proto3" json:"count,omitempty"`
	Stddev               float64  `protobuf:"fixed64,6,opt,name=stddev,proto3" json:"stddev,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) GetStddev 

func (m *StatPoint) GetStddev() 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,proto3" json:"code,omitempty"`
	Msg                  string   `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
	Mash                 *Mash    `protobuf:"bytes,3,opt,name=mash,proto3" 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,proto3" json:"version,omitempty"`
	Label                string   `protobuf:"bytes,2,opt,name=label,proto3" 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,proto3" json:"collection,omitempty"`
	Tags                 []*KeyOptValue `protobuf:"bytes,3,rep,name=tags,proto3" json:"tags,omitempty"`
	Annotations          []*KeyOptValue `protobuf:"bytes,4,rep,name=annotations,proto3" json:"annotations,omitempty"`
	PropertyVersion      uint64         `protobuf:"varint,5,opt,name=propertyVersion,proto3" json:"propertyVersion,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*StreamDescriptor) Descriptor 

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

func (*StreamDescriptor) GetAnnotations 

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

func (*StreamDescriptor) GetCollection 

func (m *StreamDescriptor) GetCollection() string

func (*StreamDescriptor) GetPropertyVersion 

func (m *StreamDescriptor) GetPropertyVersion() uint64

func (*StreamDescriptor) GetTags 

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

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,proto3" json:"omitVersion,omitempty"`
	OmitDescriptor       bool     `protobuf:"varint,3,opt,name=omitDescriptor,proto3" json:"omitDescriptor,omitempty"`
	Role                 *Role    `protobuf:"bytes,100,opt,name=role,proto3" json:"role,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) GetRole 

func (m *StreamInfoParams) GetRole() *Role

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,proto3" json:"stat,omitempty"`
	VersionMajor         uint64            `protobuf:"varint,2,opt,name=versionMajor,proto3" json:"versionMajor,omitempty"`
	VersionMinor         uint64            `protobuf:"varint,3,opt,name=versionMinor,proto3" json:"versionMinor,omitempty"`
	Descriptor_          *StreamDescriptor `protobuf:"bytes,4,opt,name=descriptor,proto3" 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 WindowsParams 

type WindowsParams struct {
	Uuid                 []byte   `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	Start                int64    `protobuf:"fixed64,2,opt,name=start,proto3" json:"start,omitempty"`
	End                  int64    `protobuf:"fixed64,3,opt,name=end,proto3" json:"end,omitempty"`
	VersionMajor         uint64   `protobuf:"varint,4,opt,name=versionMajor,proto3" json:"versionMajor,omitempty"`
	Width                uint64   `protobuf:"varint,5,opt,name=width,proto3" json:"width,omitempty"`
	Depth                uint32   `protobuf:"varint,6,opt,name=depth,proto3" 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,proto3" json:"stat,omitempty"`
	VersionMajor         uint64       `protobuf:"varint,2,opt,name=versionMajor,proto3" json:"versionMajor,omitempty"`
	VersionMinor         uint64       `protobuf:"varint,3,opt,name=versionMinor,proto3" json:"versionMinor,omitempty"`
	Values               []*StatPoint `protobuf:"bytes,4,rep,name=values,proto3" 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.