v5api

package
v5.17.1 Latest Latest
Warning

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

 Go to latest Published: Feb 10, 2023 License: BSD-2-Clause Imports: 16 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 (
	MergePolicy_name = map[int32]string{
		0: "NEVER",
		1: "EQUAL",
		2: "RETAIN",
		3: "REPLACE",
	}
	MergePolicy_value = map[string]int32{
		"NEVER":   0,
		"EQUAL":   1,
		"RETAIN":  2,
		"REPLACE": 3,
	}
)

Enum value maps for MergePolicy.

View Source 
var (
	GenerateCSVParams_QueryType_name = map[int32]string{
		0: "ALIGNED_WINDOWS_QUERY",
		1: "WINDOWS_QUERY",
		2: "RAW_QUERY",
	}
	GenerateCSVParams_QueryType_value = map[string]int32{
		"ALIGNED_WINDOWS_QUERY": 0,
		"WINDOWS_QUERY":         1,
		"RAW_QUERY":             2,
	}
)

Enum value maps for GenerateCSVParams_QueryType.

View Source 
var BTrDB_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "v5api.BTrDB",
	HandlerType: (*BTrDBServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "StreamInfo",
			Handler:    _BTrDB_StreamInfo_Handler,
		},
		{
			MethodName: "SetStreamAnnotations",
			Handler:    _BTrDB_SetStreamAnnotations_Handler,
		},
		{
			MethodName: "SetStreamTags",
			Handler:    _BTrDB_SetStreamTags_Handler,
		},
		{
			MethodName: "Create",
			Handler:    _BTrDB_Create_Handler,
		},
		{
			MethodName: "Nearest",
			Handler:    _BTrDB_Nearest_Handler,
		},
		{
			MethodName: "Insert",
			Handler:    _BTrDB_Insert_Handler,
		},
		{
			MethodName: "Delete",
			Handler:    _BTrDB_Delete_Handler,
		},
		{
			MethodName: "Info",
			Handler:    _BTrDB_Info_Handler,
		},
		{
			MethodName: "FaultInject",
			Handler:    _BTrDB_FaultInject_Handler,
		},
		{
			MethodName: "Flush",
			Handler:    _BTrDB_Flush_Handler,
		},
		{
			MethodName: "Obliterate",
			Handler:    _BTrDB_Obliterate_Handler,
		},
		{
			MethodName: "GetMetadataUsage",
			Handler:    _BTrDB_GetMetadataUsage_Handler,
		},
		{
			MethodName: "SetCompactionConfig",
			Handler:    _BTrDB_SetCompactionConfig_Handler,
		},
		{
			MethodName: "GetCompactionConfig",
			Handler:    _BTrDB_GetCompactionConfig_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "RawValues",
			Handler:       _BTrDB_RawValues_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "MultiRawValues",
			Handler:       _BTrDB_MultiRawValues_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "AlignedWindows",
			Handler:       _BTrDB_AlignedWindows_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "Windows",
			Handler:       _BTrDB_Windows_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "ListCollections",
			Handler:       _BTrDB_ListCollections_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "LookupStreams",
			Handler:       _BTrDB_LookupStreams_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "Changes",
			Handler:       _BTrDB_Changes_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "GenerateCSV",
			Handler:       _BTrDB_GenerateCSV_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SQLQuery",
			Handler:       _BTrDB_SQLQuery_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "Subscribe",
			Handler:       _BTrDB_Subscribe_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "btrdb.proto",
}

BTrDB_ServiceDesc is the grpc.ServiceDesc for BTrDB service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_btrdb_proto protoreflect.FileDescriptor

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 RegisterBTrDBHandlerServer added in v5.11.2 

func RegisterBTrDBHandlerServer(ctx context.Context, mux *runtime.ServeMux, server BTrDBServer) error

RegisterBTrDBHandlerServer registers the http handlers for service BTrDB to "mux". UnaryRPC :call BTrDBServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterBTrDBHandlerFromEndpoint instead.

func RegisterBTrDBServer 

func RegisterBTrDBServer(s grpc.ServiceRegistrar, 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"`
	// contains filtered or unexported fields
}

func (*AlignedWindowsParams) Descriptor deprecated 

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

Deprecated: Use AlignedWindowsParams.ProtoReflect.Descriptor instead.

func (*AlignedWindowsParams) GetEnd 

func (x *AlignedWindowsParams) GetEnd() int64

func (*AlignedWindowsParams) GetPointWidth 

func (x *AlignedWindowsParams) GetPointWidth() uint32

func (*AlignedWindowsParams) GetStart 

func (x *AlignedWindowsParams) GetStart() int64

func (*AlignedWindowsParams) GetUuid 

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

func (*AlignedWindowsParams) GetVersionMajor 

func (x *AlignedWindowsParams) GetVersionMajor() uint64

func (*AlignedWindowsParams) ProtoMessage 

func (*AlignedWindowsParams) ProtoMessage()

func (*AlignedWindowsParams) ProtoReflect added in v5.12.2 

func (x *AlignedWindowsParams) ProtoReflect() protoreflect.Message

func (*AlignedWindowsParams) Reset 

func (x *AlignedWindowsParams) Reset()

func (*AlignedWindowsParams) String 

func (x *AlignedWindowsParams) String() string

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"`
	// contains filtered or unexported fields
}

func (*AlignedWindowsResponse) Descriptor deprecated 

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

Deprecated: Use AlignedWindowsResponse.ProtoReflect.Descriptor instead.

func (*AlignedWindowsResponse) GetStat 

func (x *AlignedWindowsResponse) GetStat() *Status

func (*AlignedWindowsResponse) GetValues 

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

func (*AlignedWindowsResponse) GetVersionMajor 

func (x *AlignedWindowsResponse) GetVersionMajor() uint64

func (*AlignedWindowsResponse) GetVersionMinor 

func (x *AlignedWindowsResponse) GetVersionMinor() uint64

func (*AlignedWindowsResponse) ProtoMessage 

func (*AlignedWindowsResponse) ProtoMessage()

func (*AlignedWindowsResponse) ProtoReflect added in v5.12.2 

func (x *AlignedWindowsResponse) ProtoReflect() protoreflect.Message

func (*AlignedWindowsResponse) Reset 

func (x *AlignedWindowsResponse) Reset()

func (*AlignedWindowsResponse) String 

func (x *AlignedWindowsResponse) String() string

type BTrDBClient 

type BTrDBClient interface {
	RawValues(ctx context.Context, in *RawValuesParams, opts ...grpc.CallOption) (BTrDB_RawValuesClient, error)
	MultiRawValues(ctx context.Context, in *MultiRawValuesParams, opts ...grpc.CallOption) (BTrDB_MultiRawValuesClient, 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)
	Subscribe(ctx context.Context, in *SubscriptionParams, opts ...grpc.CallOption) (BTrDB_SubscribeClient, 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://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewBTrDBClient 

func NewBTrDBClient(cc grpc.ClientConnInterface) BTrDBClient

type BTrDBServer 

type BTrDBServer interface {
	RawValues(*RawValuesParams, BTrDB_RawValuesServer) error
	MultiRawValues(*MultiRawValuesParams, BTrDB_MultiRawValuesServer) 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
	Subscribe(*SubscriptionParams, BTrDB_SubscribeServer) error
	SetCompactionConfig(context.Context, *SetCompactionConfigParams) (*SetCompactionConfigResponse, error)
	GetCompactionConfig(context.Context, *GetCompactionConfigParams) (*GetCompactionConfigResponse, error)
	// contains filtered or unexported methods
}

BTrDBServer is the server API for BTrDB service. All implementations must embed UnimplementedBTrDBServer for forward compatibility

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_MultiRawValuesClient added in v5.17.0 

type BTrDB_MultiRawValuesClient interface {
	Recv() (*MultiRawValuesResponse, error)
	grpc.ClientStream
}

type BTrDB_MultiRawValuesServer added in v5.17.0 

type BTrDB_MultiRawValuesServer interface {
	Send(*MultiRawValuesResponse) 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_SubscribeClient added in v5.17.0 

type BTrDB_SubscribeClient interface {
	Recv() (*SubscriptionResp, error)
	grpc.ClientStream
}

type BTrDB_SubscribeServer added in v5.17.0 

type BTrDB_SubscribeServer interface {
	Send(*SubscriptionResp) 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"`
	// contains filtered or unexported fields
}

func (*ChangedRange) Descriptor deprecated 

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

Deprecated: Use ChangedRange.ProtoReflect.Descriptor instead.

func (*ChangedRange) GetEnd 

func (x *ChangedRange) GetEnd() int64

func (*ChangedRange) GetStart 

func (x *ChangedRange) GetStart() int64

func (*ChangedRange) ProtoMessage 

func (*ChangedRange) ProtoMessage()

func (*ChangedRange) ProtoReflect added in v5.12.2 

func (x *ChangedRange) ProtoReflect() protoreflect.Message

func (*ChangedRange) Reset 

func (x *ChangedRange) Reset()

func (*ChangedRange) String 

func (x *ChangedRange) String() string

type ChangesParams 

type ChangesParams struct {
	Uuid       []byte `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	FromMajor  uint64 `protobuf:"varint,2,opt,name=fromMajor,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"`
	// contains filtered or unexported fields
}

func (*ChangesParams) Descriptor deprecated 

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

Deprecated: Use ChangesParams.ProtoReflect.Descriptor instead.

func (*ChangesParams) GetFromMajor 

func (x *ChangesParams) GetFromMajor() uint64

func (*ChangesParams) GetResolution 

func (x *ChangesParams) GetResolution() uint32

func (*ChangesParams) GetToMajor 

func (x *ChangesParams) GetToMajor() uint64

func (*ChangesParams) GetUuid 

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

func (*ChangesParams) ProtoMessage 

func (*ChangesParams) ProtoMessage()

func (*ChangesParams) ProtoReflect added in v5.12.2 

func (x *ChangesParams) ProtoReflect() protoreflect.Message

func (*ChangesParams) Reset 

func (x *ChangesParams) Reset()

func (*ChangesParams) String 

func (x *ChangesParams) String() string

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"`
	// contains filtered or unexported fields
}

func (*ChangesResponse) Descriptor deprecated 

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

Deprecated: Use ChangesResponse.ProtoReflect.Descriptor instead.

func (*ChangesResponse) GetRanges 

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

func (*ChangesResponse) GetStat 

func (x *ChangesResponse) GetStat() *Status

func (*ChangesResponse) GetVersionMajor 

func (x *ChangesResponse) GetVersionMajor() uint64

func (*ChangesResponse) GetVersionMinor 

func (x *ChangesResponse) GetVersionMinor() uint64

func (*ChangesResponse) ProtoMessage 

func (*ChangesResponse) ProtoMessage()

func (*ChangesResponse) ProtoReflect added in v5.12.2 

func (x *ChangesResponse) ProtoReflect() protoreflect.Message

func (*ChangesResponse) Reset 

func (x *ChangesResponse) Reset()

func (*ChangesResponse) String 

func (x *ChangesResponse) String() string

type CreateParams 

type CreateParams struct {
	Uuid        []byte         `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	Collection  string         `protobuf:"bytes,2,opt,name=collection,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"`
	// contains filtered or unexported fields
}

func (*CreateParams) Descriptor deprecated 

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

Deprecated: Use CreateParams.ProtoReflect.Descriptor instead.

func (*CreateParams) GetAnnotations 

func (x *CreateParams) GetAnnotations() []*KeyOptValue

func (*CreateParams) GetCollection 

func (x *CreateParams) GetCollection() string

func (*CreateParams) GetTags 

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

func (*CreateParams) GetUuid 

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

func (*CreateParams) ProtoMessage 

func (*CreateParams) ProtoMessage()

func (*CreateParams) ProtoReflect added in v5.12.2 

func (x *CreateParams) ProtoReflect() protoreflect.Message

func (*CreateParams) Reset 

func (x *CreateParams) Reset()

func (*CreateParams) String 

func (x *CreateParams) String() string

type CreateResponse 

type CreateResponse struct {
	Stat *Status `protobuf:"bytes,1,opt,name=stat,proto3" json:"stat,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateResponse) Descriptor deprecated 

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

Deprecated: Use CreateResponse.ProtoReflect.Descriptor instead.

func (*CreateResponse) GetStat 

func (x *CreateResponse) GetStat() *Status

func (*CreateResponse) ProtoMessage 

func (*CreateResponse) ProtoMessage()

func (*CreateResponse) ProtoReflect added in v5.12.2 

func (x *CreateResponse) ProtoReflect() protoreflect.Message

func (*CreateResponse) Reset 

func (x *CreateResponse) Reset()

func (*CreateResponse) String 

func (x *CreateResponse) String() string

type DeleteParams 

type DeleteParams struct {
	Uuid  []byte `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	Start int64  `protobuf:"fixed64,2,opt,name=start,proto3" json:"start,omitempty"`
	End   int64  `protobuf:"fixed64,3,opt,name=end,proto3" json:"end,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteParams) Descriptor deprecated 

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

Deprecated: Use DeleteParams.ProtoReflect.Descriptor instead.

func (*DeleteParams) GetEnd 

func (x *DeleteParams) GetEnd() int64

func (*DeleteParams) GetStart 

func (x *DeleteParams) GetStart() int64

func (*DeleteParams) GetUuid 

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

func (*DeleteParams) ProtoMessage 

func (*DeleteParams) ProtoMessage()

func (*DeleteParams) ProtoReflect added in v5.12.2 

func (x *DeleteParams) ProtoReflect() protoreflect.Message

func (*DeleteParams) Reset 

func (x *DeleteParams) Reset()

func (*DeleteParams) String 

func (x *DeleteParams) String() string

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"`
	// contains filtered or unexported fields
}

func (*DeleteResponse) Descriptor deprecated 

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

Deprecated: Use DeleteResponse.ProtoReflect.Descriptor instead.

func (*DeleteResponse) GetStat 

func (x *DeleteResponse) GetStat() *Status

func (*DeleteResponse) GetVersionMajor 

func (x *DeleteResponse) GetVersionMajor() uint64

func (*DeleteResponse) GetVersionMinor 

func (x *DeleteResponse) GetVersionMinor() uint64

func (*DeleteResponse) ProtoMessage 

func (*DeleteResponse) ProtoMessage()

func (*DeleteResponse) ProtoReflect added in v5.12.2 

func (x *DeleteResponse) ProtoReflect() protoreflect.Message

func (*DeleteResponse) Reset 

func (x *DeleteResponse) Reset()

func (*DeleteResponse) String 

func (x *DeleteResponse) String() string

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"`
	// contains filtered or unexported fields
}

func (*FaultInjectParams) Descriptor deprecated 

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

Deprecated: Use FaultInjectParams.ProtoReflect.Descriptor instead.

func (*FaultInjectParams) GetParams 

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

func (*FaultInjectParams) GetType 

func (x *FaultInjectParams) GetType() uint64

func (*FaultInjectParams) ProtoMessage 

func (*FaultInjectParams) ProtoMessage()

func (*FaultInjectParams) ProtoReflect added in v5.12.2 

func (x *FaultInjectParams) ProtoReflect() protoreflect.Message

func (*FaultInjectParams) Reset 

func (x *FaultInjectParams) Reset()

func (*FaultInjectParams) String 

func (x *FaultInjectParams) String() string

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"`
	// contains filtered or unexported fields
}

func (*FaultInjectResponse) Descriptor deprecated 

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

Deprecated: Use FaultInjectResponse.ProtoReflect.Descriptor instead.

func (*FaultInjectResponse) GetRv 

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

func (*FaultInjectResponse) GetStat 

func (x *FaultInjectResponse) GetStat() *Status

func (*FaultInjectResponse) ProtoMessage 

func (*FaultInjectResponse) ProtoMessage()

func (*FaultInjectResponse) ProtoReflect added in v5.12.2 

func (x *FaultInjectResponse) ProtoReflect() protoreflect.Message

func (*FaultInjectResponse) Reset 

func (x *FaultInjectResponse) Reset()

func (*FaultInjectResponse) String 

func (x *FaultInjectResponse) String() string

type FlushParams 

type FlushParams struct {
	Uuid []byte `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	// contains filtered or unexported fields
}

func (*FlushParams) Descriptor deprecated 

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

Deprecated: Use FlushParams.ProtoReflect.Descriptor instead.

func (*FlushParams) GetUuid 

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

func (*FlushParams) ProtoMessage 

func (*FlushParams) ProtoMessage()

func (*FlushParams) ProtoReflect added in v5.12.2 

func (x *FlushParams) ProtoReflect() protoreflect.Message

func (*FlushParams) Reset 

func (x *FlushParams) Reset()

func (*FlushParams) String 

func (x *FlushParams) String() string

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"`
	// contains filtered or unexported fields
}

func (*FlushResponse) Descriptor deprecated 

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

Deprecated: Use FlushResponse.ProtoReflect.Descriptor instead.

func (*FlushResponse) GetStat 

func (x *FlushResponse) GetStat() *Status

func (*FlushResponse) GetVersionMajor 

func (x *FlushResponse) GetVersionMajor() uint64

func (*FlushResponse) GetVersionMinor 

func (x *FlushResponse) GetVersionMinor() uint64

func (*FlushResponse) ProtoMessage 

func (*FlushResponse) ProtoMessage()

func (*FlushResponse) ProtoReflect added in v5.12.2 

func (x *FlushResponse) ProtoReflect() protoreflect.Message

func (*FlushResponse) Reset 

func (x *FlushResponse) Reset()

func (*FlushResponse) String 

func (x *FlushResponse) String() string

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"`
	// contains filtered or unexported fields
}

func (*GenerateCSVParams) Descriptor deprecated 

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

Deprecated: Use GenerateCSVParams.ProtoReflect.Descriptor instead.

func (*GenerateCSVParams) GetDepth 

func (x *GenerateCSVParams) GetDepth() uint32

func (*GenerateCSVParams) GetEndTime 

func (x *GenerateCSVParams) GetEndTime() int64

func (*GenerateCSVParams) GetIncludeVersions 

func (x *GenerateCSVParams) GetIncludeVersions() bool

func (*GenerateCSVParams) GetQueryType 

func (x *GenerateCSVParams) GetQueryType() GenerateCSVParams_QueryType

func (*GenerateCSVParams) GetStartTime 

func (x *GenerateCSVParams) GetStartTime() int64

func (*GenerateCSVParams) GetStreams 

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

func (*GenerateCSVParams) GetWindowSize 

func (x *GenerateCSVParams) GetWindowSize() uint64

func (*GenerateCSVParams) ProtoMessage 

func (*GenerateCSVParams) ProtoMessage()

func (*GenerateCSVParams) ProtoReflect added in v5.12.2 

func (x *GenerateCSVParams) ProtoReflect() protoreflect.Message

func (*GenerateCSVParams) Reset 

func (x *GenerateCSVParams) Reset()

func (*GenerateCSVParams) String 

func (x *GenerateCSVParams) String() string

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) Descriptor added in v5.12.2 

func (GenerateCSVParams_QueryType) Descriptor() protoreflect.EnumDescriptor

func (GenerateCSVParams_QueryType) Enum added in v5.12.2 

func (x GenerateCSVParams_QueryType) Enum() *GenerateCSVParams_QueryType

func (GenerateCSVParams_QueryType) EnumDescriptor deprecated 

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

Deprecated: Use GenerateCSVParams_QueryType.Descriptor instead.

func (GenerateCSVParams_QueryType) Number added in v5.12.2 

func (x GenerateCSVParams_QueryType) Number() protoreflect.EnumNumber

func (GenerateCSVParams_QueryType) String 

func (x GenerateCSVParams_QueryType) String() string

func (GenerateCSVParams_QueryType) Type added in v5.12.2 

func (GenerateCSVParams_QueryType) Type() protoreflect.EnumType

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"`
	// contains filtered or unexported fields
}

func (*GenerateCSVResponse) Descriptor deprecated 

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

Deprecated: Use GenerateCSVResponse.ProtoReflect.Descriptor instead.

func (*GenerateCSVResponse) GetIsHeader 

func (x *GenerateCSVResponse) GetIsHeader() bool

func (*GenerateCSVResponse) GetRow 

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

func (*GenerateCSVResponse) GetStat 

func (x *GenerateCSVResponse) GetStat() *Status

func (*GenerateCSVResponse) ProtoMessage 

func (*GenerateCSVResponse) ProtoMessage()

func (*GenerateCSVResponse) ProtoReflect added in v5.12.2 

func (x *GenerateCSVResponse) ProtoReflect() protoreflect.Message

func (*GenerateCSVResponse) Reset 

func (x *GenerateCSVResponse) Reset()

func (*GenerateCSVResponse) String 

func (x *GenerateCSVResponse) String() string

type GetCompactionConfigParams 

type GetCompactionConfigParams struct {

	//Which stream to query
	Uuid []byte `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	// contains filtered or unexported fields
}

func (*GetCompactionConfigParams) Descriptor deprecated 

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

Deprecated: Use GetCompactionConfigParams.ProtoReflect.Descriptor instead.

func (*GetCompactionConfigParams) GetUuid 

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

func (*GetCompactionConfigParams) ProtoMessage 

func (*GetCompactionConfigParams) ProtoMessage()

func (*GetCompactionConfigParams) ProtoReflect added in v5.12.2 

func (x *GetCompactionConfigParams) ProtoReflect() protoreflect.Message

func (*GetCompactionConfigParams) Reset 

func (x *GetCompactionConfigParams) Reset()

func (*GetCompactionConfigParams) String 

func (x *GetCompactionConfigParams) String() string

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"`
	// contains filtered or unexported fields
}

func (*GetCompactionConfigResponse) Descriptor deprecated 

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

Deprecated: Use GetCompactionConfigResponse.ProtoReflect.Descriptor instead.

func (*GetCompactionConfigResponse) GetCompactedVersion 

func (x *GetCompactionConfigResponse) GetCompactedVersion() uint64

func (*GetCompactionConfigResponse) GetLatestMajorVersion 

func (x *GetCompactionConfigResponse) GetLatestMajorVersion() uint64

func (*GetCompactionConfigResponse) GetReducedResolutionRanges 

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

func (*GetCompactionConfigResponse) GetStat 

func (x *GetCompactionConfigResponse) GetStat() *Status

func (*GetCompactionConfigResponse) GetTargetArchiveHorizon 

func (x *GetCompactionConfigResponse) GetTargetArchiveHorizon() uint64

func (*GetCompactionConfigResponse) ProtoMessage 

func (*GetCompactionConfigResponse) ProtoMessage()

func (*GetCompactionConfigResponse) ProtoReflect added in v5.12.2 

func (x *GetCompactionConfigResponse) ProtoReflect() protoreflect.Message

func (*GetCompactionConfigResponse) Reset 

func (x *GetCompactionConfigResponse) Reset()

func (*GetCompactionConfigResponse) String 

func (x *GetCompactionConfigResponse) String() string

type InfoParams 

type InfoParams struct {
	// contains filtered or unexported fields
}

func (*InfoParams) Descriptor deprecated 

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

Deprecated: Use InfoParams.ProtoReflect.Descriptor instead.

func (*InfoParams) ProtoMessage 

func (*InfoParams) ProtoMessage()

func (*InfoParams) ProtoReflect added in v5.12.2 

func (x *InfoParams) ProtoReflect() protoreflect.Message

func (*InfoParams) Reset 

func (x *InfoParams) Reset()

func (*InfoParams) String 

func (x *InfoParams) String() string

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"`
	// contains filtered or unexported fields
}

func (*InfoResponse) Descriptor deprecated 

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

Deprecated: Use InfoResponse.ProtoReflect.Descriptor instead.

func (*InfoResponse) GetBuild 

func (x *InfoResponse) GetBuild() string

func (*InfoResponse) GetMajorVersion 

func (x *InfoResponse) GetMajorVersion() uint32

func (*InfoResponse) GetMash 

func (x *InfoResponse) GetMash() *Mash

func (*InfoResponse) GetMinorVersion 

func (x *InfoResponse) GetMinorVersion() uint32

func (*InfoResponse) GetProxy 

func (x *InfoResponse) GetProxy() *ProxyInfo

func (*InfoResponse) GetStat 

func (x *InfoResponse) GetStat() *Status

func (*InfoResponse) ProtoMessage 

func (*InfoResponse) ProtoMessage()

func (*InfoResponse) ProtoReflect added in v5.12.2 

func (x *InfoResponse) ProtoReflect() protoreflect.Message

func (*InfoResponse) Reset 

func (x *InfoResponse) Reset()

func (*InfoResponse) String 

func (x *InfoResponse) String() string

type InsertParams 

type InsertParams struct {
	Uuid        []byte      `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	Sync        bool        `protobuf:"varint,2,opt,name=sync,proto3" json:"sync,omitempty"`
	MergePolicy MergePolicy `protobuf:"varint,4,opt,name=merge_policy,json=mergePolicy,proto3,enum=v5api.MergePolicy" json:"merge_policy,omitempty"`
	Rounding    *RoundSpec  `protobuf:"bytes,5,opt,name=rounding,proto3" json:"rounding,omitempty"`
	Values      []*RawPoint `protobuf:"bytes,3,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*InsertParams) Descriptor deprecated 

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

Deprecated: Use InsertParams.ProtoReflect.Descriptor instead.

func (*InsertParams) GetMergePolicy added in v5.11.2 

func (x *InsertParams) GetMergePolicy() MergePolicy

func (*InsertParams) GetRounding added in v5.12.2 

func (x *InsertParams) GetRounding() *RoundSpec

func (*InsertParams) GetSync 

func (x *InsertParams) GetSync() bool

func (*InsertParams) GetUuid 

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

func (*InsertParams) GetValues 

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

func (*InsertParams) ProtoMessage 

func (*InsertParams) ProtoMessage()

func (*InsertParams) ProtoReflect added in v5.12.2 

func (x *InsertParams) ProtoReflect() protoreflect.Message

func (*InsertParams) Reset 

func (x *InsertParams) Reset()

func (*InsertParams) String 

func (x *InsertParams) String() string

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"`
	// contains filtered or unexported fields
}

func (*InsertResponse) Descriptor deprecated 

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

Deprecated: Use InsertResponse.ProtoReflect.Descriptor instead.

func (*InsertResponse) GetStat 

func (x *InsertResponse) GetStat() *Status

func (*InsertResponse) GetVersionMajor 

func (x *InsertResponse) GetVersionMajor() uint64

func (*InsertResponse) GetVersionMinor 

func (x *InsertResponse) GetVersionMinor() uint64

func (*InsertResponse) ProtoMessage 

func (*InsertResponse) ProtoMessage()

func (*InsertResponse) ProtoReflect added in v5.12.2 

func (x *InsertResponse) ProtoReflect() protoreflect.Message

func (*InsertResponse) Reset 

func (x *InsertResponse) Reset()

func (*InsertResponse) String 

func (x *InsertResponse) String() string

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"`
	// contains filtered or unexported fields
}

func (*KeyCount) Descriptor deprecated 

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

Deprecated: Use KeyCount.ProtoReflect.Descriptor instead.

func (*KeyCount) GetCount 

func (x *KeyCount) GetCount() uint64

func (*KeyCount) GetKey 

func (x *KeyCount) GetKey() string

func (*KeyCount) ProtoMessage 

func (*KeyCount) ProtoMessage()

func (*KeyCount) ProtoReflect added in v5.12.2 

func (x *KeyCount) ProtoReflect() protoreflect.Message

func (*KeyCount) Reset 

func (x *KeyCount) Reset()

func (*KeyCount) String 

func (x *KeyCount) String() string

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"`
	// contains filtered or unexported fields
}

func (*KeyOptValue) Descriptor deprecated 

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

Deprecated: Use KeyOptValue.ProtoReflect.Descriptor instead.

func (*KeyOptValue) GetKey 

func (x *KeyOptValue) GetKey() string

func (*KeyOptValue) GetVal 

func (x *KeyOptValue) GetVal() *OptValue

func (*KeyOptValue) ProtoMessage 

func (*KeyOptValue) ProtoMessage()

func (*KeyOptValue) ProtoReflect added in v5.12.2 

func (x *KeyOptValue) ProtoReflect() protoreflect.Message

func (*KeyOptValue) Reset 

func (x *KeyOptValue) Reset()

func (*KeyOptValue) String 

func (x *KeyOptValue) String() string

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"`
	// contains filtered or unexported fields
}

func (*KeyValue) Descriptor deprecated 

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

Deprecated: Use KeyValue.ProtoReflect.Descriptor instead.

func (*KeyValue) GetKey 

func (x *KeyValue) GetKey() string

func (*KeyValue) GetValue 

func (x *KeyValue) GetValue() string

func (*KeyValue) ProtoMessage 

func (*KeyValue) ProtoMessage()

func (*KeyValue) ProtoReflect added in v5.12.2 

func (x *KeyValue) ProtoReflect() protoreflect.Message

func (*KeyValue) Reset 

func (x *KeyValue) Reset()

func (*KeyValue) String 

func (x *KeyValue) String() string

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"`
	// contains filtered or unexported fields
}

func (*ListCollectionsParams) Descriptor deprecated 

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

Deprecated: Use ListCollectionsParams.ProtoReflect.Descriptor instead.

func (*ListCollectionsParams) GetPrefix 

func (x *ListCollectionsParams) GetPrefix() string

func (*ListCollectionsParams) GetRole 

func (x *ListCollectionsParams) GetRole() *Role

func (*ListCollectionsParams) ProtoMessage 

func (*ListCollectionsParams) ProtoMessage()

func (*ListCollectionsParams) ProtoReflect added in v5.12.2 

func (x *ListCollectionsParams) ProtoReflect() protoreflect.Message

func (*ListCollectionsParams) Reset 

func (x *ListCollectionsParams) Reset()

func (*ListCollectionsParams) String 

func (x *ListCollectionsParams) String() string

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"`
	// contains filtered or unexported fields
}

func (*ListCollectionsResponse) Descriptor deprecated 

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

Deprecated: Use ListCollectionsResponse.ProtoReflect.Descriptor instead.

func (*ListCollectionsResponse) GetCollections 

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

func (*ListCollectionsResponse) GetStat 

func (x *ListCollectionsResponse) GetStat() *Status

func (*ListCollectionsResponse) ProtoMessage 

func (*ListCollectionsResponse) ProtoMessage()

func (*ListCollectionsResponse) ProtoReflect added in v5.12.2 

func (x *ListCollectionsResponse) ProtoReflect() protoreflect.Message

func (*ListCollectionsResponse) Reset 

func (x *ListCollectionsResponse) Reset()

func (*ListCollectionsResponse) String 

func (x *ListCollectionsResponse) String() string

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"`
	// contains filtered or unexported fields
}

func (*LookupStreamsParams) Descriptor deprecated 

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

Deprecated: Use LookupStreamsParams.ProtoReflect.Descriptor instead.

func (*LookupStreamsParams) GetAnnotations 

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

func (*LookupStreamsParams) GetCollection 

func (x *LookupStreamsParams) GetCollection() string

func (*LookupStreamsParams) GetIsCollectionPrefix 

func (x *LookupStreamsParams) GetIsCollectionPrefix() bool

func (*LookupStreamsParams) GetRole 

func (x *LookupStreamsParams) GetRole() *Role

func (*LookupStreamsParams) GetTags 

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

func (*LookupStreamsParams) ProtoMessage 

func (*LookupStreamsParams) ProtoMessage()

func (*LookupStreamsParams) ProtoReflect added in v5.12.2 

func (x *LookupStreamsParams) ProtoReflect() protoreflect.Message

func (*LookupStreamsParams) Reset 

func (x *LookupStreamsParams) Reset()

func (*LookupStreamsParams) String 

func (x *LookupStreamsParams) String() string

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"`
	// contains filtered or unexported fields
}

func (*LookupStreamsResponse) Descriptor deprecated 

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

Deprecated: Use LookupStreamsResponse.ProtoReflect.Descriptor instead.

func (*LookupStreamsResponse) GetResults 

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

func (*LookupStreamsResponse) GetStat 

func (x *LookupStreamsResponse) GetStat() *Status

func (*LookupStreamsResponse) ProtoMessage 

func (*LookupStreamsResponse) ProtoMessage()

func (*LookupStreamsResponse) ProtoReflect added in v5.12.2 

func (x *LookupStreamsResponse) ProtoReflect() protoreflect.Message

func (*LookupStreamsResponse) Reset 

func (x *LookupStreamsResponse) Reset()

func (*LookupStreamsResponse) String 

func (x *LookupStreamsResponse) String() string

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"`
	// contains filtered or unexported fields
}

func (*Mash) Descriptor deprecated 

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

Deprecated: Use Mash.ProtoReflect.Descriptor instead.

func (*Mash) GetHealthy 

func (x *Mash) GetHealthy() bool

func (*Mash) GetLeader 

func (x *Mash) GetLeader() string

func (*Mash) GetLeaderRevision 

func (x *Mash) GetLeaderRevision() int64

func (*Mash) GetMembers 

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

func (*Mash) GetRevision 

func (x *Mash) GetRevision() int64

func (*Mash) GetTotalWeight 

func (x *Mash) GetTotalWeight() int64

func (*Mash) GetUnmapped 

func (x *Mash) GetUnmapped() float64

func (*Mash) ProtoMessage 

func (*Mash) ProtoMessage()

func (*Mash) ProtoReflect added in v5.12.2 

func (x *Mash) ProtoReflect() protoreflect.Message

func (*Mash) Reset 

func (x *Mash) Reset()

func (*Mash) String 

func (x *Mash) String() string

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"`
	// contains filtered or unexported fields
}

func (*Member) Descriptor deprecated 

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

Deprecated: Use Member.ProtoReflect.Descriptor instead.

func (*Member) GetEnabled 

func (x *Member) GetEnabled() bool

func (*Member) GetEnd 

func (x *Member) GetEnd() int64

func (*Member) GetGrpcEndpoints 

func (x *Member) GetGrpcEndpoints() string

func (*Member) GetHash 

func (x *Member) GetHash() uint32

func (*Member) GetHttpEndpoints 

func (x *Member) GetHttpEndpoints() string

func (*Member) GetIn 

func (x *Member) GetIn() bool

func (*Member) GetNodename 

func (x *Member) GetNodename() string

func (*Member) GetReadPreference 

func (x *Member) GetReadPreference() float64

func (*Member) GetStart 

func (x *Member) GetStart() int64

func (*Member) GetUp 

func (x *Member) GetUp() bool

func (*Member) GetWeight 

func (x *Member) GetWeight() int64

func (*Member) ProtoMessage 

func (*Member) ProtoMessage()

func (*Member) ProtoReflect added in v5.12.2 

func (x *Member) ProtoReflect() protoreflect.Message

func (*Member) Reset 

func (x *Member) Reset()

func (*Member) String 

func (x *Member) String() string

type MergePolicy added in v5.11.2 

type MergePolicy int32
const (
	MergePolicy_NEVER   MergePolicy = 0 // Never merge
	MergePolicy_EQUAL   MergePolicy = 1 // Merge identical (key, value) pairs
	MergePolicy_RETAIN  MergePolicy = 2 // When timestamps are equal, keep old value
	MergePolicy_REPLACE MergePolicy = 3 // When timestamps are equal, keep new value
)

func (MergePolicy) Descriptor added in v5.12.2 

func (MergePolicy) Descriptor() protoreflect.EnumDescriptor

func (MergePolicy) Enum added in v5.12.2 

func (x MergePolicy) Enum() *MergePolicy

func (MergePolicy) EnumDescriptor deprecated added in v5.11.2 

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

Deprecated: Use MergePolicy.Descriptor instead.

func (MergePolicy) Number added in v5.12.2 

func (x MergePolicy) Number() protoreflect.EnumNumber

func (MergePolicy) String added in v5.11.2 

func (x MergePolicy) String() string

func (MergePolicy) Type added in v5.12.2 

func (MergePolicy) Type() protoreflect.EnumType

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"`
	// contains filtered or unexported fields
}

func (*MetadataUsageParams) Descriptor deprecated 

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

Deprecated: Use MetadataUsageParams.ProtoReflect.Descriptor instead.

func (*MetadataUsageParams) GetPrefix 

func (x *MetadataUsageParams) GetPrefix() string

func (*MetadataUsageParams) GetRole 

func (x *MetadataUsageParams) GetRole() *Role

func (*MetadataUsageParams) ProtoMessage 

func (*MetadataUsageParams) ProtoMessage()

func (*MetadataUsageParams) ProtoReflect added in v5.12.2 

func (x *MetadataUsageParams) ProtoReflect() protoreflect.Message

func (*MetadataUsageParams) Reset 

func (x *MetadataUsageParams) Reset()

func (*MetadataUsageParams) String 

func (x *MetadataUsageParams) String() string

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"`
	// contains filtered or unexported fields
}

func (*MetadataUsageResponse) Descriptor deprecated 

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

Deprecated: Use MetadataUsageResponse.ProtoReflect.Descriptor instead.

func (*MetadataUsageResponse) GetAnnotations 

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

func (*MetadataUsageResponse) GetStat 

func (x *MetadataUsageResponse) GetStat() *Status

func (*MetadataUsageResponse) GetTags 

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

func (*MetadataUsageResponse) ProtoMessage 

func (*MetadataUsageResponse) ProtoMessage()

func (*MetadataUsageResponse) ProtoReflect added in v5.12.2 

func (x *MetadataUsageResponse) ProtoReflect() protoreflect.Message

func (*MetadataUsageResponse) Reset 

func (x *MetadataUsageResponse) Reset()

func (*MetadataUsageResponse) String 

func (x *MetadataUsageResponse) String() string

type MultiRawValuesParams added in v5.17.0 

type MultiRawValuesParams struct {
	Uuid         [][]byte `protobuf:"bytes,1,rep,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"`
	PeriodNs     int64    `protobuf:"varint,5,opt,name=periodNs,proto3" json:"periodNs,omitempty"`
	// contains filtered or unexported fields
}

func (*MultiRawValuesParams) Descriptor deprecated added in v5.17.0 

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

Deprecated: Use MultiRawValuesParams.ProtoReflect.Descriptor instead.

func (*MultiRawValuesParams) GetEnd added in v5.17.0 

func (x *MultiRawValuesParams) GetEnd() int64

func (*MultiRawValuesParams) GetPeriodNs added in v5.17.0 

func (x *MultiRawValuesParams) GetPeriodNs() int64

func (*MultiRawValuesParams) GetStart added in v5.17.0 

func (x *MultiRawValuesParams) GetStart() int64

func (*MultiRawValuesParams) GetUuid added in v5.17.0 

func (x *MultiRawValuesParams) GetUuid() [][]byte

func (*MultiRawValuesParams) GetVersionMajor added in v5.17.0 

func (x *MultiRawValuesParams) GetVersionMajor() uint64

func (*MultiRawValuesParams) ProtoMessage added in v5.17.0 

func (*MultiRawValuesParams) ProtoMessage()

func (*MultiRawValuesParams) ProtoReflect added in v5.17.0 

func (x *MultiRawValuesParams) ProtoReflect() protoreflect.Message

func (*MultiRawValuesParams) Reset added in v5.17.0 

func (x *MultiRawValuesParams) Reset()

func (*MultiRawValuesParams) String added in v5.17.0 

func (x *MultiRawValuesParams) String() string

type MultiRawValuesResponse added in v5.17.0 

type MultiRawValuesResponse struct {
	Stat         *Status        `protobuf:"bytes,1,opt,name=stat,proto3" json:"stat,omitempty"`
	VersionMajor []uint64       `protobuf:"varint,2,rep,packed,name=versionMajor,proto3" json:"versionMajor,omitempty"`
	VersionMinor []uint64       `protobuf:"varint,3,rep,packed,name=versionMinor,proto3" json:"versionMinor,omitempty"`
	Values       []*RawPointVec `protobuf:"bytes,4,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*MultiRawValuesResponse) Descriptor deprecated added in v5.17.0 

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

Deprecated: Use MultiRawValuesResponse.ProtoReflect.Descriptor instead.

func (*MultiRawValuesResponse) GetStat added in v5.17.0 

func (x *MultiRawValuesResponse) GetStat() *Status

func (*MultiRawValuesResponse) GetValues added in v5.17.0 

func (x *MultiRawValuesResponse) GetValues() []*RawPointVec

func (*MultiRawValuesResponse) GetVersionMajor added in v5.17.0 

func (x *MultiRawValuesResponse) GetVersionMajor() []uint64

func (*MultiRawValuesResponse) GetVersionMinor added in v5.17.0 

func (x *MultiRawValuesResponse) GetVersionMinor() []uint64

func (*MultiRawValuesResponse) ProtoMessage added in v5.17.0 

func (*MultiRawValuesResponse) ProtoMessage()

func (*MultiRawValuesResponse) ProtoReflect added in v5.17.0 

func (x *MultiRawValuesResponse) ProtoReflect() protoreflect.Message

func (*MultiRawValuesResponse) Reset added in v5.17.0 

func (x *MultiRawValuesResponse) Reset()

func (*MultiRawValuesResponse) String added in v5.17.0 

func (x *MultiRawValuesResponse) String() string

type NearestParams 

type NearestParams struct {
	Uuid         []byte `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	Time         int64  `protobuf:"fixed64,2,opt,name=time,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"`
	// contains filtered or unexported fields
}

func (*NearestParams) Descriptor deprecated 

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

Deprecated: Use NearestParams.ProtoReflect.Descriptor instead.

func (*NearestParams) GetBackward 

func (x *NearestParams) GetBackward() bool

func (*NearestParams) GetTime 

func (x *NearestParams) GetTime() int64

func (*NearestParams) GetUuid 

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

func (*NearestParams) GetVersionMajor 

func (x *NearestParams) GetVersionMajor() uint64

func (*NearestParams) ProtoMessage 

func (*NearestParams) ProtoMessage()

func (*NearestParams) ProtoReflect added in v5.12.2 

func (x *NearestParams) ProtoReflect() protoreflect.Message

func (*NearestParams) Reset 

func (x *NearestParams) Reset()

func (*NearestParams) String 

func (x *NearestParams) String() string

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"`
	// contains filtered or unexported fields
}

func (*NearestResponse) Descriptor deprecated 

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

Deprecated: Use NearestResponse.ProtoReflect.Descriptor instead.

func (*NearestResponse) GetStat 

func (x *NearestResponse) GetStat() *Status

func (*NearestResponse) GetValue 

func (x *NearestResponse) GetValue() *RawPoint

func (*NearestResponse) GetVersionMajor 

func (x *NearestResponse) GetVersionMajor() uint64

func (*NearestResponse) GetVersionMinor 

func (x *NearestResponse) GetVersionMinor() uint64

func (*NearestResponse) ProtoMessage 

func (*NearestResponse) ProtoMessage()

func (*NearestResponse) ProtoReflect added in v5.12.2 

func (x *NearestResponse) ProtoReflect() protoreflect.Message

func (*NearestResponse) Reset 

func (x *NearestResponse) Reset()

func (*NearestResponse) String 

func (x *NearestResponse) String() string

type ObliterateParams 

type ObliterateParams struct {
	Uuid []byte `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	// contains filtered or unexported fields
}

func (*ObliterateParams) Descriptor deprecated 

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

Deprecated: Use ObliterateParams.ProtoReflect.Descriptor instead.

func (*ObliterateParams) GetUuid 

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

func (*ObliterateParams) ProtoMessage 

func (*ObliterateParams) ProtoMessage()

func (*ObliterateParams) ProtoReflect added in v5.12.2 

func (x *ObliterateParams) ProtoReflect() protoreflect.Message

func (*ObliterateParams) Reset 

func (x *ObliterateParams) Reset()

func (*ObliterateParams) String 

func (x *ObliterateParams) String() string

type ObliterateResponse 

type ObliterateResponse struct {
	Stat *Status `protobuf:"bytes,1,opt,name=stat,proto3" json:"stat,omitempty"`
	// contains filtered or unexported fields
}

func (*ObliterateResponse) Descriptor deprecated 

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

Deprecated: Use ObliterateResponse.ProtoReflect.Descriptor instead.

func (*ObliterateResponse) GetStat 

func (x *ObliterateResponse) GetStat() *Status

func (*ObliterateResponse) ProtoMessage 

func (*ObliterateResponse) ProtoMessage()

func (*ObliterateResponse) ProtoReflect added in v5.12.2 

func (x *ObliterateResponse) ProtoReflect() protoreflect.Message

func (*ObliterateResponse) Reset 

func (x *ObliterateResponse) Reset()

func (*ObliterateResponse) String 

func (x *ObliterateResponse) String() string

type OptValue 

type OptValue struct {
	Value string `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*OptValue) Descriptor deprecated 

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

Deprecated: Use OptValue.ProtoReflect.Descriptor instead.

func (*OptValue) GetValue 

func (x *OptValue) GetValue() string

func (*OptValue) ProtoMessage 

func (*OptValue) ProtoMessage()

func (*OptValue) ProtoReflect added in v5.12.2 

func (x *OptValue) ProtoReflect() protoreflect.Message

func (*OptValue) Reset 

func (x *OptValue) Reset()

func (*OptValue) String 

func (x *OptValue) String() string

type ProxyInfo 

type ProxyInfo struct {
	ProxyEndpoints []string `protobuf:"bytes,1,rep,name=proxyEndpoints,proto3" json:"proxyEndpoints,omitempty"`
	// contains filtered or unexported fields
}

func (*ProxyInfo) Descriptor deprecated 

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

Deprecated: Use ProxyInfo.ProtoReflect.Descriptor instead.

func (*ProxyInfo) GetProxyEndpoints 

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

func (*ProxyInfo) ProtoMessage 

func (*ProxyInfo) ProtoMessage()

func (*ProxyInfo) ProtoReflect added in v5.12.2 

func (x *ProxyInfo) ProtoReflect() protoreflect.Message

func (*ProxyInfo) Reset 

func (x *ProxyInfo) Reset()

func (*ProxyInfo) String 

func (x *ProxyInfo) String() string

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"`
	// contains filtered or unexported fields
}

func (*RawPoint) Descriptor deprecated 

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

Deprecated: Use RawPoint.ProtoReflect.Descriptor instead.

func (*RawPoint) GetTime 

func (x *RawPoint) GetTime() int64

func (*RawPoint) GetValue 

func (x *RawPoint) GetValue() float64

func (*RawPoint) ProtoMessage 

func (*RawPoint) ProtoMessage()

func (*RawPoint) ProtoReflect added in v5.12.2 

func (x *RawPoint) ProtoReflect() protoreflect.Message

func (*RawPoint) Reset 

func (x *RawPoint) Reset()

func (*RawPoint) String 

func (x *RawPoint) String() string

type RawPointVec added in v5.17.0 

type RawPointVec struct {
	Time  int64     `protobuf:"fixed64,1,opt,name=time,proto3" json:"time,omitempty"`
	Value []float64 `protobuf:"fixed64,2,rep,packed,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*RawPointVec) Descriptor deprecated added in v5.17.0 

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

Deprecated: Use RawPointVec.ProtoReflect.Descriptor instead.

func (*RawPointVec) GetTime added in v5.17.0 

func (x *RawPointVec) GetTime() int64

func (*RawPointVec) GetValue added in v5.17.0 

func (x *RawPointVec) GetValue() []float64

func (*RawPointVec) ProtoMessage added in v5.17.0 

func (*RawPointVec) ProtoMessage()

func (*RawPointVec) ProtoReflect added in v5.17.0 

func (x *RawPointVec) ProtoReflect() protoreflect.Message

func (*RawPointVec) Reset added in v5.17.0 

func (x *RawPointVec) Reset()

func (*RawPointVec) String added in v5.17.0 

func (x *RawPointVec) String() string

type RawValuesParams 

type RawValuesParams struct {
	Uuid         []byte `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	Start        int64  `protobuf:"fixed64,2,opt,name=start,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"`
	// contains filtered or unexported fields
}

func (*RawValuesParams) Descriptor deprecated 

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

Deprecated: Use RawValuesParams.ProtoReflect.Descriptor instead.

func (*RawValuesParams) GetEnd 

func (x *RawValuesParams) GetEnd() int64

func (*RawValuesParams) GetStart 

func (x *RawValuesParams) GetStart() int64

func (*RawValuesParams) GetUuid 

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

func (*RawValuesParams) GetVersionMajor 

func (x *RawValuesParams) GetVersionMajor() uint64

func (*RawValuesParams) ProtoMessage 

func (*RawValuesParams) ProtoMessage()

func (*RawValuesParams) ProtoReflect added in v5.12.2 

func (x *RawValuesParams) ProtoReflect() protoreflect.Message

func (*RawValuesParams) Reset 

func (x *RawValuesParams) Reset()

func (*RawValuesParams) String 

func (x *RawValuesParams) String() string

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"`
	// contains filtered or unexported fields
}

func (*RawValuesResponse) Descriptor deprecated 

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

Deprecated: Use RawValuesResponse.ProtoReflect.Descriptor instead.

func (*RawValuesResponse) GetStat 

func (x *RawValuesResponse) GetStat() *Status

func (*RawValuesResponse) GetValues 

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

func (*RawValuesResponse) GetVersionMajor 

func (x *RawValuesResponse) GetVersionMajor() uint64

func (*RawValuesResponse) GetVersionMinor 

func (x *RawValuesResponse) GetVersionMinor() uint64

func (*RawValuesResponse) ProtoMessage 

func (*RawValuesResponse) ProtoMessage()

func (*RawValuesResponse) ProtoReflect added in v5.12.2 

func (x *RawValuesResponse) ProtoReflect() protoreflect.Message

func (*RawValuesResponse) Reset 

func (x *RawValuesResponse) Reset()

func (*RawValuesResponse) String 

func (x *RawValuesResponse) String() string

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"`
	// contains filtered or unexported fields
}

func (*ReducedResolutionRange) Descriptor deprecated 

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

Deprecated: Use ReducedResolutionRange.ProtoReflect.Descriptor instead.

func (*ReducedResolutionRange) GetEnd 

func (x *ReducedResolutionRange) GetEnd() int64

func (*ReducedResolutionRange) GetResolution 

func (x *ReducedResolutionRange) GetResolution() uint32

func (*ReducedResolutionRange) GetStart 

func (x *ReducedResolutionRange) GetStart() int64

func (*ReducedResolutionRange) ProtoMessage 

func (*ReducedResolutionRange) ProtoMessage()

func (*ReducedResolutionRange) ProtoReflect added in v5.12.2 

func (x *ReducedResolutionRange) ProtoReflect() protoreflect.Message

func (*ReducedResolutionRange) Reset 

func (x *ReducedResolutionRange) Reset()

func (*ReducedResolutionRange) String 

func (x *ReducedResolutionRange) String() string

type Role 

type Role struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*Role) Descriptor deprecated 

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

Deprecated: Use Role.ProtoReflect.Descriptor instead.

func (*Role) GetName 

func (x *Role) GetName() string

func (*Role) ProtoMessage 

func (*Role) ProtoMessage()

func (*Role) ProtoReflect added in v5.12.2 

func (x *Role) ProtoReflect() protoreflect.Message

func (*Role) Reset 

func (x *Role) Reset()

func (*Role) String 

func (x *Role) String() string

type RoundSpec added in v5.12.2 

type RoundSpec struct {

	// Types that are assignable to Spec:
	//	*RoundSpec_Bits
	Spec isRoundSpec_Spec `protobuf_oneof:"spec"`
	// contains filtered or unexported fields
}

func (*RoundSpec) Descriptor deprecated added in v5.12.2 

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

Deprecated: Use RoundSpec.ProtoReflect.Descriptor instead.

func (*RoundSpec) GetBits added in v5.12.2 

func (x *RoundSpec) GetBits() int32

func (*RoundSpec) GetSpec added in v5.12.2 

func (m *RoundSpec) GetSpec() isRoundSpec_Spec

func (*RoundSpec) ProtoMessage added in v5.12.2 

func (*RoundSpec) ProtoMessage()

func (*RoundSpec) ProtoReflect added in v5.12.2 

func (x *RoundSpec) ProtoReflect() protoreflect.Message

func (*RoundSpec) Reset added in v5.12.2 

func (x *RoundSpec) Reset()

func (*RoundSpec) String added in v5.12.2 

func (x *RoundSpec) String() string

type RoundSpec_Bits added in v5.12.2 

type RoundSpec_Bits struct {
	Bits int32 `protobuf:"varint,2,opt,name=bits,proto3,oneof"` // Round to a bit boundary
}

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"`
	// contains filtered or unexported fields
}

func (*SQLQueryParams) Descriptor deprecated 

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

Deprecated: Use SQLQueryParams.ProtoReflect.Descriptor instead.

func (*SQLQueryParams) GetParams 

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

func (*SQLQueryParams) GetQuery 

func (x *SQLQueryParams) GetQuery() string

func (*SQLQueryParams) GetRole 

func (x *SQLQueryParams) GetRole() *Role

func (*SQLQueryParams) ProtoMessage 

func (*SQLQueryParams) ProtoMessage()

func (*SQLQueryParams) ProtoReflect added in v5.12.2 

func (x *SQLQueryParams) ProtoReflect() protoreflect.Message

func (*SQLQueryParams) Reset 

func (x *SQLQueryParams) Reset()

func (*SQLQueryParams) String 

func (x *SQLQueryParams) String() string

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"`
	// contains filtered or unexported fields
}

func (*SQLQueryResponse) Descriptor deprecated 

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

Deprecated: Use SQLQueryResponse.ProtoReflect.Descriptor instead.

func (*SQLQueryResponse) GetSQLQueryRow 

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

func (*SQLQueryResponse) GetStat 

func (x *SQLQueryResponse) GetStat() *Status

func (*SQLQueryResponse) ProtoMessage 

func (*SQLQueryResponse) ProtoMessage()

func (*SQLQueryResponse) ProtoReflect added in v5.12.2 

func (x *SQLQueryResponse) ProtoReflect() protoreflect.Message

func (*SQLQueryResponse) Reset 

func (x *SQLQueryResponse) Reset()

func (*SQLQueryResponse) String 

func (x *SQLQueryResponse) String() string

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"`
	// contains filtered or unexported fields
}

func (*SetCompactionConfigParams) Descriptor deprecated 

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

Deprecated: Use SetCompactionConfigParams.ProtoReflect.Descriptor instead.

func (*SetCompactionConfigParams) GetCompactedVersion 

func (x *SetCompactionConfigParams) GetCompactedVersion() uint64

func (*SetCompactionConfigParams) GetReducedResolutionRanges 

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

func (*SetCompactionConfigParams) GetTargetArchiveHorizon 

func (x *SetCompactionConfigParams) GetTargetArchiveHorizon() uint64

func (*SetCompactionConfigParams) GetUuid 

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

func (*SetCompactionConfigParams) ProtoMessage 

func (*SetCompactionConfigParams) ProtoMessage()

func (*SetCompactionConfigParams) ProtoReflect added in v5.12.2 

func (x *SetCompactionConfigParams) ProtoReflect() protoreflect.Message

func (*SetCompactionConfigParams) Reset 

func (x *SetCompactionConfigParams) Reset()

func (*SetCompactionConfigParams) String 

func (x *SetCompactionConfigParams) String() string

type SetCompactionConfigResponse 

type SetCompactionConfigResponse struct {
	Stat *Status `protobuf:"bytes,1,opt,name=stat,proto3" json:"stat,omitempty"`
	// contains filtered or unexported fields
}

func (*SetCompactionConfigResponse) Descriptor deprecated 

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

Deprecated: Use SetCompactionConfigResponse.ProtoReflect.Descriptor instead.

func (*SetCompactionConfigResponse) GetStat 

func (x *SetCompactionConfigResponse) GetStat() *Status

func (*SetCompactionConfigResponse) ProtoMessage 

func (*SetCompactionConfigResponse) ProtoMessage()

func (*SetCompactionConfigResponse) ProtoReflect added in v5.12.2 

func (x *SetCompactionConfigResponse) ProtoReflect() protoreflect.Message

func (*SetCompactionConfigResponse) Reset 

func (x *SetCompactionConfigResponse) Reset()

func (*SetCompactionConfigResponse) String 

func (x *SetCompactionConfigResponse) String() string

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"`
	// contains filtered or unexported fields
}

func (*SetStreamAnnotationsParams) Descriptor deprecated 

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

Deprecated: Use SetStreamAnnotationsParams.ProtoReflect.Descriptor instead.

func (*SetStreamAnnotationsParams) GetChanges 

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

func (*SetStreamAnnotationsParams) GetExpectedPropertyVersion 

func (x *SetStreamAnnotationsParams) GetExpectedPropertyVersion() uint64

func (*SetStreamAnnotationsParams) GetRemovals 

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

func (*SetStreamAnnotationsParams) GetUuid 

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

func (*SetStreamAnnotationsParams) ProtoMessage 

func (*SetStreamAnnotationsParams) ProtoMessage()

func (*SetStreamAnnotationsParams) ProtoReflect added in v5.12.2 

func (x *SetStreamAnnotationsParams) ProtoReflect() protoreflect.Message

func (*SetStreamAnnotationsParams) Reset 

func (x *SetStreamAnnotationsParams) Reset()

func (*SetStreamAnnotationsParams) String 

func (x *SetStreamAnnotationsParams) String() string

type SetStreamAnnotationsResponse 

type SetStreamAnnotationsResponse struct {
	Stat *Status `protobuf:"bytes,1,opt,name=stat,proto3" json:"stat,omitempty"`
	// contains filtered or unexported fields
}

func (*SetStreamAnnotationsResponse) Descriptor deprecated 

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

Deprecated: Use SetStreamAnnotationsResponse.ProtoReflect.Descriptor instead.

func (*SetStreamAnnotationsResponse) GetStat 

func (x *SetStreamAnnotationsResponse) GetStat() *Status

func (*SetStreamAnnotationsResponse) ProtoMessage 

func (*SetStreamAnnotationsResponse) ProtoMessage()

func (*SetStreamAnnotationsResponse) ProtoReflect added in v5.12.2 

func (x *SetStreamAnnotationsResponse) ProtoReflect() protoreflect.Message

func (*SetStreamAnnotationsResponse) Reset 

func (x *SetStreamAnnotationsResponse) Reset()

func (*SetStreamAnnotationsResponse) String 

func (x *SetStreamAnnotationsResponse) String() string

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"`
	// contains filtered or unexported fields
}

func (*SetStreamTagsParams) Descriptor deprecated 

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

Deprecated: Use SetStreamTagsParams.ProtoReflect.Descriptor instead.

func (*SetStreamTagsParams) GetCollection 

func (x *SetStreamTagsParams) GetCollection() string

func (*SetStreamTagsParams) GetExpectedPropertyVersion 

func (x *SetStreamTagsParams) GetExpectedPropertyVersion() uint64

func (*SetStreamTagsParams) GetRemove 

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

func (*SetStreamTagsParams) GetTags 

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

func (*SetStreamTagsParams) GetUuid 

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

func (*SetStreamTagsParams) ProtoMessage 

func (*SetStreamTagsParams) ProtoMessage()

func (*SetStreamTagsParams) ProtoReflect added in v5.12.2 

func (x *SetStreamTagsParams) ProtoReflect() protoreflect.Message

func (*SetStreamTagsParams) Reset 

func (x *SetStreamTagsParams) Reset()

func (*SetStreamTagsParams) String 

func (x *SetStreamTagsParams) String() string

type SetStreamTagsResponse 

type SetStreamTagsResponse struct {
	Stat *Status `protobuf:"bytes,1,opt,name=stat,proto3" json:"stat,omitempty"`
	// contains filtered or unexported fields
}

func (*SetStreamTagsResponse) Descriptor deprecated 

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

Deprecated: Use SetStreamTagsResponse.ProtoReflect.Descriptor instead.

func (*SetStreamTagsResponse) GetStat 

func (x *SetStreamTagsResponse) GetStat() *Status

func (*SetStreamTagsResponse) ProtoMessage 

func (*SetStreamTagsResponse) ProtoMessage()

func (*SetStreamTagsResponse) ProtoReflect added in v5.12.2 

func (x *SetStreamTagsResponse) ProtoReflect() protoreflect.Message

func (*SetStreamTagsResponse) Reset 

func (x *SetStreamTagsResponse) Reset()

func (*SetStreamTagsResponse) String 

func (x *SetStreamTagsResponse) String() string

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"`
	// contains filtered or unexported fields
}

func (*StatPoint) Descriptor deprecated 

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

Deprecated: Use StatPoint.ProtoReflect.Descriptor instead.

func (*StatPoint) GetCount 

func (x *StatPoint) GetCount() uint64

func (*StatPoint) GetMax 

func (x *StatPoint) GetMax() float64

func (*StatPoint) GetMean 

func (x *StatPoint) GetMean() float64

func (*StatPoint) GetMin 

func (x *StatPoint) GetMin() float64

func (*StatPoint) GetStddev 

func (x *StatPoint) GetStddev() float64

func (*StatPoint) GetTime 

func (x *StatPoint) GetTime() int64

func (*StatPoint) ProtoMessage 

func (*StatPoint) ProtoMessage()

func (*StatPoint) ProtoReflect added in v5.12.2 

func (x *StatPoint) ProtoReflect() protoreflect.Message

func (*StatPoint) Reset 

func (x *StatPoint) Reset()

func (*StatPoint) String 

func (x *StatPoint) String() string

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"`
	// contains filtered or unexported fields
}

func (*Status) Descriptor deprecated 

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

Deprecated: Use Status.ProtoReflect.Descriptor instead.

func (*Status) GetCode 

func (x *Status) GetCode() uint32

func (*Status) GetMash 

func (x *Status) GetMash() *Mash

func (*Status) GetMsg 

func (x *Status) GetMsg() string

func (*Status) ProtoMessage 

func (*Status) ProtoMessage()

func (*Status) ProtoReflect added in v5.12.2 

func (x *Status) ProtoReflect() protoreflect.Message

func (*Status) Reset 

func (x *Status) Reset()

func (*Status) String 

func (x *Status) String() string

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"`
	// contains filtered or unexported fields
}

func (*StreamCSVConfig) Descriptor deprecated 

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

Deprecated: Use StreamCSVConfig.ProtoReflect.Descriptor instead.

func (*StreamCSVConfig) GetLabel 

func (x *StreamCSVConfig) GetLabel() string

func (*StreamCSVConfig) GetUuid 

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

func (*StreamCSVConfig) GetVersion 

func (x *StreamCSVConfig) GetVersion() uint64

func (*StreamCSVConfig) ProtoMessage 

func (*StreamCSVConfig) ProtoMessage()

func (*StreamCSVConfig) ProtoReflect added in v5.12.2 

func (x *StreamCSVConfig) ProtoReflect() protoreflect.Message

func (*StreamCSVConfig) Reset 

func (x *StreamCSVConfig) Reset()

func (*StreamCSVConfig) String 

func (x *StreamCSVConfig) String() string

type StreamDescriptor 

type StreamDescriptor struct {
	Uuid            []byte         `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	Collection      string         `protobuf:"bytes,2,opt,name=collection,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"`
	// contains filtered or unexported fields
}

func (*StreamDescriptor) Descriptor deprecated 

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

Deprecated: Use StreamDescriptor.ProtoReflect.Descriptor instead.

func (*StreamDescriptor) GetAnnotations 

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

func (*StreamDescriptor) GetCollection 

func (x *StreamDescriptor) GetCollection() string

func (*StreamDescriptor) GetPropertyVersion 

func (x *StreamDescriptor) GetPropertyVersion() uint64

func (*StreamDescriptor) GetTags 

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

func (*StreamDescriptor) GetUuid 

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

func (*StreamDescriptor) ProtoMessage 

func (*StreamDescriptor) ProtoMessage()

func (*StreamDescriptor) ProtoReflect added in v5.12.2 

func (x *StreamDescriptor) ProtoReflect() protoreflect.Message

func (*StreamDescriptor) Reset 

func (x *StreamDescriptor) Reset()

func (*StreamDescriptor) String 

func (x *StreamDescriptor) String() string

type StreamInfoParams 

type StreamInfoParams struct {
	Uuid           []byte `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	OmitVersion    bool   `protobuf:"varint,2,opt,name=omitVersion,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"`
	// contains filtered or unexported fields
}

func (*StreamInfoParams) Descriptor deprecated 

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

Deprecated: Use StreamInfoParams.ProtoReflect.Descriptor instead.

func (*StreamInfoParams) GetOmitDescriptor 

func (x *StreamInfoParams) GetOmitDescriptor() bool

func (*StreamInfoParams) GetOmitVersion 

func (x *StreamInfoParams) GetOmitVersion() bool

func (*StreamInfoParams) GetRole 

func (x *StreamInfoParams) GetRole() *Role

func (*StreamInfoParams) GetUuid 

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

func (*StreamInfoParams) ProtoMessage 

func (*StreamInfoParams) ProtoMessage()

func (*StreamInfoParams) ProtoReflect added in v5.12.2 

func (x *StreamInfoParams) ProtoReflect() protoreflect.Message

func (*StreamInfoParams) Reset 

func (x *StreamInfoParams) Reset()

func (*StreamInfoParams) String 

func (x *StreamInfoParams) String() string

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"`
	// contains filtered or unexported fields
}

func (*StreamInfoResponse) Descriptor deprecated 

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

Deprecated: Use StreamInfoResponse.ProtoReflect.Descriptor instead.

func (*StreamInfoResponse) GetDescriptor_ 

func (x *StreamInfoResponse) GetDescriptor_() *StreamDescriptor

func (*StreamInfoResponse) GetStat 

func (x *StreamInfoResponse) GetStat() *Status

func (*StreamInfoResponse) GetVersionMajor 

func (x *StreamInfoResponse) GetVersionMajor() uint64

func (*StreamInfoResponse) GetVersionMinor 

func (x *StreamInfoResponse) GetVersionMinor() uint64

func (*StreamInfoResponse) ProtoMessage 

func (*StreamInfoResponse) ProtoMessage()

func (*StreamInfoResponse) ProtoReflect added in v5.12.2 

func (x *StreamInfoResponse) ProtoReflect() protoreflect.Message

func (*StreamInfoResponse) Reset 

func (x *StreamInfoResponse) Reset()

func (*StreamInfoResponse) String 

func (x *StreamInfoResponse) String() string

type SubscriptionParams added in v5.17.0 

type SubscriptionParams struct {
	Uuid [][]byte `protobuf:"bytes,1,rep,name=uuid,proto3" json:"uuid,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscriptionParams) Descriptor deprecated added in v5.17.0 

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

Deprecated: Use SubscriptionParams.ProtoReflect.Descriptor instead.

func (*SubscriptionParams) GetUuid added in v5.17.0 

func (x *SubscriptionParams) GetUuid() [][]byte

func (*SubscriptionParams) ProtoMessage added in v5.17.0 

func (*SubscriptionParams) ProtoMessage()

func (*SubscriptionParams) ProtoReflect added in v5.17.0 

func (x *SubscriptionParams) ProtoReflect() protoreflect.Message

func (*SubscriptionParams) Reset added in v5.17.0 

func (x *SubscriptionParams) Reset()

func (*SubscriptionParams) String added in v5.17.0 

func (x *SubscriptionParams) String() string

type SubscriptionResp added in v5.17.0 

type SubscriptionResp struct {
	Stat   *Status     `protobuf:"bytes,1,opt,name=stat,proto3" json:"stat,omitempty"`
	Uuid   []byte      `protobuf:"bytes,3,opt,name=uuid,proto3" json:"uuid,omitempty"`
	Values []*RawPoint `protobuf:"bytes,2,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscriptionResp) Descriptor deprecated added in v5.17.0 

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

Deprecated: Use SubscriptionResp.ProtoReflect.Descriptor instead.

func (*SubscriptionResp) GetStat added in v5.17.0 

func (x *SubscriptionResp) GetStat() *Status

func (*SubscriptionResp) GetUuid added in v5.17.1 

func (x *SubscriptionResp) GetUuid() []byte

func (*SubscriptionResp) GetValues added in v5.17.0 

func (x *SubscriptionResp) GetValues() []*RawPoint

func (*SubscriptionResp) ProtoMessage added in v5.17.0 

func (*SubscriptionResp) ProtoMessage()

func (*SubscriptionResp) ProtoReflect added in v5.17.0 

func (x *SubscriptionResp) ProtoReflect() protoreflect.Message

func (*SubscriptionResp) Reset added in v5.17.0 

func (x *SubscriptionResp) Reset()

func (*SubscriptionResp) String added in v5.17.0 

func (x *SubscriptionResp) String() string

type UnimplementedBTrDBServer added in v5.11.2 

type UnimplementedBTrDBServer struct {
}

UnimplementedBTrDBServer must be embedded to have forward compatible implementations.

func (UnimplementedBTrDBServer) AlignedWindows added in v5.11.2 

func (UnimplementedBTrDBServer) AlignedWindows(*AlignedWindowsParams, BTrDB_AlignedWindowsServer) error

func (UnimplementedBTrDBServer) Changes added in v5.11.2 

func (UnimplementedBTrDBServer) Changes(*ChangesParams, BTrDB_ChangesServer) error

func (UnimplementedBTrDBServer) Create added in v5.11.2 

func (UnimplementedBTrDBServer) Create(context.Context, *CreateParams) (*CreateResponse, error)

func (UnimplementedBTrDBServer) Delete added in v5.11.2 

func (UnimplementedBTrDBServer) Delete(context.Context, *DeleteParams) (*DeleteResponse, error)

func (UnimplementedBTrDBServer) FaultInject added in v5.11.2 

func (UnimplementedBTrDBServer) FaultInject(context.Context, *FaultInjectParams) (*FaultInjectResponse, error)

func (UnimplementedBTrDBServer) Flush added in v5.11.2 

func (UnimplementedBTrDBServer) Flush(context.Context, *FlushParams) (*FlushResponse, error)

func (UnimplementedBTrDBServer) GenerateCSV added in v5.11.2 

func (UnimplementedBTrDBServer) GenerateCSV(*GenerateCSVParams, BTrDB_GenerateCSVServer) error

func (UnimplementedBTrDBServer) GetCompactionConfig added in v5.11.2 

func (UnimplementedBTrDBServer) GetCompactionConfig(context.Context, *GetCompactionConfigParams) (*GetCompactionConfigResponse, error)

func (UnimplementedBTrDBServer) GetMetadataUsage added in v5.11.2 

func (UnimplementedBTrDBServer) GetMetadataUsage(context.Context, *MetadataUsageParams) (*MetadataUsageResponse, error)

func (UnimplementedBTrDBServer) Info added in v5.11.2 

func (UnimplementedBTrDBServer) Info(context.Context, *InfoParams) (*InfoResponse, error)

func (UnimplementedBTrDBServer) Insert added in v5.11.2 

func (UnimplementedBTrDBServer) Insert(context.Context, *InsertParams) (*InsertResponse, error)

func (UnimplementedBTrDBServer) ListCollections added in v5.11.2 

func (UnimplementedBTrDBServer) ListCollections(*ListCollectionsParams, BTrDB_ListCollectionsServer) error

func (UnimplementedBTrDBServer) LookupStreams added in v5.11.2 

func (UnimplementedBTrDBServer) LookupStreams(*LookupStreamsParams, BTrDB_LookupStreamsServer) error

func (UnimplementedBTrDBServer) MultiRawValues added in v5.17.0 

func (UnimplementedBTrDBServer) MultiRawValues(*MultiRawValuesParams, BTrDB_MultiRawValuesServer) error

func (UnimplementedBTrDBServer) Nearest added in v5.11.2 

func (UnimplementedBTrDBServer) Nearest(context.Context, *NearestParams) (*NearestResponse, error)

func (UnimplementedBTrDBServer) Obliterate added in v5.11.2 

func (UnimplementedBTrDBServer) Obliterate(context.Context, *ObliterateParams) (*ObliterateResponse, error)

func (UnimplementedBTrDBServer) RawValues added in v5.11.2 

func (UnimplementedBTrDBServer) RawValues(*RawValuesParams, BTrDB_RawValuesServer) error

func (UnimplementedBTrDBServer) SQLQuery added in v5.11.2 

func (UnimplementedBTrDBServer) SQLQuery(*SQLQueryParams, BTrDB_SQLQueryServer) error

func (UnimplementedBTrDBServer) SetCompactionConfig added in v5.11.2 

func (UnimplementedBTrDBServer) SetCompactionConfig(context.Context, *SetCompactionConfigParams) (*SetCompactionConfigResponse, error)

func (UnimplementedBTrDBServer) SetStreamAnnotations added in v5.11.2 

func (UnimplementedBTrDBServer) SetStreamAnnotations(context.Context, *SetStreamAnnotationsParams) (*SetStreamAnnotationsResponse, error)

func (UnimplementedBTrDBServer) SetStreamTags added in v5.11.2 

func (UnimplementedBTrDBServer) SetStreamTags(context.Context, *SetStreamTagsParams) (*SetStreamTagsResponse, error)

func (UnimplementedBTrDBServer) StreamInfo added in v5.11.2 

func (UnimplementedBTrDBServer) StreamInfo(context.Context, *StreamInfoParams) (*StreamInfoResponse, error)

func (UnimplementedBTrDBServer) Subscribe added in v5.17.0 

func (UnimplementedBTrDBServer) Subscribe(*SubscriptionParams, BTrDB_SubscribeServer) error

func (UnimplementedBTrDBServer) Windows added in v5.11.2 

func (UnimplementedBTrDBServer) Windows(*WindowsParams, BTrDB_WindowsServer) error

type UnsafeBTrDBServer added in v5.13.0 

type UnsafeBTrDBServer interface {
	// contains filtered or unexported methods
}

UnsafeBTrDBServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to BTrDBServer will result in compilation errors.

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"`
	// contains filtered or unexported fields
}

func (*WindowsParams) Descriptor deprecated 

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

Deprecated: Use WindowsParams.ProtoReflect.Descriptor instead.

func (*WindowsParams) GetDepth 

func (x *WindowsParams) GetDepth() uint32

func (*WindowsParams) GetEnd 

func (x *WindowsParams) GetEnd() int64

func (*WindowsParams) GetStart 

func (x *WindowsParams) GetStart() int64

func (*WindowsParams) GetUuid 

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

func (*WindowsParams) GetVersionMajor 

func (x *WindowsParams) GetVersionMajor() uint64

func (*WindowsParams) GetWidth 

func (x *WindowsParams) GetWidth() uint64

func (*WindowsParams) ProtoMessage 

func (*WindowsParams) ProtoMessage()

func (*WindowsParams) ProtoReflect added in v5.12.2 

func (x *WindowsParams) ProtoReflect() protoreflect.Message

func (*WindowsParams) Reset 

func (x *WindowsParams) Reset()

func (*WindowsParams) String 

func (x *WindowsParams) String() string

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"`
	// contains filtered or unexported fields
}

func (*WindowsResponse) Descriptor deprecated 

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

Deprecated: Use WindowsResponse.ProtoReflect.Descriptor instead.

func (*WindowsResponse) GetStat 

func (x *WindowsResponse) GetStat() *Status

func (*WindowsResponse) GetValues 

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

func (*WindowsResponse) GetVersionMajor 

func (x *WindowsResponse) GetVersionMajor() uint64

func (*WindowsResponse) GetVersionMinor 

func (x *WindowsResponse) GetVersionMinor() uint64

func (*WindowsResponse) ProtoMessage 

func (*WindowsResponse) ProtoMessage()

func (*WindowsResponse) ProtoReflect added in v5.12.2 

func (x *WindowsResponse) ProtoReflect() protoreflect.Message

func (*WindowsResponse) Reset 

func (x *WindowsResponse) Reset()

func (*WindowsResponse) String 

func (x *WindowsResponse) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

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