v1

package
v0.1.0 Latest Latest
Warning

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

 Go to latest Published: Jun 2, 2022 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	Action_name = map[int32]string{
		0: "ACTION_UNSPECIFIED",
		1: "ACTION_PUT",
		2: "ACTION_DELETE",
	}
	Action_value = map[string]int32{
		"ACTION_UNSPECIFIED": 0,
		"ACTION_PUT":         1,
		"ACTION_DELETE":      2,
	}
)

Enum value maps for Action.

View Source 
var (
	TagType_name = map[int32]string{
		0: "TAG_TYPE_UNSPECIFIED",
		1: "TAG_TYPE_STRING",
		2: "TAG_TYPE_INT",
		3: "TAG_TYPE_STRING_ARRAY",
		4: "TAG_TYPE_INT_ARRAY",
		5: "TAG_TYPE_DATA_BINARY",
		6: "TAG_TYPE_ID",
	}
	TagType_value = map[string]int32{
		"TAG_TYPE_UNSPECIFIED":  0,
		"TAG_TYPE_STRING":       1,
		"TAG_TYPE_INT":          2,
		"TAG_TYPE_STRING_ARRAY": 3,
		"TAG_TYPE_INT_ARRAY":    4,
		"TAG_TYPE_DATA_BINARY":  5,
		"TAG_TYPE_ID":           6,
	}
)

Enum value maps for TagType.

View Source 
var (
	FieldType_name = map[int32]string{
		0: "FIELD_TYPE_UNSPECIFIED",
		1: "FIELD_TYPE_STRING",
		2: "FIELD_TYPE_INT",
		3: "FIELD_TYPE_DATA_BINARY",
	}
	FieldType_value = map[string]int32{
		"FIELD_TYPE_UNSPECIFIED": 0,
		"FIELD_TYPE_STRING":      1,
		"FIELD_TYPE_INT":         2,
		"FIELD_TYPE_DATA_BINARY": 3,
	}
)

Enum value maps for FieldType.

View Source 
var (
	EncodingMethod_name = map[int32]string{
		0: "ENCODING_METHOD_UNSPECIFIED",
		1: "ENCODING_METHOD_GORILLA",
	}
	EncodingMethod_value = map[string]int32{
		"ENCODING_METHOD_UNSPECIFIED": 0,
		"ENCODING_METHOD_GORILLA":     1,
	}
)

Enum value maps for EncodingMethod.

View Source 
var (
	CompressionMethod_name = map[int32]string{
		0: "COMPRESSION_METHOD_UNSPECIFIED",
		1: "COMPRESSION_METHOD_ZSTD",
	}
	CompressionMethod_value = map[string]int32{
		"COMPRESSION_METHOD_UNSPECIFIED": 0,
		"COMPRESSION_METHOD_ZSTD":        1,
	}
)

Enum value maps for CompressionMethod.

View Source 
var (
	IndexRule_Type_name = map[int32]string{
		0: "TYPE_UNSPECIFIED",
		1: "TYPE_TREE",
		2: "TYPE_INVERTED",
	}
	IndexRule_Type_value = map[string]int32{
		"TYPE_UNSPECIFIED": 0,
		"TYPE_TREE":        1,
		"TYPE_INVERTED":    2,
	}
)

Enum value maps for IndexRule_Type.

View Source 
var (
	IndexRule_Location_name = map[int32]string{
		0: "LOCATION_UNSPECIFIED",
		1: "LOCATION_SERIES",
		2: "LOCATION_GLOBAL",
	}
	IndexRule_Location_value = map[string]int32{
		"LOCATION_UNSPECIFIED": 0,
		"LOCATION_SERIES":      1,
		"LOCATION_GLOBAL":      2,
	}
)

Enum value maps for IndexRule_Location.

View Source 
var File_banyandb_database_v1_database_proto protoreflect.FileDescriptor
View Source 
var File_banyandb_database_v1_event_proto protoreflect.FileDescriptor
View Source 
var File_banyandb_database_v1_rpc_proto protoreflect.FileDescriptor
View Source 
var File_banyandb_database_v1_schema_proto protoreflect.FileDescriptor
View Source 
var GroupRegistryService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "banyandb.database.v1.GroupRegistryService",
	HandlerType: (*GroupRegistryServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Create",
			Handler:    _GroupRegistryService_Create_Handler,
		},
		{
			MethodName: "Update",
			Handler:    _GroupRegistryService_Update_Handler,
		},
		{
			MethodName: "Delete",
			Handler:    _GroupRegistryService_Delete_Handler,
		},
		{
			MethodName: "Get",
			Handler:    _GroupRegistryService_Get_Handler,
		},
		{
			MethodName: "List",
			Handler:    _GroupRegistryService_List_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "banyandb/database/v1/rpc.proto",
}

GroupRegistryService_ServiceDesc is the grpc.ServiceDesc for GroupRegistryService 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 IndexRuleBindingRegistryService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "banyandb.database.v1.IndexRuleBindingRegistryService",
	HandlerType: (*IndexRuleBindingRegistryServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Create",
			Handler:    _IndexRuleBindingRegistryService_Create_Handler,
		},
		{
			MethodName: "Update",
			Handler:    _IndexRuleBindingRegistryService_Update_Handler,
		},
		{
			MethodName: "Delete",
			Handler:    _IndexRuleBindingRegistryService_Delete_Handler,
		},
		{
			MethodName: "Get",
			Handler:    _IndexRuleBindingRegistryService_Get_Handler,
		},
		{
			MethodName: "List",
			Handler:    _IndexRuleBindingRegistryService_List_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "banyandb/database/v1/rpc.proto",
}

IndexRuleBindingRegistryService_ServiceDesc is the grpc.ServiceDesc for IndexRuleBindingRegistryService 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 IndexRuleRegistryService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "banyandb.database.v1.IndexRuleRegistryService",
	HandlerType: (*IndexRuleRegistryServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Create",
			Handler:    _IndexRuleRegistryService_Create_Handler,
		},
		{
			MethodName: "Update",
			Handler:    _IndexRuleRegistryService_Update_Handler,
		},
		{
			MethodName: "Delete",
			Handler:    _IndexRuleRegistryService_Delete_Handler,
		},
		{
			MethodName: "Get",
			Handler:    _IndexRuleRegistryService_Get_Handler,
		},
		{
			MethodName: "List",
			Handler:    _IndexRuleRegistryService_List_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "banyandb/database/v1/rpc.proto",
}

IndexRuleRegistryService_ServiceDesc is the grpc.ServiceDesc for IndexRuleRegistryService 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 MeasureRegistryService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "banyandb.database.v1.MeasureRegistryService",
	HandlerType: (*MeasureRegistryServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Create",
			Handler:    _MeasureRegistryService_Create_Handler,
		},
		{
			MethodName: "Update",
			Handler:    _MeasureRegistryService_Update_Handler,
		},
		{
			MethodName: "Delete",
			Handler:    _MeasureRegistryService_Delete_Handler,
		},
		{
			MethodName: "Get",
			Handler:    _MeasureRegistryService_Get_Handler,
		},
		{
			MethodName: "List",
			Handler:    _MeasureRegistryService_List_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "banyandb/database/v1/rpc.proto",
}

MeasureRegistryService_ServiceDesc is the grpc.ServiceDesc for MeasureRegistryService 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 StreamRegistryService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "banyandb.database.v1.StreamRegistryService",
	HandlerType: (*StreamRegistryServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Create",
			Handler:    _StreamRegistryService_Create_Handler,
		},
		{
			MethodName: "Update",
			Handler:    _StreamRegistryService_Update_Handler,
		},
		{
			MethodName: "Delete",
			Handler:    _StreamRegistryService_Delete_Handler,
		},
		{
			MethodName: "Get",
			Handler:    _StreamRegistryService_Get_Handler,
		},
		{
			MethodName: "List",
			Handler:    _StreamRegistryService_List_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "banyandb/database/v1/rpc.proto",
}

StreamRegistryService_ServiceDesc is the grpc.ServiceDesc for StreamRegistryService 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 TopNAggregationRegistryService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "banyandb.database.v1.TopNAggregationRegistryService",
	HandlerType: (*TopNAggregationRegistryServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Create",
			Handler:    _TopNAggregationRegistryService_Create_Handler,
		},
		{
			MethodName: "Update",
			Handler:    _TopNAggregationRegistryService_Update_Handler,
		},
		{
			MethodName: "Delete",
			Handler:    _TopNAggregationRegistryService_Delete_Handler,
		},
		{
			MethodName: "Get",
			Handler:    _TopNAggregationRegistryService_Get_Handler,
		},
		{
			MethodName: "List",
			Handler:    _TopNAggregationRegistryService_List_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "banyandb/database/v1/rpc.proto",
}

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

Functions

func RegisterGroupRegistryServiceServer 

func RegisterGroupRegistryServiceServer(s grpc.ServiceRegistrar, srv GroupRegistryServiceServer)

func RegisterIndexRuleBindingRegistryServiceServer 

func RegisterIndexRuleBindingRegistryServiceServer(s grpc.ServiceRegistrar, srv IndexRuleBindingRegistryServiceServer)

func RegisterIndexRuleRegistryServiceServer 

func RegisterIndexRuleRegistryServiceServer(s grpc.ServiceRegistrar, srv IndexRuleRegistryServiceServer)

func RegisterMeasureRegistryServiceServer 

func RegisterMeasureRegistryServiceServer(s grpc.ServiceRegistrar, srv MeasureRegistryServiceServer)

func RegisterStreamRegistryServiceServer 

func RegisterStreamRegistryServiceServer(s grpc.ServiceRegistrar, srv StreamRegistryServiceServer)

func RegisterTopNAggregationRegistryServiceServer 

func RegisterTopNAggregationRegistryServiceServer(s grpc.ServiceRegistrar, srv TopNAggregationRegistryServiceServer)

Types

type Action 

type Action int32
const (
	Action_ACTION_UNSPECIFIED Action = 0
	Action_ACTION_PUT         Action = 1
	Action_ACTION_DELETE      Action = 2
)

func (Action) Descriptor 

func (Action) Descriptor() protoreflect.EnumDescriptor

func (Action) Enum 

func (x Action) Enum() *Action

func (Action) EnumDescriptor deprecated 

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

Deprecated: Use Action.Descriptor instead.

func (Action) Number 

func (x Action) Number() protoreflect.EnumNumber

func (Action) String 

func (x Action) String() string

func (Action) Type 

func (Action) Type() protoreflect.EnumType

type CompressionMethod 

type CompressionMethod int32
const (
	CompressionMethod_COMPRESSION_METHOD_UNSPECIFIED CompressionMethod = 0
	CompressionMethod_COMPRESSION_METHOD_ZSTD        CompressionMethod = 1
)

func (CompressionMethod) Descriptor 

func (CompressionMethod) Descriptor() protoreflect.EnumDescriptor

func (CompressionMethod) Enum 

func (x CompressionMethod) Enum() *CompressionMethod

func (CompressionMethod) EnumDescriptor deprecated 

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

Deprecated: Use CompressionMethod.Descriptor instead.

func (CompressionMethod) Number 

func (x CompressionMethod) Number() protoreflect.EnumNumber

func (CompressionMethod) String 

func (x CompressionMethod) String() string

func (CompressionMethod) Type 

func (CompressionMethod) Type() protoreflect.EnumType

type EncodingMethod 

type EncodingMethod int32
const (
	EncodingMethod_ENCODING_METHOD_UNSPECIFIED EncodingMethod = 0
	EncodingMethod_ENCODING_METHOD_GORILLA     EncodingMethod = 1
)

func (EncodingMethod) Descriptor 

func (EncodingMethod) Descriptor() protoreflect.EnumDescriptor

func (EncodingMethod) Enum 

func (x EncodingMethod) Enum() *EncodingMethod

func (EncodingMethod) EnumDescriptor deprecated 

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

Deprecated: Use EncodingMethod.Descriptor instead.

func (EncodingMethod) Number 

func (x EncodingMethod) Number() protoreflect.EnumNumber

func (EncodingMethod) String 

func (x EncodingMethod) String() string

func (EncodingMethod) Type 

func (EncodingMethod) Type() protoreflect.EnumType

type Entity 

type Entity struct {
	TagNames []string `protobuf:"bytes,1,rep,name=tag_names,json=tagNames,proto3" json:"tag_names,omitempty"`
	// contains filtered or unexported fields
}

func (*Entity) Descriptor deprecated 

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

Deprecated: Use Entity.ProtoReflect.Descriptor instead.

func (*Entity) GetTagNames 

func (x *Entity) GetTagNames() []string

func (*Entity) ProtoMessage 

func (*Entity) ProtoMessage()

func (*Entity) ProtoReflect 

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

func (*Entity) Reset 

func (x *Entity) Reset()

func (*Entity) String 

func (x *Entity) String() string

type EntityEvent 

type EntityEvent struct {
	Subject       *v1.Metadata              `protobuf:"bytes,1,opt,name=subject,proto3" json:"subject,omitempty"`
	EntityLocator []*EntityEvent_TagLocator `protobuf:"bytes,2,rep,name=entity_locator,json=entityLocator,proto3" json:"entity_locator,omitempty"`
	Action        Action                    `protobuf:"varint,3,opt,name=action,proto3,enum=banyandb.database.v1.Action" json:"action,omitempty"`
	Time          *timestamppb.Timestamp    `protobuf:"bytes,4,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*EntityEvent) Descriptor deprecated 

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

Deprecated: Use EntityEvent.ProtoReflect.Descriptor instead.

func (*EntityEvent) GetAction 

func (x *EntityEvent) GetAction() Action

func (*EntityEvent) GetEntityLocator 

func (x *EntityEvent) GetEntityLocator() []*EntityEvent_TagLocator

func (*EntityEvent) GetSubject 

func (x *EntityEvent) GetSubject() *v1.Metadata

func (*EntityEvent) GetTime 

func (x *EntityEvent) GetTime() *timestamppb.Timestamp

func (*EntityEvent) ProtoMessage 

func (*EntityEvent) ProtoMessage()

func (*EntityEvent) ProtoReflect 

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

func (*EntityEvent) Reset 

func (x *EntityEvent) Reset()

func (*EntityEvent) String 

func (x *EntityEvent) String() string

type EntityEvent_TagLocator 

type EntityEvent_TagLocator struct {
	FamilyOffset uint32 `protobuf:"varint,1,opt,name=family_offset,json=familyOffset,proto3" json:"family_offset,omitempty"`
	TagOffset    uint32 `protobuf:"varint,2,opt,name=tag_offset,json=tagOffset,proto3" json:"tag_offset,omitempty"`
	// contains filtered or unexported fields
}

func (*EntityEvent_TagLocator) Descriptor deprecated 

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

Deprecated: Use EntityEvent_TagLocator.ProtoReflect.Descriptor instead.

func (*EntityEvent_TagLocator) GetFamilyOffset 

func (x *EntityEvent_TagLocator) GetFamilyOffset() uint32

func (*EntityEvent_TagLocator) GetTagOffset 

func (x *EntityEvent_TagLocator) GetTagOffset() uint32

func (*EntityEvent_TagLocator) ProtoMessage 

func (*EntityEvent_TagLocator) ProtoMessage()

func (*EntityEvent_TagLocator) ProtoReflect 

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

func (*EntityEvent_TagLocator) Reset 

func (x *EntityEvent_TagLocator) Reset()

func (*EntityEvent_TagLocator) String 

func (x *EntityEvent_TagLocator) String() string

type FieldSpec 

type FieldSpec struct {

	// name is the identity of a field
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// field_type denotes the type of field value
	FieldType FieldType `protobuf:"varint,2,opt,name=field_type,json=fieldType,proto3,enum=banyandb.database.v1.FieldType" json:"field_type,omitempty"`
	// encoding_method indicates how to encode data during writing
	EncodingMethod EncodingMethod `` /* 145-byte string literal not displayed */
	// compression_method indicates how to compress data during writing
	CompressionMethod CompressionMethod `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

FieldSpec is the specification of field

func (*FieldSpec) Descriptor deprecated 

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

Deprecated: Use FieldSpec.ProtoReflect.Descriptor instead.

func (*FieldSpec) GetCompressionMethod 

func (x *FieldSpec) GetCompressionMethod() CompressionMethod

func (*FieldSpec) GetEncodingMethod 

func (x *FieldSpec) GetEncodingMethod() EncodingMethod

func (*FieldSpec) GetFieldType 

func (x *FieldSpec) GetFieldType() FieldType

func (*FieldSpec) GetName 

func (x *FieldSpec) GetName() string

func (*FieldSpec) ProtoMessage 

func (*FieldSpec) ProtoMessage()

func (*FieldSpec) ProtoReflect 

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

func (*FieldSpec) Reset 

func (x *FieldSpec) Reset()

func (*FieldSpec) String 

func (x *FieldSpec) String() string

type FieldType 

type FieldType int32
const (
	FieldType_FIELD_TYPE_UNSPECIFIED FieldType = 0
	FieldType_FIELD_TYPE_STRING      FieldType = 1
	FieldType_FIELD_TYPE_INT         FieldType = 2
	FieldType_FIELD_TYPE_DATA_BINARY FieldType = 3
)

func (FieldType) Descriptor 

func (FieldType) Descriptor() protoreflect.EnumDescriptor

func (FieldType) Enum 

func (x FieldType) Enum() *FieldType

func (FieldType) EnumDescriptor deprecated 

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

Deprecated: Use FieldType.Descriptor instead.

func (FieldType) Number 

func (x FieldType) Number() protoreflect.EnumNumber

func (FieldType) String 

func (x FieldType) String() string

func (FieldType) Type 

func (FieldType) Type() protoreflect.EnumType

type GroupRegistryServiceClient 

type GroupRegistryServiceClient interface {
	Create(ctx context.Context, in *GroupRegistryServiceCreateRequest, opts ...grpc.CallOption) (*GroupRegistryServiceCreateResponse, error)
	Update(ctx context.Context, in *GroupRegistryServiceUpdateRequest, opts ...grpc.CallOption) (*GroupRegistryServiceUpdateResponse, error)
	Delete(ctx context.Context, in *GroupRegistryServiceDeleteRequest, opts ...grpc.CallOption) (*GroupRegistryServiceDeleteResponse, error)
	Get(ctx context.Context, in *GroupRegistryServiceGetRequest, opts ...grpc.CallOption) (*GroupRegistryServiceGetResponse, error)
	List(ctx context.Context, in *GroupRegistryServiceListRequest, opts ...grpc.CallOption) (*GroupRegistryServiceListResponse, error)
}

GroupRegistryServiceClient is the client API for GroupRegistryService 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 NewGroupRegistryServiceClient 

func NewGroupRegistryServiceClient(cc grpc.ClientConnInterface) GroupRegistryServiceClient

type GroupRegistryServiceCreateRequest 

type GroupRegistryServiceCreateRequest struct {
	Group *v1.Group `protobuf:"bytes,1,opt,name=group,proto3" json:"group,omitempty"`
	// contains filtered or unexported fields
}

func (*GroupRegistryServiceCreateRequest) Descriptor deprecated 

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

Deprecated: Use GroupRegistryServiceCreateRequest.ProtoReflect.Descriptor instead.

func (*GroupRegistryServiceCreateRequest) GetGroup 

func (x *GroupRegistryServiceCreateRequest) GetGroup() *v1.Group

func (*GroupRegistryServiceCreateRequest) ProtoMessage 

func (*GroupRegistryServiceCreateRequest) ProtoMessage()

func (*GroupRegistryServiceCreateRequest) ProtoReflect 

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

func (*GroupRegistryServiceCreateRequest) Reset 

func (x *GroupRegistryServiceCreateRequest) Reset()

func (*GroupRegistryServiceCreateRequest) String 

func (x *GroupRegistryServiceCreateRequest) String() string

type GroupRegistryServiceCreateResponse 

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

func (*GroupRegistryServiceCreateResponse) Descriptor deprecated 

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

Deprecated: Use GroupRegistryServiceCreateResponse.ProtoReflect.Descriptor instead.

func (*GroupRegistryServiceCreateResponse) ProtoMessage 

func (*GroupRegistryServiceCreateResponse) ProtoMessage()

func (*GroupRegistryServiceCreateResponse) ProtoReflect 

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

func (*GroupRegistryServiceCreateResponse) Reset 

func (x *GroupRegistryServiceCreateResponse) Reset()

func (*GroupRegistryServiceCreateResponse) String 

func (x *GroupRegistryServiceCreateResponse) String() string

type GroupRegistryServiceDeleteRequest 

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

func (*GroupRegistryServiceDeleteRequest) Descriptor deprecated 

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

Deprecated: Use GroupRegistryServiceDeleteRequest.ProtoReflect.Descriptor instead.

func (*GroupRegistryServiceDeleteRequest) GetGroup 

func (x *GroupRegistryServiceDeleteRequest) GetGroup() string

func (*GroupRegistryServiceDeleteRequest) ProtoMessage 

func (*GroupRegistryServiceDeleteRequest) ProtoMessage()

func (*GroupRegistryServiceDeleteRequest) ProtoReflect 

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

func (*GroupRegistryServiceDeleteRequest) Reset 

func (x *GroupRegistryServiceDeleteRequest) Reset()

func (*GroupRegistryServiceDeleteRequest) String 

func (x *GroupRegistryServiceDeleteRequest) String() string

type GroupRegistryServiceDeleteResponse 

type GroupRegistryServiceDeleteResponse struct {
	Deleted bool `protobuf:"varint,1,opt,name=deleted,proto3" json:"deleted,omitempty"`
	// contains filtered or unexported fields
}

func (*GroupRegistryServiceDeleteResponse) Descriptor deprecated 

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

Deprecated: Use GroupRegistryServiceDeleteResponse.ProtoReflect.Descriptor instead.

func (*GroupRegistryServiceDeleteResponse) GetDeleted 

func (x *GroupRegistryServiceDeleteResponse) GetDeleted() bool

func (*GroupRegistryServiceDeleteResponse) ProtoMessage 

func (*GroupRegistryServiceDeleteResponse) ProtoMessage()

func (*GroupRegistryServiceDeleteResponse) ProtoReflect 

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

func (*GroupRegistryServiceDeleteResponse) Reset 

func (x *GroupRegistryServiceDeleteResponse) Reset()

func (*GroupRegistryServiceDeleteResponse) String 

func (x *GroupRegistryServiceDeleteResponse) String() string

type GroupRegistryServiceGetRequest 

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

func (*GroupRegistryServiceGetRequest) Descriptor deprecated 

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

Deprecated: Use GroupRegistryServiceGetRequest.ProtoReflect.Descriptor instead.

func (*GroupRegistryServiceGetRequest) GetGroup 

func (x *GroupRegistryServiceGetRequest) GetGroup() string

func (*GroupRegistryServiceGetRequest) ProtoMessage 

func (*GroupRegistryServiceGetRequest) ProtoMessage()

func (*GroupRegistryServiceGetRequest) ProtoReflect 

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

func (*GroupRegistryServiceGetRequest) Reset 

func (x *GroupRegistryServiceGetRequest) Reset()

func (*GroupRegistryServiceGetRequest) String 

func (x *GroupRegistryServiceGetRequest) String() string

type GroupRegistryServiceGetResponse 

type GroupRegistryServiceGetResponse struct {
	Group *v1.Group `protobuf:"bytes,1,opt,name=group,proto3" json:"group,omitempty"`
	// contains filtered or unexported fields
}

func (*GroupRegistryServiceGetResponse) Descriptor deprecated 

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

Deprecated: Use GroupRegistryServiceGetResponse.ProtoReflect.Descriptor instead.

func (*GroupRegistryServiceGetResponse) GetGroup 

func (x *GroupRegistryServiceGetResponse) GetGroup() *v1.Group

func (*GroupRegistryServiceGetResponse) ProtoMessage 

func (*GroupRegistryServiceGetResponse) ProtoMessage()

func (*GroupRegistryServiceGetResponse) ProtoReflect 

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

func (*GroupRegistryServiceGetResponse) Reset 

func (x *GroupRegistryServiceGetResponse) Reset()

func (*GroupRegistryServiceGetResponse) String 

func (x *GroupRegistryServiceGetResponse) String() string

type GroupRegistryServiceListRequest 

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

func (*GroupRegistryServiceListRequest) Descriptor deprecated 

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

Deprecated: Use GroupRegistryServiceListRequest.ProtoReflect.Descriptor instead.

func (*GroupRegistryServiceListRequest) ProtoMessage 

func (*GroupRegistryServiceListRequest) ProtoMessage()

func (*GroupRegistryServiceListRequest) ProtoReflect 

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

func (*GroupRegistryServiceListRequest) Reset 

func (x *GroupRegistryServiceListRequest) Reset()

func (*GroupRegistryServiceListRequest) String 

func (x *GroupRegistryServiceListRequest) String() string

type GroupRegistryServiceListResponse 

type GroupRegistryServiceListResponse struct {
	Group []*v1.Group `protobuf:"bytes,1,rep,name=group,proto3" json:"group,omitempty"`
	// contains filtered or unexported fields
}

func (*GroupRegistryServiceListResponse) Descriptor deprecated 

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

Deprecated: Use GroupRegistryServiceListResponse.ProtoReflect.Descriptor instead.

func (*GroupRegistryServiceListResponse) GetGroup 

func (x *GroupRegistryServiceListResponse) GetGroup() []*v1.Group

func (*GroupRegistryServiceListResponse) ProtoMessage 

func (*GroupRegistryServiceListResponse) ProtoMessage()

func (*GroupRegistryServiceListResponse) ProtoReflect 

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

func (*GroupRegistryServiceListResponse) Reset 

func (x *GroupRegistryServiceListResponse) Reset()

func (*GroupRegistryServiceListResponse) String 

func (x *GroupRegistryServiceListResponse) String() string

type GroupRegistryServiceServer 

type GroupRegistryServiceServer interface {
	Create(context.Context, *GroupRegistryServiceCreateRequest) (*GroupRegistryServiceCreateResponse, error)
	Update(context.Context, *GroupRegistryServiceUpdateRequest) (*GroupRegistryServiceUpdateResponse, error)
	Delete(context.Context, *GroupRegistryServiceDeleteRequest) (*GroupRegistryServiceDeleteResponse, error)
	Get(context.Context, *GroupRegistryServiceGetRequest) (*GroupRegistryServiceGetResponse, error)
	List(context.Context, *GroupRegistryServiceListRequest) (*GroupRegistryServiceListResponse, error)
	// contains filtered or unexported methods
}

GroupRegistryServiceServer is the server API for GroupRegistryService service. All implementations must embed UnimplementedGroupRegistryServiceServer for forward compatibility

type GroupRegistryServiceUpdateRequest 

type GroupRegistryServiceUpdateRequest struct {
	Group *v1.Group `protobuf:"bytes,1,opt,name=group,proto3" json:"group,omitempty"`
	// contains filtered or unexported fields
}

func (*GroupRegistryServiceUpdateRequest) Descriptor deprecated 

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

Deprecated: Use GroupRegistryServiceUpdateRequest.ProtoReflect.Descriptor instead.

func (*GroupRegistryServiceUpdateRequest) GetGroup 

func (x *GroupRegistryServiceUpdateRequest) GetGroup() *v1.Group

func (*GroupRegistryServiceUpdateRequest) ProtoMessage 

func (*GroupRegistryServiceUpdateRequest) ProtoMessage()

func (*GroupRegistryServiceUpdateRequest) ProtoReflect 

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

func (*GroupRegistryServiceUpdateRequest) Reset 

func (x *GroupRegistryServiceUpdateRequest) Reset()

func (*GroupRegistryServiceUpdateRequest) String 

func (x *GroupRegistryServiceUpdateRequest) String() string

type GroupRegistryServiceUpdateResponse 

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

func (*GroupRegistryServiceUpdateResponse) Descriptor deprecated 

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

Deprecated: Use GroupRegistryServiceUpdateResponse.ProtoReflect.Descriptor instead.

func (*GroupRegistryServiceUpdateResponse) ProtoMessage 

func (*GroupRegistryServiceUpdateResponse) ProtoMessage()

func (*GroupRegistryServiceUpdateResponse) ProtoReflect 

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

func (*GroupRegistryServiceUpdateResponse) Reset 

func (x *GroupRegistryServiceUpdateResponse) Reset()

func (*GroupRegistryServiceUpdateResponse) String 

func (x *GroupRegistryServiceUpdateResponse) String() string

type IndexRule 

type IndexRule struct {

	// metadata define the rule's identity
	Metadata *v1.Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// tags are the combination that refers to an indexed object
	// If the elements in tags are more than 1, the object will generate a multi-tag index
	// Caveat: All tags in a multi-tag MUST have an identical IndexType
	Tags []string `protobuf:"bytes,2,rep,name=tags,proto3" json:"tags,omitempty"`
	// type is the IndexType of this IndexObject.
	Type IndexRule_Type `protobuf:"varint,3,opt,name=type,proto3,enum=banyandb.database.v1.IndexRule_Type" json:"type,omitempty"`
	// location indicates where to store index.
	Location IndexRule_Location `protobuf:"varint,4,opt,name=location,proto3,enum=banyandb.database.v1.IndexRule_Location" json:"location,omitempty"`
	// updated_at indicates when the IndexRule is updated
	UpdatedAt *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// contains filtered or unexported fields
}

IndexRule defines how to generate indices based on tags and the index type IndexRule should bind to a subject through an IndexRuleBinding to generate proper indices.

func (*IndexRule) Descriptor deprecated 

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

Deprecated: Use IndexRule.ProtoReflect.Descriptor instead.

func (*IndexRule) GetLocation 

func (x *IndexRule) GetLocation() IndexRule_Location

func (*IndexRule) GetMetadata 

func (x *IndexRule) GetMetadata() *v1.Metadata

func (*IndexRule) GetTags 

func (x *IndexRule) GetTags() []string

func (*IndexRule) GetType 

func (x *IndexRule) GetType() IndexRule_Type

func (*IndexRule) GetUpdatedAt 

func (x *IndexRule) GetUpdatedAt() *timestamppb.Timestamp

func (*IndexRule) ProtoMessage 

func (*IndexRule) ProtoMessage()

func (*IndexRule) ProtoReflect 

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

func (*IndexRule) Reset 

func (x *IndexRule) Reset()

func (*IndexRule) String 

func (x *IndexRule) String() string

type IndexRuleBinding 

type IndexRuleBinding struct {

	// metadata is the identity of this binding
	Metadata *v1.Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// rules refers to the IndexRule
	Rules []string `protobuf:"bytes,2,rep,name=rules,proto3" json:"rules,omitempty"`
	// subject indicates the subject of binding action
	Subject *Subject `protobuf:"bytes,3,opt,name=subject,proto3" json:"subject,omitempty"`
	// begin_at_nanoseconds is the timestamp, after which the binding will be active
	BeginAt *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=begin_at,json=beginAt,proto3" json:"begin_at,omitempty"`
	// expire_at_nanoseconds it the timestamp, after which the binding will be inactive
	// expire_at_nanoseconds must be larger than begin_at_nanoseconds
	ExpireAt *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=expire_at,json=expireAt,proto3" json:"expire_at,omitempty"`
	// updated_at indicates when the IndexRuleBinding is updated
	UpdatedAt *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// contains filtered or unexported fields
}

IndexRuleBinding is a bridge to connect severalIndexRules to a subject This binding is valid between begin_at_nanoseconds and expire_at_nanoseconds, that provides flexible strategies to control how to generate time series indices.

func (*IndexRuleBinding) Descriptor deprecated 

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

Deprecated: Use IndexRuleBinding.ProtoReflect.Descriptor instead.

func (*IndexRuleBinding) GetBeginAt 

func (x *IndexRuleBinding) GetBeginAt() *timestamppb.Timestamp

func (*IndexRuleBinding) GetExpireAt 

func (x *IndexRuleBinding) GetExpireAt() *timestamppb.Timestamp

func (*IndexRuleBinding) GetMetadata 

func (x *IndexRuleBinding) GetMetadata() *v1.Metadata

func (*IndexRuleBinding) GetRules 

func (x *IndexRuleBinding) GetRules() []string

func (*IndexRuleBinding) GetSubject 

func (x *IndexRuleBinding) GetSubject() *Subject

func (*IndexRuleBinding) GetUpdatedAt 

func (x *IndexRuleBinding) GetUpdatedAt() *timestamppb.Timestamp

func (*IndexRuleBinding) ProtoMessage 

func (*IndexRuleBinding) ProtoMessage()

func (*IndexRuleBinding) ProtoReflect 

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

func (*IndexRuleBinding) Reset 

func (x *IndexRuleBinding) Reset()

func (*IndexRuleBinding) String 

func (x *IndexRuleBinding) String() string

type IndexRuleBindingRegistryServiceClient 

type IndexRuleBindingRegistryServiceClient interface {
	Create(ctx context.Context, in *IndexRuleBindingRegistryServiceCreateRequest, opts ...grpc.CallOption) (*IndexRuleBindingRegistryServiceCreateResponse, error)
	Update(ctx context.Context, in *IndexRuleBindingRegistryServiceUpdateRequest, opts ...grpc.CallOption) (*IndexRuleBindingRegistryServiceUpdateResponse, error)
	Delete(ctx context.Context, in *IndexRuleBindingRegistryServiceDeleteRequest, opts ...grpc.CallOption) (*IndexRuleBindingRegistryServiceDeleteResponse, error)
	Get(ctx context.Context, in *IndexRuleBindingRegistryServiceGetRequest, opts ...grpc.CallOption) (*IndexRuleBindingRegistryServiceGetResponse, error)
	List(ctx context.Context, in *IndexRuleBindingRegistryServiceListRequest, opts ...grpc.CallOption) (*IndexRuleBindingRegistryServiceListResponse, error)
}

IndexRuleBindingRegistryServiceClient is the client API for IndexRuleBindingRegistryService 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 NewIndexRuleBindingRegistryServiceClient 

func NewIndexRuleBindingRegistryServiceClient(cc grpc.ClientConnInterface) IndexRuleBindingRegistryServiceClient

type IndexRuleBindingRegistryServiceCreateRequest 

type IndexRuleBindingRegistryServiceCreateRequest struct {
	IndexRuleBinding *IndexRuleBinding `protobuf:"bytes,1,opt,name=index_rule_binding,json=indexRuleBinding,proto3" json:"index_rule_binding,omitempty"`
	// contains filtered or unexported fields
}

func (*IndexRuleBindingRegistryServiceCreateRequest) Descriptor deprecated 

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

Deprecated: Use IndexRuleBindingRegistryServiceCreateRequest.ProtoReflect.Descriptor instead.

func (*IndexRuleBindingRegistryServiceCreateRequest) GetIndexRuleBinding 

func (x *IndexRuleBindingRegistryServiceCreateRequest) GetIndexRuleBinding() *IndexRuleBinding

func (*IndexRuleBindingRegistryServiceCreateRequest) ProtoMessage 

func (*IndexRuleBindingRegistryServiceCreateRequest) ProtoMessage()

func (*IndexRuleBindingRegistryServiceCreateRequest) ProtoReflect 

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

func (*IndexRuleBindingRegistryServiceCreateRequest) Reset 

func (x *IndexRuleBindingRegistryServiceCreateRequest) Reset()

func (*IndexRuleBindingRegistryServiceCreateRequest) String 

func (x *IndexRuleBindingRegistryServiceCreateRequest) String() string

type IndexRuleBindingRegistryServiceCreateResponse 

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

func (*IndexRuleBindingRegistryServiceCreateResponse) Descriptor deprecated 

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

Deprecated: Use IndexRuleBindingRegistryServiceCreateResponse.ProtoReflect.Descriptor instead.

func (*IndexRuleBindingRegistryServiceCreateResponse) ProtoMessage 

func (*IndexRuleBindingRegistryServiceCreateResponse) ProtoMessage()

func (*IndexRuleBindingRegistryServiceCreateResponse) ProtoReflect 

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

func (*IndexRuleBindingRegistryServiceCreateResponse) Reset 

func (x *IndexRuleBindingRegistryServiceCreateResponse) Reset()

func (*IndexRuleBindingRegistryServiceCreateResponse) String 

func (x *IndexRuleBindingRegistryServiceCreateResponse) String() string

type IndexRuleBindingRegistryServiceDeleteRequest 

type IndexRuleBindingRegistryServiceDeleteRequest struct {
	Metadata *v1.Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

func (*IndexRuleBindingRegistryServiceDeleteRequest) Descriptor deprecated 

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

Deprecated: Use IndexRuleBindingRegistryServiceDeleteRequest.ProtoReflect.Descriptor instead.

func (*IndexRuleBindingRegistryServiceDeleteRequest) GetMetadata 

func (x *IndexRuleBindingRegistryServiceDeleteRequest) GetMetadata() *v1.Metadata

func (*IndexRuleBindingRegistryServiceDeleteRequest) ProtoMessage 

func (*IndexRuleBindingRegistryServiceDeleteRequest) ProtoMessage()

func (*IndexRuleBindingRegistryServiceDeleteRequest) ProtoReflect 

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

func (*IndexRuleBindingRegistryServiceDeleteRequest) Reset 

func (x *IndexRuleBindingRegistryServiceDeleteRequest) Reset()

func (*IndexRuleBindingRegistryServiceDeleteRequest) String 

func (x *IndexRuleBindingRegistryServiceDeleteRequest) String() string

type IndexRuleBindingRegistryServiceDeleteResponse 

type IndexRuleBindingRegistryServiceDeleteResponse struct {
	Deleted bool `protobuf:"varint,1,opt,name=deleted,proto3" json:"deleted,omitempty"`
	// contains filtered or unexported fields
}

func (*IndexRuleBindingRegistryServiceDeleteResponse) Descriptor deprecated 

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

Deprecated: Use IndexRuleBindingRegistryServiceDeleteResponse.ProtoReflect.Descriptor instead.

func (*IndexRuleBindingRegistryServiceDeleteResponse) GetDeleted 

func (x *IndexRuleBindingRegistryServiceDeleteResponse) GetDeleted() bool

func (*IndexRuleBindingRegistryServiceDeleteResponse) ProtoMessage 

func (*IndexRuleBindingRegistryServiceDeleteResponse) ProtoMessage()

func (*IndexRuleBindingRegistryServiceDeleteResponse) ProtoReflect 

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

func (*IndexRuleBindingRegistryServiceDeleteResponse) Reset 

func (x *IndexRuleBindingRegistryServiceDeleteResponse) Reset()

func (*IndexRuleBindingRegistryServiceDeleteResponse) String 

func (x *IndexRuleBindingRegistryServiceDeleteResponse) String() string

type IndexRuleBindingRegistryServiceGetRequest 

type IndexRuleBindingRegistryServiceGetRequest struct {
	Metadata *v1.Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

func (*IndexRuleBindingRegistryServiceGetRequest) Descriptor deprecated 

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

Deprecated: Use IndexRuleBindingRegistryServiceGetRequest.ProtoReflect.Descriptor instead.

func (*IndexRuleBindingRegistryServiceGetRequest) GetMetadata 

func (x *IndexRuleBindingRegistryServiceGetRequest) GetMetadata() *v1.Metadata

func (*IndexRuleBindingRegistryServiceGetRequest) ProtoMessage 

func (*IndexRuleBindingRegistryServiceGetRequest) ProtoMessage()

func (*IndexRuleBindingRegistryServiceGetRequest) ProtoReflect 

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

func (*IndexRuleBindingRegistryServiceGetRequest) Reset 

func (x *IndexRuleBindingRegistryServiceGetRequest) Reset()

func (*IndexRuleBindingRegistryServiceGetRequest) String 

func (x *IndexRuleBindingRegistryServiceGetRequest) String() string

type IndexRuleBindingRegistryServiceGetResponse 

type IndexRuleBindingRegistryServiceGetResponse struct {
	IndexRuleBinding *IndexRuleBinding `protobuf:"bytes,1,opt,name=index_rule_binding,json=indexRuleBinding,proto3" json:"index_rule_binding,omitempty"`
	// contains filtered or unexported fields
}

func (*IndexRuleBindingRegistryServiceGetResponse) Descriptor deprecated 

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

Deprecated: Use IndexRuleBindingRegistryServiceGetResponse.ProtoReflect.Descriptor instead.

func (*IndexRuleBindingRegistryServiceGetResponse) GetIndexRuleBinding 

func (x *IndexRuleBindingRegistryServiceGetResponse) GetIndexRuleBinding() *IndexRuleBinding

func (*IndexRuleBindingRegistryServiceGetResponse) ProtoMessage 

func (*IndexRuleBindingRegistryServiceGetResponse) ProtoMessage()

func (*IndexRuleBindingRegistryServiceGetResponse) ProtoReflect 

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

func (*IndexRuleBindingRegistryServiceGetResponse) Reset 

func (x *IndexRuleBindingRegistryServiceGetResponse) Reset()

func (*IndexRuleBindingRegistryServiceGetResponse) String 

func (x *IndexRuleBindingRegistryServiceGetResponse) String() string

type IndexRuleBindingRegistryServiceListRequest 

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

func (*IndexRuleBindingRegistryServiceListRequest) Descriptor deprecated 

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

Deprecated: Use IndexRuleBindingRegistryServiceListRequest.ProtoReflect.Descriptor instead.

func (*IndexRuleBindingRegistryServiceListRequest) GetGroup 

func (x *IndexRuleBindingRegistryServiceListRequest) GetGroup() string

func (*IndexRuleBindingRegistryServiceListRequest) ProtoMessage 

func (*IndexRuleBindingRegistryServiceListRequest) ProtoMessage()

func (*IndexRuleBindingRegistryServiceListRequest) ProtoReflect 

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

func (*IndexRuleBindingRegistryServiceListRequest) Reset 

func (x *IndexRuleBindingRegistryServiceListRequest) Reset()

func (*IndexRuleBindingRegistryServiceListRequest) String 

func (x *IndexRuleBindingRegistryServiceListRequest) String() string

type IndexRuleBindingRegistryServiceListResponse 

type IndexRuleBindingRegistryServiceListResponse struct {
	IndexRuleBinding []*IndexRuleBinding `protobuf:"bytes,1,rep,name=index_rule_binding,json=indexRuleBinding,proto3" json:"index_rule_binding,omitempty"`
	// contains filtered or unexported fields
}

func (*IndexRuleBindingRegistryServiceListResponse) Descriptor deprecated 

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

Deprecated: Use IndexRuleBindingRegistryServiceListResponse.ProtoReflect.Descriptor instead.

func (*IndexRuleBindingRegistryServiceListResponse) GetIndexRuleBinding 

func (x *IndexRuleBindingRegistryServiceListResponse) GetIndexRuleBinding() []*IndexRuleBinding

func (*IndexRuleBindingRegistryServiceListResponse) ProtoMessage 

func (*IndexRuleBindingRegistryServiceListResponse) ProtoMessage()

func (*IndexRuleBindingRegistryServiceListResponse) ProtoReflect 

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

func (*IndexRuleBindingRegistryServiceListResponse) Reset 

func (x *IndexRuleBindingRegistryServiceListResponse) Reset()

func (*IndexRuleBindingRegistryServiceListResponse) String 

func (x *IndexRuleBindingRegistryServiceListResponse) String() string

type IndexRuleBindingRegistryServiceServer 

type IndexRuleBindingRegistryServiceServer interface {
	Create(context.Context, *IndexRuleBindingRegistryServiceCreateRequest) (*IndexRuleBindingRegistryServiceCreateResponse, error)
	Update(context.Context, *IndexRuleBindingRegistryServiceUpdateRequest) (*IndexRuleBindingRegistryServiceUpdateResponse, error)
	Delete(context.Context, *IndexRuleBindingRegistryServiceDeleteRequest) (*IndexRuleBindingRegistryServiceDeleteResponse, error)
	Get(context.Context, *IndexRuleBindingRegistryServiceGetRequest) (*IndexRuleBindingRegistryServiceGetResponse, error)
	List(context.Context, *IndexRuleBindingRegistryServiceListRequest) (*IndexRuleBindingRegistryServiceListResponse, error)
	// contains filtered or unexported methods
}

IndexRuleBindingRegistryServiceServer is the server API for IndexRuleBindingRegistryService service. All implementations must embed UnimplementedIndexRuleBindingRegistryServiceServer for forward compatibility

type IndexRuleBindingRegistryServiceUpdateRequest 

type IndexRuleBindingRegistryServiceUpdateRequest struct {
	IndexRuleBinding *IndexRuleBinding `protobuf:"bytes,1,opt,name=index_rule_binding,json=indexRuleBinding,proto3" json:"index_rule_binding,omitempty"`
	// contains filtered or unexported fields
}

func (*IndexRuleBindingRegistryServiceUpdateRequest) Descriptor deprecated 

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

Deprecated: Use IndexRuleBindingRegistryServiceUpdateRequest.ProtoReflect.Descriptor instead.

func (*IndexRuleBindingRegistryServiceUpdateRequest) GetIndexRuleBinding 

func (x *IndexRuleBindingRegistryServiceUpdateRequest) GetIndexRuleBinding() *IndexRuleBinding

func (*IndexRuleBindingRegistryServiceUpdateRequest) ProtoMessage 

func (*IndexRuleBindingRegistryServiceUpdateRequest) ProtoMessage()

func (*IndexRuleBindingRegistryServiceUpdateRequest) ProtoReflect 

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

func (*IndexRuleBindingRegistryServiceUpdateRequest) Reset 

func (x *IndexRuleBindingRegistryServiceUpdateRequest) Reset()

func (*IndexRuleBindingRegistryServiceUpdateRequest) String 

func (x *IndexRuleBindingRegistryServiceUpdateRequest) String() string

type IndexRuleBindingRegistryServiceUpdateResponse 

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

func (*IndexRuleBindingRegistryServiceUpdateResponse) Descriptor deprecated 

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

Deprecated: Use IndexRuleBindingRegistryServiceUpdateResponse.ProtoReflect.Descriptor instead.

func (*IndexRuleBindingRegistryServiceUpdateResponse) ProtoMessage 

func (*IndexRuleBindingRegistryServiceUpdateResponse) ProtoMessage()

func (*IndexRuleBindingRegistryServiceUpdateResponse) ProtoReflect 

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

func (*IndexRuleBindingRegistryServiceUpdateResponse) Reset 

func (x *IndexRuleBindingRegistryServiceUpdateResponse) Reset()

func (*IndexRuleBindingRegistryServiceUpdateResponse) String 

func (x *IndexRuleBindingRegistryServiceUpdateResponse) String() string

type IndexRuleRegistryServiceClient 

type IndexRuleRegistryServiceClient interface {
	Create(ctx context.Context, in *IndexRuleRegistryServiceCreateRequest, opts ...grpc.CallOption) (*IndexRuleRegistryServiceCreateResponse, error)
	Update(ctx context.Context, in *IndexRuleRegistryServiceUpdateRequest, opts ...grpc.CallOption) (*IndexRuleRegistryServiceUpdateResponse, error)
	Delete(ctx context.Context, in *IndexRuleRegistryServiceDeleteRequest, opts ...grpc.CallOption) (*IndexRuleRegistryServiceDeleteResponse, error)
	Get(ctx context.Context, in *IndexRuleRegistryServiceGetRequest, opts ...grpc.CallOption) (*IndexRuleRegistryServiceGetResponse, error)
	List(ctx context.Context, in *IndexRuleRegistryServiceListRequest, opts ...grpc.CallOption) (*IndexRuleRegistryServiceListResponse, error)
}

IndexRuleRegistryServiceClient is the client API for IndexRuleRegistryService 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 NewIndexRuleRegistryServiceClient 

func NewIndexRuleRegistryServiceClient(cc grpc.ClientConnInterface) IndexRuleRegistryServiceClient

type IndexRuleRegistryServiceCreateRequest 

type IndexRuleRegistryServiceCreateRequest struct {
	IndexRule *IndexRule `protobuf:"bytes,1,opt,name=index_rule,json=indexRule,proto3" json:"index_rule,omitempty"`
	// contains filtered or unexported fields
}

func (*IndexRuleRegistryServiceCreateRequest) Descriptor deprecated 

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

Deprecated: Use IndexRuleRegistryServiceCreateRequest.ProtoReflect.Descriptor instead.

func (*IndexRuleRegistryServiceCreateRequest) GetIndexRule 

func (x *IndexRuleRegistryServiceCreateRequest) GetIndexRule() *IndexRule

func (*IndexRuleRegistryServiceCreateRequest) ProtoMessage 

func (*IndexRuleRegistryServiceCreateRequest) ProtoMessage()

func (*IndexRuleRegistryServiceCreateRequest) ProtoReflect 

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

func (*IndexRuleRegistryServiceCreateRequest) Reset 

func (x *IndexRuleRegistryServiceCreateRequest) Reset()

func (*IndexRuleRegistryServiceCreateRequest) String 

func (x *IndexRuleRegistryServiceCreateRequest) String() string

type IndexRuleRegistryServiceCreateResponse 

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

func (*IndexRuleRegistryServiceCreateResponse) Descriptor deprecated 

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

Deprecated: Use IndexRuleRegistryServiceCreateResponse.ProtoReflect.Descriptor instead.

func (*IndexRuleRegistryServiceCreateResponse) ProtoMessage 

func (*IndexRuleRegistryServiceCreateResponse) ProtoMessage()

func (*IndexRuleRegistryServiceCreateResponse) ProtoReflect 

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

func (*IndexRuleRegistryServiceCreateResponse) Reset 

func (x *IndexRuleRegistryServiceCreateResponse) Reset()

func (*IndexRuleRegistryServiceCreateResponse) String 

func (x *IndexRuleRegistryServiceCreateResponse) String() string

type IndexRuleRegistryServiceDeleteRequest 

type IndexRuleRegistryServiceDeleteRequest struct {
	Metadata *v1.Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

func (*IndexRuleRegistryServiceDeleteRequest) Descriptor deprecated 

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

Deprecated: Use IndexRuleRegistryServiceDeleteRequest.ProtoReflect.Descriptor instead.

func (*IndexRuleRegistryServiceDeleteRequest) GetMetadata 

func (x *IndexRuleRegistryServiceDeleteRequest) GetMetadata() *v1.Metadata

func (*IndexRuleRegistryServiceDeleteRequest) ProtoMessage 

func (*IndexRuleRegistryServiceDeleteRequest) ProtoMessage()

func (*IndexRuleRegistryServiceDeleteRequest) ProtoReflect 

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

func (*IndexRuleRegistryServiceDeleteRequest) Reset 

func (x *IndexRuleRegistryServiceDeleteRequest) Reset()

func (*IndexRuleRegistryServiceDeleteRequest) String 

func (x *IndexRuleRegistryServiceDeleteRequest) String() string

type IndexRuleRegistryServiceDeleteResponse 

type IndexRuleRegistryServiceDeleteResponse struct {
	Deleted bool `protobuf:"varint,1,opt,name=deleted,proto3" json:"deleted,omitempty"`
	// contains filtered or unexported fields
}

func (*IndexRuleRegistryServiceDeleteResponse) Descriptor deprecated 

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

Deprecated: Use IndexRuleRegistryServiceDeleteResponse.ProtoReflect.Descriptor instead.

func (*IndexRuleRegistryServiceDeleteResponse) GetDeleted 

func (x *IndexRuleRegistryServiceDeleteResponse) GetDeleted() bool

func (*IndexRuleRegistryServiceDeleteResponse) ProtoMessage 

func (*IndexRuleRegistryServiceDeleteResponse) ProtoMessage()

func (*IndexRuleRegistryServiceDeleteResponse) ProtoReflect 

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

func (*IndexRuleRegistryServiceDeleteResponse) Reset 

func (x *IndexRuleRegistryServiceDeleteResponse) Reset()

func (*IndexRuleRegistryServiceDeleteResponse) String 

func (x *IndexRuleRegistryServiceDeleteResponse) String() string

type IndexRuleRegistryServiceGetRequest 

type IndexRuleRegistryServiceGetRequest struct {
	Metadata *v1.Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

func (*IndexRuleRegistryServiceGetRequest) Descriptor deprecated 

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

Deprecated: Use IndexRuleRegistryServiceGetRequest.ProtoReflect.Descriptor instead.

func (*IndexRuleRegistryServiceGetRequest) GetMetadata 

func (x *IndexRuleRegistryServiceGetRequest) GetMetadata() *v1.Metadata

func (*IndexRuleRegistryServiceGetRequest) ProtoMessage 

func (*IndexRuleRegistryServiceGetRequest) ProtoMessage()

func (*IndexRuleRegistryServiceGetRequest) ProtoReflect 

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

func (*IndexRuleRegistryServiceGetRequest) Reset 

func (x *IndexRuleRegistryServiceGetRequest) Reset()

func (*IndexRuleRegistryServiceGetRequest) String 

func (x *IndexRuleRegistryServiceGetRequest) String() string

type IndexRuleRegistryServiceGetResponse 

type IndexRuleRegistryServiceGetResponse struct {
	IndexRule *IndexRule `protobuf:"bytes,1,opt,name=index_rule,json=indexRule,proto3" json:"index_rule,omitempty"`
	// contains filtered or unexported fields
}

func (*IndexRuleRegistryServiceGetResponse) Descriptor deprecated 

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

Deprecated: Use IndexRuleRegistryServiceGetResponse.ProtoReflect.Descriptor instead.

func (*IndexRuleRegistryServiceGetResponse) GetIndexRule 

func (x *IndexRuleRegistryServiceGetResponse) GetIndexRule() *IndexRule

func (*IndexRuleRegistryServiceGetResponse) ProtoMessage 

func (*IndexRuleRegistryServiceGetResponse) ProtoMessage()

func (*IndexRuleRegistryServiceGetResponse) ProtoReflect 

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

func (*IndexRuleRegistryServiceGetResponse) Reset 

func (x *IndexRuleRegistryServiceGetResponse) Reset()

func (*IndexRuleRegistryServiceGetResponse) String 

func (x *IndexRuleRegistryServiceGetResponse) String() string

type IndexRuleRegistryServiceListRequest 

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

func (*IndexRuleRegistryServiceListRequest) Descriptor deprecated 

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

Deprecated: Use IndexRuleRegistryServiceListRequest.ProtoReflect.Descriptor instead.

func (*IndexRuleRegistryServiceListRequest) GetGroup 

func (x *IndexRuleRegistryServiceListRequest) GetGroup() string

func (*IndexRuleRegistryServiceListRequest) ProtoMessage 

func (*IndexRuleRegistryServiceListRequest) ProtoMessage()

func (*IndexRuleRegistryServiceListRequest) ProtoReflect 

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

func (*IndexRuleRegistryServiceListRequest) Reset 

func (x *IndexRuleRegistryServiceListRequest) Reset()

func (*IndexRuleRegistryServiceListRequest) String 

func (x *IndexRuleRegistryServiceListRequest) String() string

type IndexRuleRegistryServiceListResponse 

type IndexRuleRegistryServiceListResponse struct {
	IndexRule []*IndexRule `protobuf:"bytes,1,rep,name=index_rule,json=indexRule,proto3" json:"index_rule,omitempty"`
	// contains filtered or unexported fields
}

func (*IndexRuleRegistryServiceListResponse) Descriptor deprecated 

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

Deprecated: Use IndexRuleRegistryServiceListResponse.ProtoReflect.Descriptor instead.

func (*IndexRuleRegistryServiceListResponse) GetIndexRule 

func (x *IndexRuleRegistryServiceListResponse) GetIndexRule() []*IndexRule

func (*IndexRuleRegistryServiceListResponse) ProtoMessage 

func (*IndexRuleRegistryServiceListResponse) ProtoMessage()

func (*IndexRuleRegistryServiceListResponse) ProtoReflect 

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

func (*IndexRuleRegistryServiceListResponse) Reset 

func (x *IndexRuleRegistryServiceListResponse) Reset()

func (*IndexRuleRegistryServiceListResponse) String 

func (x *IndexRuleRegistryServiceListResponse) String() string

type IndexRuleRegistryServiceServer 

type IndexRuleRegistryServiceServer interface {
	Create(context.Context, *IndexRuleRegistryServiceCreateRequest) (*IndexRuleRegistryServiceCreateResponse, error)
	Update(context.Context, *IndexRuleRegistryServiceUpdateRequest) (*IndexRuleRegistryServiceUpdateResponse, error)
	Delete(context.Context, *IndexRuleRegistryServiceDeleteRequest) (*IndexRuleRegistryServiceDeleteResponse, error)
	Get(context.Context, *IndexRuleRegistryServiceGetRequest) (*IndexRuleRegistryServiceGetResponse, error)
	List(context.Context, *IndexRuleRegistryServiceListRequest) (*IndexRuleRegistryServiceListResponse, error)
	// contains filtered or unexported methods
}

IndexRuleRegistryServiceServer is the server API for IndexRuleRegistryService service. All implementations must embed UnimplementedIndexRuleRegistryServiceServer for forward compatibility

type IndexRuleRegistryServiceUpdateRequest 

type IndexRuleRegistryServiceUpdateRequest struct {
	IndexRule *IndexRule `protobuf:"bytes,1,opt,name=index_rule,json=indexRule,proto3" json:"index_rule,omitempty"`
	// contains filtered or unexported fields
}

func (*IndexRuleRegistryServiceUpdateRequest) Descriptor deprecated 

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

Deprecated: Use IndexRuleRegistryServiceUpdateRequest.ProtoReflect.Descriptor instead.

func (*IndexRuleRegistryServiceUpdateRequest) GetIndexRule 

func (x *IndexRuleRegistryServiceUpdateRequest) GetIndexRule() *IndexRule

func (*IndexRuleRegistryServiceUpdateRequest) ProtoMessage 

func (*IndexRuleRegistryServiceUpdateRequest) ProtoMessage()

func (*IndexRuleRegistryServiceUpdateRequest) ProtoReflect 

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

func (*IndexRuleRegistryServiceUpdateRequest) Reset 

func (x *IndexRuleRegistryServiceUpdateRequest) Reset()

func (*IndexRuleRegistryServiceUpdateRequest) String 

func (x *IndexRuleRegistryServiceUpdateRequest) String() string

type IndexRuleRegistryServiceUpdateResponse 

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

func (*IndexRuleRegistryServiceUpdateResponse) Descriptor deprecated 

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

Deprecated: Use IndexRuleRegistryServiceUpdateResponse.ProtoReflect.Descriptor instead.

func (*IndexRuleRegistryServiceUpdateResponse) ProtoMessage 

func (*IndexRuleRegistryServiceUpdateResponse) ProtoMessage()

func (*IndexRuleRegistryServiceUpdateResponse) ProtoReflect 

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

func (*IndexRuleRegistryServiceUpdateResponse) Reset 

func (x *IndexRuleRegistryServiceUpdateResponse) Reset()

func (*IndexRuleRegistryServiceUpdateResponse) String 

func (x *IndexRuleRegistryServiceUpdateResponse) String() string

type IndexRule_Location 

type IndexRule_Location int32
const (
	IndexRule_LOCATION_UNSPECIFIED IndexRule_Location = 0
	IndexRule_LOCATION_SERIES      IndexRule_Location = 1
	IndexRule_LOCATION_GLOBAL      IndexRule_Location = 2
)

func (IndexRule_Location) Descriptor 

func (IndexRule_Location) Descriptor() protoreflect.EnumDescriptor

func (IndexRule_Location) Enum 

func (x IndexRule_Location) Enum() *IndexRule_Location

func (IndexRule_Location) EnumDescriptor deprecated 

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

Deprecated: Use IndexRule_Location.Descriptor instead.

func (IndexRule_Location) Number 

func (x IndexRule_Location) Number() protoreflect.EnumNumber

func (IndexRule_Location) String 

func (x IndexRule_Location) String() string

func (IndexRule_Location) Type 

func (IndexRule_Location) Type() protoreflect.EnumType

type IndexRule_Type 

type IndexRule_Type int32

Type determine the index structure under the hood 

const (
	IndexRule_TYPE_UNSPECIFIED IndexRule_Type = 0
	IndexRule_TYPE_TREE        IndexRule_Type = 1
	IndexRule_TYPE_INVERTED    IndexRule_Type = 2
)

func (IndexRule_Type) Descriptor 

func (IndexRule_Type) Descriptor() protoreflect.EnumDescriptor

func (IndexRule_Type) Enum 

func (x IndexRule_Type) Enum() *IndexRule_Type

func (IndexRule_Type) EnumDescriptor deprecated 

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

Deprecated: Use IndexRule_Type.Descriptor instead.

func (IndexRule_Type) Number 

func (x IndexRule_Type) Number() protoreflect.EnumNumber

func (IndexRule_Type) String 

func (x IndexRule_Type) String() string

func (IndexRule_Type) Type 

func (IndexRule_Type) Type() protoreflect.EnumType

type Measure 

type Measure struct {

	// metadata is the identity of a measure
	Metadata *v1.Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// tag_families are for filter measures
	TagFamilies []*TagFamilySpec `protobuf:"bytes,2,rep,name=tag_families,json=tagFamilies,proto3" json:"tag_families,omitempty"`
	// fields denote measure values
	Fields []*FieldSpec `protobuf:"bytes,3,rep,name=fields,proto3" json:"fields,omitempty"`
	// entity indicates which tags will be to generate a series and shard a measure
	Entity *Entity `protobuf:"bytes,4,opt,name=entity,proto3" json:"entity,omitempty"`
	// interval indicates how frequently to send a data point
	// valid time units are "ns", "us" (or "µs"), "ms", "s", "m", "h", "d".
	Interval string `protobuf:"bytes,5,opt,name=interval,proto3" json:"interval,omitempty"`
	// updated_at indicates when the measure is updated
	UpdatedAt *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// contains filtered or unexported fields
}

Measure intends to store data point

func (*Measure) Descriptor deprecated 

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

Deprecated: Use Measure.ProtoReflect.Descriptor instead.

func (*Measure) GetEntity 

func (x *Measure) GetEntity() *Entity

func (*Measure) GetFields 

func (x *Measure) GetFields() []*FieldSpec

func (*Measure) GetInterval 

func (x *Measure) GetInterval() string

func (*Measure) GetMetadata 

func (x *Measure) GetMetadata() *v1.Metadata

func (*Measure) GetTagFamilies 

func (x *Measure) GetTagFamilies() []*TagFamilySpec

func (*Measure) GetUpdatedAt 

func (x *Measure) GetUpdatedAt() *timestamppb.Timestamp

func (*Measure) ProtoMessage 

func (*Measure) ProtoMessage()

func (*Measure) ProtoReflect 

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

func (*Measure) Reset 

func (x *Measure) Reset()

func (*Measure) String 

func (x *Measure) String() string

type MeasureRegistryServiceClient 

type MeasureRegistryServiceClient interface {
	Create(ctx context.Context, in *MeasureRegistryServiceCreateRequest, opts ...grpc.CallOption) (*MeasureRegistryServiceCreateResponse, error)
	Update(ctx context.Context, in *MeasureRegistryServiceUpdateRequest, opts ...grpc.CallOption) (*MeasureRegistryServiceUpdateResponse, error)
	Delete(ctx context.Context, in *MeasureRegistryServiceDeleteRequest, opts ...grpc.CallOption) (*MeasureRegistryServiceDeleteResponse, error)
	Get(ctx context.Context, in *MeasureRegistryServiceGetRequest, opts ...grpc.CallOption) (*MeasureRegistryServiceGetResponse, error)
	List(ctx context.Context, in *MeasureRegistryServiceListRequest, opts ...grpc.CallOption) (*MeasureRegistryServiceListResponse, error)
}

MeasureRegistryServiceClient is the client API for MeasureRegistryService 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 NewMeasureRegistryServiceClient 

func NewMeasureRegistryServiceClient(cc grpc.ClientConnInterface) MeasureRegistryServiceClient

type MeasureRegistryServiceCreateRequest 

type MeasureRegistryServiceCreateRequest struct {
	Measure *Measure `protobuf:"bytes,1,opt,name=measure,proto3" json:"measure,omitempty"`
	// contains filtered or unexported fields
}

func (*MeasureRegistryServiceCreateRequest) Descriptor deprecated 

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

Deprecated: Use MeasureRegistryServiceCreateRequest.ProtoReflect.Descriptor instead.

func (*MeasureRegistryServiceCreateRequest) GetMeasure 

func (x *MeasureRegistryServiceCreateRequest) GetMeasure() *Measure

func (*MeasureRegistryServiceCreateRequest) ProtoMessage 

func (*MeasureRegistryServiceCreateRequest) ProtoMessage()

func (*MeasureRegistryServiceCreateRequest) ProtoReflect 

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

func (*MeasureRegistryServiceCreateRequest) Reset 

func (x *MeasureRegistryServiceCreateRequest) Reset()

func (*MeasureRegistryServiceCreateRequest) String 

func (x *MeasureRegistryServiceCreateRequest) String() string

type MeasureRegistryServiceCreateResponse 

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

func (*MeasureRegistryServiceCreateResponse) Descriptor deprecated 

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

Deprecated: Use MeasureRegistryServiceCreateResponse.ProtoReflect.Descriptor instead.

func (*MeasureRegistryServiceCreateResponse) ProtoMessage 

func (*MeasureRegistryServiceCreateResponse) ProtoMessage()

func (*MeasureRegistryServiceCreateResponse) ProtoReflect 

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

func (*MeasureRegistryServiceCreateResponse) Reset 

func (x *MeasureRegistryServiceCreateResponse) Reset()

func (*MeasureRegistryServiceCreateResponse) String 

func (x *MeasureRegistryServiceCreateResponse) String() string

type MeasureRegistryServiceDeleteRequest 

type MeasureRegistryServiceDeleteRequest struct {
	Metadata *v1.Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

func (*MeasureRegistryServiceDeleteRequest) Descriptor deprecated 

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

Deprecated: Use MeasureRegistryServiceDeleteRequest.ProtoReflect.Descriptor instead.

func (*MeasureRegistryServiceDeleteRequest) GetMetadata 

func (x *MeasureRegistryServiceDeleteRequest) GetMetadata() *v1.Metadata

func (*MeasureRegistryServiceDeleteRequest) ProtoMessage 

func (*MeasureRegistryServiceDeleteRequest) ProtoMessage()

func (*MeasureRegistryServiceDeleteRequest) ProtoReflect 

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

func (*MeasureRegistryServiceDeleteRequest) Reset 

func (x *MeasureRegistryServiceDeleteRequest) Reset()

func (*MeasureRegistryServiceDeleteRequest) String 

func (x *MeasureRegistryServiceDeleteRequest) String() string

type MeasureRegistryServiceDeleteResponse 

type MeasureRegistryServiceDeleteResponse struct {
	Deleted bool `protobuf:"varint,1,opt,name=deleted,proto3" json:"deleted,omitempty"`
	// contains filtered or unexported fields
}

func (*MeasureRegistryServiceDeleteResponse) Descriptor deprecated 

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

Deprecated: Use MeasureRegistryServiceDeleteResponse.ProtoReflect.Descriptor instead.

func (*MeasureRegistryServiceDeleteResponse) GetDeleted 

func (x *MeasureRegistryServiceDeleteResponse) GetDeleted() bool

func (*MeasureRegistryServiceDeleteResponse) ProtoMessage 

func (*MeasureRegistryServiceDeleteResponse) ProtoMessage()

func (*MeasureRegistryServiceDeleteResponse) ProtoReflect 

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

func (*MeasureRegistryServiceDeleteResponse) Reset 

func (x *MeasureRegistryServiceDeleteResponse) Reset()

func (*MeasureRegistryServiceDeleteResponse) String 

func (x *MeasureRegistryServiceDeleteResponse) String() string

type MeasureRegistryServiceGetRequest 

type MeasureRegistryServiceGetRequest struct {
	Metadata *v1.Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

func (*MeasureRegistryServiceGetRequest) Descriptor deprecated 

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

Deprecated: Use MeasureRegistryServiceGetRequest.ProtoReflect.Descriptor instead.

func (*MeasureRegistryServiceGetRequest) GetMetadata 

func (x *MeasureRegistryServiceGetRequest) GetMetadata() *v1.Metadata

func (*MeasureRegistryServiceGetRequest) ProtoMessage 

func (*MeasureRegistryServiceGetRequest) ProtoMessage()

func (*MeasureRegistryServiceGetRequest) ProtoReflect 

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

func (*MeasureRegistryServiceGetRequest) Reset 

func (x *MeasureRegistryServiceGetRequest) Reset()

func (*MeasureRegistryServiceGetRequest) String 

func (x *MeasureRegistryServiceGetRequest) String() string

type MeasureRegistryServiceGetResponse 

type MeasureRegistryServiceGetResponse struct {
	Measure *Measure `protobuf:"bytes,1,opt,name=measure,proto3" json:"measure,omitempty"`
	// contains filtered or unexported fields
}

func (*MeasureRegistryServiceGetResponse) Descriptor deprecated 

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

Deprecated: Use MeasureRegistryServiceGetResponse.ProtoReflect.Descriptor instead.

func (*MeasureRegistryServiceGetResponse) GetMeasure 

func (x *MeasureRegistryServiceGetResponse) GetMeasure() *Measure

func (*MeasureRegistryServiceGetResponse) ProtoMessage 

func (*MeasureRegistryServiceGetResponse) ProtoMessage()

func (*MeasureRegistryServiceGetResponse) ProtoReflect 

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

func (*MeasureRegistryServiceGetResponse) Reset 

func (x *MeasureRegistryServiceGetResponse) Reset()

func (*MeasureRegistryServiceGetResponse) String 

func (x *MeasureRegistryServiceGetResponse) String() string

type MeasureRegistryServiceListRequest 

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

func (*MeasureRegistryServiceListRequest) Descriptor deprecated 

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

Deprecated: Use MeasureRegistryServiceListRequest.ProtoReflect.Descriptor instead.

func (*MeasureRegistryServiceListRequest) GetGroup 

func (x *MeasureRegistryServiceListRequest) GetGroup() string

func (*MeasureRegistryServiceListRequest) ProtoMessage 

func (*MeasureRegistryServiceListRequest) ProtoMessage()

func (*MeasureRegistryServiceListRequest) ProtoReflect 

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

func (*MeasureRegistryServiceListRequest) Reset 

func (x *MeasureRegistryServiceListRequest) Reset()

func (*MeasureRegistryServiceListRequest) String 

func (x *MeasureRegistryServiceListRequest) String() string

type MeasureRegistryServiceListResponse 

type MeasureRegistryServiceListResponse struct {
	Measure []*Measure `protobuf:"bytes,1,rep,name=measure,proto3" json:"measure,omitempty"`
	// contains filtered or unexported fields
}

func (*MeasureRegistryServiceListResponse) Descriptor deprecated 

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

Deprecated: Use MeasureRegistryServiceListResponse.ProtoReflect.Descriptor instead.

func (*MeasureRegistryServiceListResponse) GetMeasure 

func (x *MeasureRegistryServiceListResponse) GetMeasure() []*Measure

func (*MeasureRegistryServiceListResponse) ProtoMessage 

func (*MeasureRegistryServiceListResponse) ProtoMessage()

func (*MeasureRegistryServiceListResponse) ProtoReflect 

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

func (*MeasureRegistryServiceListResponse) Reset 

func (x *MeasureRegistryServiceListResponse) Reset()

func (*MeasureRegistryServiceListResponse) String 

func (x *MeasureRegistryServiceListResponse) String() string

type MeasureRegistryServiceServer 

type MeasureRegistryServiceServer interface {
	Create(context.Context, *MeasureRegistryServiceCreateRequest) (*MeasureRegistryServiceCreateResponse, error)
	Update(context.Context, *MeasureRegistryServiceUpdateRequest) (*MeasureRegistryServiceUpdateResponse, error)
	Delete(context.Context, *MeasureRegistryServiceDeleteRequest) (*MeasureRegistryServiceDeleteResponse, error)
	Get(context.Context, *MeasureRegistryServiceGetRequest) (*MeasureRegistryServiceGetResponse, error)
	List(context.Context, *MeasureRegistryServiceListRequest) (*MeasureRegistryServiceListResponse, error)
	// contains filtered or unexported methods
}

MeasureRegistryServiceServer is the server API for MeasureRegistryService service. All implementations must embed UnimplementedMeasureRegistryServiceServer for forward compatibility

type MeasureRegistryServiceUpdateRequest 

type MeasureRegistryServiceUpdateRequest struct {
	Measure *Measure `protobuf:"bytes,1,opt,name=measure,proto3" json:"measure,omitempty"`
	// contains filtered or unexported fields
}

func (*MeasureRegistryServiceUpdateRequest) Descriptor deprecated 

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

Deprecated: Use MeasureRegistryServiceUpdateRequest.ProtoReflect.Descriptor instead.

func (*MeasureRegistryServiceUpdateRequest) GetMeasure 

func (x *MeasureRegistryServiceUpdateRequest) GetMeasure() *Measure

func (*MeasureRegistryServiceUpdateRequest) ProtoMessage 

func (*MeasureRegistryServiceUpdateRequest) ProtoMessage()

func (*MeasureRegistryServiceUpdateRequest) ProtoReflect 

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

func (*MeasureRegistryServiceUpdateRequest) Reset 

func (x *MeasureRegistryServiceUpdateRequest) Reset()

func (*MeasureRegistryServiceUpdateRequest) String 

func (x *MeasureRegistryServiceUpdateRequest) String() string

type MeasureRegistryServiceUpdateResponse 

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

func (*MeasureRegistryServiceUpdateResponse) Descriptor deprecated 

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

Deprecated: Use MeasureRegistryServiceUpdateResponse.ProtoReflect.Descriptor instead.

func (*MeasureRegistryServiceUpdateResponse) ProtoMessage 

func (*MeasureRegistryServiceUpdateResponse) ProtoMessage()

func (*MeasureRegistryServiceUpdateResponse) ProtoReflect 

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

func (*MeasureRegistryServiceUpdateResponse) Reset 

func (x *MeasureRegistryServiceUpdateResponse) Reset()

func (*MeasureRegistryServiceUpdateResponse) String 

func (x *MeasureRegistryServiceUpdateResponse) String() string

type Node 

type Node struct {
	Id        string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Addr      string                 `protobuf:"bytes,2,opt,name=addr,proto3" json:"addr,omitempty"`
	UpdatedAt *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// contains filtered or unexported fields
}

func (*Node) Descriptor deprecated 

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

Deprecated: Use Node.ProtoReflect.Descriptor instead.

func (*Node) GetAddr 

func (x *Node) GetAddr() string

func (*Node) GetCreatedAt 

func (x *Node) GetCreatedAt() *timestamppb.Timestamp

func (*Node) GetId 

func (x *Node) GetId() string

func (*Node) GetUpdatedAt 

func (x *Node) GetUpdatedAt() *timestamppb.Timestamp

func (*Node) ProtoMessage 

func (*Node) ProtoMessage()

func (*Node) ProtoReflect 

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

func (*Node) Reset 

func (x *Node) Reset()

func (*Node) String 

func (x *Node) String() string

type Shard 

type Shard struct {
	Id        uint64                 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Metadata  *v1.Metadata           `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Catalog   v1.Catalog             `protobuf:"varint,3,opt,name=catalog,proto3,enum=banyandb.common.v1.Catalog" json:"catalog,omitempty"`
	Node      *Node                  `protobuf:"bytes,4,opt,name=node,proto3" json:"node,omitempty"`
	Total     uint32                 `protobuf:"varint,5,opt,name=total,proto3" json:"total,omitempty"`
	UpdatedAt *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// contains filtered or unexported fields
}

func (*Shard) Descriptor deprecated 

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

Deprecated: Use Shard.ProtoReflect.Descriptor instead.

func (*Shard) GetCatalog 

func (x *Shard) GetCatalog() v1.Catalog

func (*Shard) GetCreatedAt 

func (x *Shard) GetCreatedAt() *timestamppb.Timestamp

func (*Shard) GetId 

func (x *Shard) GetId() uint64

func (*Shard) GetMetadata 

func (x *Shard) GetMetadata() *v1.Metadata

func (*Shard) GetNode 

func (x *Shard) GetNode() *Node

func (*Shard) GetTotal 

func (x *Shard) GetTotal() uint32

func (*Shard) GetUpdatedAt 

func (x *Shard) GetUpdatedAt() *timestamppb.Timestamp

func (*Shard) ProtoMessage 

func (*Shard) ProtoMessage()

func (*Shard) ProtoReflect 

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

func (*Shard) Reset 

func (x *Shard) Reset()

func (*Shard) String 

func (x *Shard) String() string

type ShardEvent 

type ShardEvent struct {
	Shard  *Shard                 `protobuf:"bytes,1,opt,name=shard,proto3" json:"shard,omitempty"`
	Action Action                 `protobuf:"varint,2,opt,name=action,proto3,enum=banyandb.database.v1.Action" json:"action,omitempty"`
	Time   *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*ShardEvent) Descriptor deprecated 

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

Deprecated: Use ShardEvent.ProtoReflect.Descriptor instead.

func (*ShardEvent) GetAction 

func (x *ShardEvent) GetAction() Action

func (*ShardEvent) GetShard 

func (x *ShardEvent) GetShard() *Shard

func (*ShardEvent) GetTime 

func (x *ShardEvent) GetTime() *timestamppb.Timestamp

func (*ShardEvent) ProtoMessage 

func (*ShardEvent) ProtoMessage()

func (*ShardEvent) ProtoReflect 

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

func (*ShardEvent) Reset 

func (x *ShardEvent) Reset()

func (*ShardEvent) String 

func (x *ShardEvent) String() string

type Stream 

type Stream struct {

	// metadata is the identity of a trace series
	Metadata *v1.Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// tag_families
	TagFamilies []*TagFamilySpec `protobuf:"bytes,2,rep,name=tag_families,json=tagFamilies,proto3" json:"tag_families,omitempty"`
	// entity indicates how to generate a series and shard a stream
	Entity *Entity `protobuf:"bytes,3,opt,name=entity,proto3" json:"entity,omitempty"`
	// updated_at indicates when the stream is updated
	UpdatedAt *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// contains filtered or unexported fields
}

Stream intends to store streaming data, for example, traces or logs

func (*Stream) Descriptor deprecated 

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

Deprecated: Use Stream.ProtoReflect.Descriptor instead.

func (*Stream) GetEntity 

func (x *Stream) GetEntity() *Entity

func (*Stream) GetMetadata 

func (x *Stream) GetMetadata() *v1.Metadata

func (*Stream) GetTagFamilies 

func (x *Stream) GetTagFamilies() []*TagFamilySpec

func (*Stream) GetUpdatedAt 

func (x *Stream) GetUpdatedAt() *timestamppb.Timestamp

func (*Stream) ProtoMessage 

func (*Stream) ProtoMessage()

func (*Stream) ProtoReflect 

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

func (*Stream) Reset 

func (x *Stream) Reset()

func (*Stream) String 

func (x *Stream) String() string

type StreamRegistryServiceClient 

type StreamRegistryServiceClient interface {
	Create(ctx context.Context, in *StreamRegistryServiceCreateRequest, opts ...grpc.CallOption) (*StreamRegistryServiceCreateResponse, error)
	Update(ctx context.Context, in *StreamRegistryServiceUpdateRequest, opts ...grpc.CallOption) (*StreamRegistryServiceUpdateResponse, error)
	Delete(ctx context.Context, in *StreamRegistryServiceDeleteRequest, opts ...grpc.CallOption) (*StreamRegistryServiceDeleteResponse, error)
	Get(ctx context.Context, in *StreamRegistryServiceGetRequest, opts ...grpc.CallOption) (*StreamRegistryServiceGetResponse, error)
	List(ctx context.Context, in *StreamRegistryServiceListRequest, opts ...grpc.CallOption) (*StreamRegistryServiceListResponse, error)
}

StreamRegistryServiceClient is the client API for StreamRegistryService 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 NewStreamRegistryServiceClient 

func NewStreamRegistryServiceClient(cc grpc.ClientConnInterface) StreamRegistryServiceClient

type StreamRegistryServiceCreateRequest 

type StreamRegistryServiceCreateRequest struct {
	Stream *Stream `protobuf:"bytes,1,opt,name=stream,proto3" json:"stream,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamRegistryServiceCreateRequest) Descriptor deprecated 

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

Deprecated: Use StreamRegistryServiceCreateRequest.ProtoReflect.Descriptor instead.

func (*StreamRegistryServiceCreateRequest) GetStream 

func (x *StreamRegistryServiceCreateRequest) GetStream() *Stream

func (*StreamRegistryServiceCreateRequest) ProtoMessage 

func (*StreamRegistryServiceCreateRequest) ProtoMessage()

func (*StreamRegistryServiceCreateRequest) ProtoReflect 

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

func (*StreamRegistryServiceCreateRequest) Reset 

func (x *StreamRegistryServiceCreateRequest) Reset()

func (*StreamRegistryServiceCreateRequest) String 

func (x *StreamRegistryServiceCreateRequest) String() string

type StreamRegistryServiceCreateResponse 

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

func (*StreamRegistryServiceCreateResponse) Descriptor deprecated 

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

Deprecated: Use StreamRegistryServiceCreateResponse.ProtoReflect.Descriptor instead.

func (*StreamRegistryServiceCreateResponse) ProtoMessage 

func (*StreamRegistryServiceCreateResponse) ProtoMessage()

func (*StreamRegistryServiceCreateResponse) ProtoReflect 

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

func (*StreamRegistryServiceCreateResponse) Reset 

func (x *StreamRegistryServiceCreateResponse) Reset()

func (*StreamRegistryServiceCreateResponse) String 

func (x *StreamRegistryServiceCreateResponse) String() string

type StreamRegistryServiceDeleteRequest 

type StreamRegistryServiceDeleteRequest struct {
	Metadata *v1.Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamRegistryServiceDeleteRequest) Descriptor deprecated 

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

Deprecated: Use StreamRegistryServiceDeleteRequest.ProtoReflect.Descriptor instead.

func (*StreamRegistryServiceDeleteRequest) GetMetadata 

func (x *StreamRegistryServiceDeleteRequest) GetMetadata() *v1.Metadata

func (*StreamRegistryServiceDeleteRequest) ProtoMessage 

func (*StreamRegistryServiceDeleteRequest) ProtoMessage()

func (*StreamRegistryServiceDeleteRequest) ProtoReflect 

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

func (*StreamRegistryServiceDeleteRequest) Reset 

func (x *StreamRegistryServiceDeleteRequest) Reset()

func (*StreamRegistryServiceDeleteRequest) String 

func (x *StreamRegistryServiceDeleteRequest) String() string

type StreamRegistryServiceDeleteResponse 

type StreamRegistryServiceDeleteResponse struct {
	Deleted bool `protobuf:"varint,1,opt,name=deleted,proto3" json:"deleted,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamRegistryServiceDeleteResponse) Descriptor deprecated 

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

Deprecated: Use StreamRegistryServiceDeleteResponse.ProtoReflect.Descriptor instead.

func (*StreamRegistryServiceDeleteResponse) GetDeleted 

func (x *StreamRegistryServiceDeleteResponse) GetDeleted() bool

func (*StreamRegistryServiceDeleteResponse) ProtoMessage 

func (*StreamRegistryServiceDeleteResponse) ProtoMessage()

func (*StreamRegistryServiceDeleteResponse) ProtoReflect 

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

func (*StreamRegistryServiceDeleteResponse) Reset 

func (x *StreamRegistryServiceDeleteResponse) Reset()

func (*StreamRegistryServiceDeleteResponse) String 

func (x *StreamRegistryServiceDeleteResponse) String() string

type StreamRegistryServiceGetRequest 

type StreamRegistryServiceGetRequest struct {
	Metadata *v1.Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamRegistryServiceGetRequest) Descriptor deprecated 

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

Deprecated: Use StreamRegistryServiceGetRequest.ProtoReflect.Descriptor instead.

func (*StreamRegistryServiceGetRequest) GetMetadata 

func (x *StreamRegistryServiceGetRequest) GetMetadata() *v1.Metadata

func (*StreamRegistryServiceGetRequest) ProtoMessage 

func (*StreamRegistryServiceGetRequest) ProtoMessage()

func (*StreamRegistryServiceGetRequest) ProtoReflect 

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

func (*StreamRegistryServiceGetRequest) Reset 

func (x *StreamRegistryServiceGetRequest) Reset()

func (*StreamRegistryServiceGetRequest) String 

func (x *StreamRegistryServiceGetRequest) String() string

type StreamRegistryServiceGetResponse 

type StreamRegistryServiceGetResponse struct {
	Stream *Stream `protobuf:"bytes,1,opt,name=stream,proto3" json:"stream,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamRegistryServiceGetResponse) Descriptor deprecated 

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

Deprecated: Use StreamRegistryServiceGetResponse.ProtoReflect.Descriptor instead.

func (*StreamRegistryServiceGetResponse) GetStream 

func (x *StreamRegistryServiceGetResponse) GetStream() *Stream

func (*StreamRegistryServiceGetResponse) ProtoMessage 

func (*StreamRegistryServiceGetResponse) ProtoMessage()

func (*StreamRegistryServiceGetResponse) ProtoReflect 

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

func (*StreamRegistryServiceGetResponse) Reset 

func (x *StreamRegistryServiceGetResponse) Reset()

func (*StreamRegistryServiceGetResponse) String 

func (x *StreamRegistryServiceGetResponse) String() string

type StreamRegistryServiceListRequest 

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

func (*StreamRegistryServiceListRequest) Descriptor deprecated 

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

Deprecated: Use StreamRegistryServiceListRequest.ProtoReflect.Descriptor instead.

func (*StreamRegistryServiceListRequest) GetGroup 

func (x *StreamRegistryServiceListRequest) GetGroup() string

func (*StreamRegistryServiceListRequest) ProtoMessage 

func (*StreamRegistryServiceListRequest) ProtoMessage()

func (*StreamRegistryServiceListRequest) ProtoReflect 

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

func (*StreamRegistryServiceListRequest) Reset 

func (x *StreamRegistryServiceListRequest) Reset()

func (*StreamRegistryServiceListRequest) String 

func (x *StreamRegistryServiceListRequest) String() string

type StreamRegistryServiceListResponse 

type StreamRegistryServiceListResponse struct {
	Stream []*Stream `protobuf:"bytes,1,rep,name=stream,proto3" json:"stream,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamRegistryServiceListResponse) Descriptor deprecated 

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

Deprecated: Use StreamRegistryServiceListResponse.ProtoReflect.Descriptor instead.

func (*StreamRegistryServiceListResponse) GetStream 

func (x *StreamRegistryServiceListResponse) GetStream() []*Stream

func (*StreamRegistryServiceListResponse) ProtoMessage 

func (*StreamRegistryServiceListResponse) ProtoMessage()

func (*StreamRegistryServiceListResponse) ProtoReflect 

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

func (*StreamRegistryServiceListResponse) Reset 

func (x *StreamRegistryServiceListResponse) Reset()

func (*StreamRegistryServiceListResponse) String 

func (x *StreamRegistryServiceListResponse) String() string

type StreamRegistryServiceServer 

type StreamRegistryServiceServer interface {
	Create(context.Context, *StreamRegistryServiceCreateRequest) (*StreamRegistryServiceCreateResponse, error)
	Update(context.Context, *StreamRegistryServiceUpdateRequest) (*StreamRegistryServiceUpdateResponse, error)
	Delete(context.Context, *StreamRegistryServiceDeleteRequest) (*StreamRegistryServiceDeleteResponse, error)
	Get(context.Context, *StreamRegistryServiceGetRequest) (*StreamRegistryServiceGetResponse, error)
	List(context.Context, *StreamRegistryServiceListRequest) (*StreamRegistryServiceListResponse, error)
	// contains filtered or unexported methods
}

StreamRegistryServiceServer is the server API for StreamRegistryService service. All implementations must embed UnimplementedStreamRegistryServiceServer for forward compatibility

type StreamRegistryServiceUpdateRequest 

type StreamRegistryServiceUpdateRequest struct {
	Stream *Stream `protobuf:"bytes,1,opt,name=stream,proto3" json:"stream,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamRegistryServiceUpdateRequest) Descriptor deprecated 

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

Deprecated: Use StreamRegistryServiceUpdateRequest.ProtoReflect.Descriptor instead.

func (*StreamRegistryServiceUpdateRequest) GetStream 

func (x *StreamRegistryServiceUpdateRequest) GetStream() *Stream

func (*StreamRegistryServiceUpdateRequest) ProtoMessage 

func (*StreamRegistryServiceUpdateRequest) ProtoMessage()

func (*StreamRegistryServiceUpdateRequest) ProtoReflect 

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

func (*StreamRegistryServiceUpdateRequest) Reset 

func (x *StreamRegistryServiceUpdateRequest) Reset()

func (*StreamRegistryServiceUpdateRequest) String 

func (x *StreamRegistryServiceUpdateRequest) String() string

type StreamRegistryServiceUpdateResponse 

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

func (*StreamRegistryServiceUpdateResponse) Descriptor deprecated 

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

Deprecated: Use StreamRegistryServiceUpdateResponse.ProtoReflect.Descriptor instead.

func (*StreamRegistryServiceUpdateResponse) ProtoMessage 

func (*StreamRegistryServiceUpdateResponse) ProtoMessage()

func (*StreamRegistryServiceUpdateResponse) ProtoReflect 

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

func (*StreamRegistryServiceUpdateResponse) Reset 

func (x *StreamRegistryServiceUpdateResponse) Reset()

func (*StreamRegistryServiceUpdateResponse) String 

func (x *StreamRegistryServiceUpdateResponse) String() string

type Subject 

type Subject struct {

	// catalog is where the subject belongs to
	Catalog v1.Catalog `protobuf:"varint,1,opt,name=catalog,proto3,enum=banyandb.common.v1.Catalog" json:"catalog,omitempty"`
	// name refers to a stream or measure in a particular catalog
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Subject defines which stream or measure would generate indices

func (*Subject) Descriptor deprecated 

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

Deprecated: Use Subject.ProtoReflect.Descriptor instead.

func (*Subject) GetCatalog 

func (x *Subject) GetCatalog() v1.Catalog

func (*Subject) GetName 

func (x *Subject) GetName() string

func (*Subject) ProtoMessage 

func (*Subject) ProtoMessage()

func (*Subject) ProtoReflect 

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

func (*Subject) Reset 

func (x *Subject) Reset()

func (*Subject) String 

func (x *Subject) String() string

type TagFamilySpec 

type TagFamilySpec struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// tags defines accepted tags
	Tags []*TagSpec `protobuf:"bytes,2,rep,name=tags,proto3" json:"tags,omitempty"`
	// contains filtered or unexported fields
}

func (*TagFamilySpec) Descriptor deprecated 

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

Deprecated: Use TagFamilySpec.ProtoReflect.Descriptor instead.

func (*TagFamilySpec) GetName 

func (x *TagFamilySpec) GetName() string

func (*TagFamilySpec) GetTags 

func (x *TagFamilySpec) GetTags() []*TagSpec

func (*TagFamilySpec) ProtoMessage 

func (*TagFamilySpec) ProtoMessage()

func (*TagFamilySpec) ProtoReflect 

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

func (*TagFamilySpec) Reset 

func (x *TagFamilySpec) Reset()

func (*TagFamilySpec) String 

func (x *TagFamilySpec) String() string

type TagSpec 

type TagSpec struct {
	Name string  `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Type TagType `protobuf:"varint,2,opt,name=type,proto3,enum=banyandb.database.v1.TagType" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*TagSpec) Descriptor deprecated 

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

Deprecated: Use TagSpec.ProtoReflect.Descriptor instead.

func (*TagSpec) GetName 

func (x *TagSpec) GetName() string

func (*TagSpec) GetType 

func (x *TagSpec) GetType() TagType

func (*TagSpec) ProtoMessage 

func (*TagSpec) ProtoMessage()

func (*TagSpec) ProtoReflect 

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

func (*TagSpec) Reset 

func (x *TagSpec) Reset()

func (*TagSpec) String 

func (x *TagSpec) String() string

type TagType 

type TagType int32
const (
	TagType_TAG_TYPE_UNSPECIFIED  TagType = 0
	TagType_TAG_TYPE_STRING       TagType = 1
	TagType_TAG_TYPE_INT          TagType = 2
	TagType_TAG_TYPE_STRING_ARRAY TagType = 3
	TagType_TAG_TYPE_INT_ARRAY    TagType = 4
	TagType_TAG_TYPE_DATA_BINARY  TagType = 5
	TagType_TAG_TYPE_ID           TagType = 6
)

func (TagType) Descriptor 

func (TagType) Descriptor() protoreflect.EnumDescriptor

func (TagType) Enum 

func (x TagType) Enum() *TagType

func (TagType) EnumDescriptor deprecated 

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

Deprecated: Use TagType.Descriptor instead.

func (TagType) Number 

func (x TagType) Number() protoreflect.EnumNumber

func (TagType) String 

func (x TagType) String() string

func (TagType) Type 

func (TagType) Type() protoreflect.EnumType

type TopNAggregation 

type TopNAggregation struct {

	// metadata is the identity of an aggregation
	Metadata *v1.Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// source_measure denotes the data source of this aggregation
	SourceMeasure *v1.Metadata `protobuf:"bytes,2,opt,name=source_measure,json=sourceMeasure,proto3" json:"source_measure,omitempty"`
	// field_name is the name of field used for ranking
	FieldName string `protobuf:"bytes,3,opt,name=field_name,json=fieldName,proto3" json:"field_name,omitempty"`
	// field_value_sort indicates how to sort fields
	// ASC: bottomN
	// DESC: topN
	// UNSPECIFIED: topN + bottomN
	FieldValueSort v11.Sort `` /* 134-byte string literal not displayed */
	// group_by_tag_names groups data points into statistical counters
	GroupByTagNames []string `protobuf:"bytes,5,rep,name=group_by_tag_names,json=groupByTagNames,proto3" json:"group_by_tag_names,omitempty"`
	// criteria select partial data points from measure
	Criteria []*v11.Criteria `protobuf:"bytes,6,rep,name=criteria,proto3" json:"criteria,omitempty"`
	// counters_number sets the number of counters to be tracked. The default value is 1000
	CountersNumber int32 `protobuf:"varint,7,opt,name=counters_number,json=countersNumber,proto3" json:"counters_number,omitempty"`
	// updated_at indicates when the measure is updated
	UpdatedAt *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// contains filtered or unexported fields
}

TopNAggregation generates offline TopN statistics for a measure's TopN approximation

func (*TopNAggregation) Descriptor deprecated 

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

Deprecated: Use TopNAggregation.ProtoReflect.Descriptor instead.

func (*TopNAggregation) GetCountersNumber 

func (x *TopNAggregation) GetCountersNumber() int32

func (*TopNAggregation) GetCriteria 

func (x *TopNAggregation) GetCriteria() []*v11.Criteria

func (*TopNAggregation) GetFieldName 

func (x *TopNAggregation) GetFieldName() string

func (*TopNAggregation) GetFieldValueSort 

func (x *TopNAggregation) GetFieldValueSort() v11.Sort

func (*TopNAggregation) GetGroupByTagNames 

func (x *TopNAggregation) GetGroupByTagNames() []string

func (*TopNAggregation) GetMetadata 

func (x *TopNAggregation) GetMetadata() *v1.Metadata

func (*TopNAggregation) GetSourceMeasure 

func (x *TopNAggregation) GetSourceMeasure() *v1.Metadata

func (*TopNAggregation) GetUpdatedAt 

func (x *TopNAggregation) GetUpdatedAt() *timestamppb.Timestamp

func (*TopNAggregation) ProtoMessage 

func (*TopNAggregation) ProtoMessage()

func (*TopNAggregation) ProtoReflect 

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

func (*TopNAggregation) Reset 

func (x *TopNAggregation) Reset()

func (*TopNAggregation) String 

func (x *TopNAggregation) String() string

type TopNAggregationRegistryServiceClient 

type TopNAggregationRegistryServiceClient interface {
	Create(ctx context.Context, in *TopNAggregationRegistryServiceCreateRequest, opts ...grpc.CallOption) (*TopNAggregationRegistryServiceCreateResponse, error)
	Update(ctx context.Context, in *TopNAggregationRegistryServiceUpdateRequest, opts ...grpc.CallOption) (*TopNAggregationRegistryServiceUpdateResponse, error)
	Delete(ctx context.Context, in *TopNAggregationRegistryServiceDeleteRequest, opts ...grpc.CallOption) (*TopNAggregationRegistryServiceDeleteResponse, error)
	Get(ctx context.Context, in *TopNAggregationRegistryServiceGetRequest, opts ...grpc.CallOption) (*TopNAggregationRegistryServiceGetResponse, error)
	List(ctx context.Context, in *TopNAggregationRegistryServiceListRequest, opts ...grpc.CallOption) (*TopNAggregationRegistryServiceListResponse, error)
}

TopNAggregationRegistryServiceClient is the client API for TopNAggregationRegistryService 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 NewTopNAggregationRegistryServiceClient 

func NewTopNAggregationRegistryServiceClient(cc grpc.ClientConnInterface) TopNAggregationRegistryServiceClient

type TopNAggregationRegistryServiceCreateRequest 

type TopNAggregationRegistryServiceCreateRequest struct {
	TopNAggregation *TopNAggregation `protobuf:"bytes,1,opt,name=top_n_aggregation,json=topNAggregation,proto3" json:"top_n_aggregation,omitempty"`
	// contains filtered or unexported fields
}

func (*TopNAggregationRegistryServiceCreateRequest) Descriptor deprecated 

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

Deprecated: Use TopNAggregationRegistryServiceCreateRequest.ProtoReflect.Descriptor instead.

func (*TopNAggregationRegistryServiceCreateRequest) GetTopNAggregation 

func (x *TopNAggregationRegistryServiceCreateRequest) GetTopNAggregation() *TopNAggregation

func (*TopNAggregationRegistryServiceCreateRequest) ProtoMessage 

func (*TopNAggregationRegistryServiceCreateRequest) ProtoMessage()

func (*TopNAggregationRegistryServiceCreateRequest) ProtoReflect 

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

func (*TopNAggregationRegistryServiceCreateRequest) Reset 

func (x *TopNAggregationRegistryServiceCreateRequest) Reset()

func (*TopNAggregationRegistryServiceCreateRequest) String 

func (x *TopNAggregationRegistryServiceCreateRequest) String() string

type TopNAggregationRegistryServiceCreateResponse 

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

func (*TopNAggregationRegistryServiceCreateResponse) Descriptor deprecated 

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

Deprecated: Use TopNAggregationRegistryServiceCreateResponse.ProtoReflect.Descriptor instead.

func (*TopNAggregationRegistryServiceCreateResponse) ProtoMessage 

func (*TopNAggregationRegistryServiceCreateResponse) ProtoMessage()

func (*TopNAggregationRegistryServiceCreateResponse) ProtoReflect 

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

func (*TopNAggregationRegistryServiceCreateResponse) Reset 

func (x *TopNAggregationRegistryServiceCreateResponse) Reset()

func (*TopNAggregationRegistryServiceCreateResponse) String 

func (x *TopNAggregationRegistryServiceCreateResponse) String() string

type TopNAggregationRegistryServiceDeleteRequest 

type TopNAggregationRegistryServiceDeleteRequest struct {
	Metadata *v1.Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

func (*TopNAggregationRegistryServiceDeleteRequest) Descriptor deprecated 

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

Deprecated: Use TopNAggregationRegistryServiceDeleteRequest.ProtoReflect.Descriptor instead.

func (*TopNAggregationRegistryServiceDeleteRequest) GetMetadata 

func (x *TopNAggregationRegistryServiceDeleteRequest) GetMetadata() *v1.Metadata

func (*TopNAggregationRegistryServiceDeleteRequest) ProtoMessage 

func (*TopNAggregationRegistryServiceDeleteRequest) ProtoMessage()

func (*TopNAggregationRegistryServiceDeleteRequest) ProtoReflect 

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

func (*TopNAggregationRegistryServiceDeleteRequest) Reset 

func (x *TopNAggregationRegistryServiceDeleteRequest) Reset()

func (*TopNAggregationRegistryServiceDeleteRequest) String 

func (x *TopNAggregationRegistryServiceDeleteRequest) String() string

type TopNAggregationRegistryServiceDeleteResponse 

type TopNAggregationRegistryServiceDeleteResponse struct {
	Deleted bool `protobuf:"varint,1,opt,name=deleted,proto3" json:"deleted,omitempty"`
	// contains filtered or unexported fields
}

func (*TopNAggregationRegistryServiceDeleteResponse) Descriptor deprecated 

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

Deprecated: Use TopNAggregationRegistryServiceDeleteResponse.ProtoReflect.Descriptor instead.

func (*TopNAggregationRegistryServiceDeleteResponse) GetDeleted 

func (x *TopNAggregationRegistryServiceDeleteResponse) GetDeleted() bool

func (*TopNAggregationRegistryServiceDeleteResponse) ProtoMessage 

func (*TopNAggregationRegistryServiceDeleteResponse) ProtoMessage()

func (*TopNAggregationRegistryServiceDeleteResponse) ProtoReflect 

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

func (*TopNAggregationRegistryServiceDeleteResponse) Reset 

func (x *TopNAggregationRegistryServiceDeleteResponse) Reset()

func (*TopNAggregationRegistryServiceDeleteResponse) String 

func (x *TopNAggregationRegistryServiceDeleteResponse) String() string

type TopNAggregationRegistryServiceGetRequest 

type TopNAggregationRegistryServiceGetRequest struct {
	Metadata *v1.Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

func (*TopNAggregationRegistryServiceGetRequest) Descriptor deprecated 

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

Deprecated: Use TopNAggregationRegistryServiceGetRequest.ProtoReflect.Descriptor instead.

func (*TopNAggregationRegistryServiceGetRequest) GetMetadata 

func (x *TopNAggregationRegistryServiceGetRequest) GetMetadata() *v1.Metadata

func (*TopNAggregationRegistryServiceGetRequest) ProtoMessage 

func (*TopNAggregationRegistryServiceGetRequest) ProtoMessage()

func (*TopNAggregationRegistryServiceGetRequest) ProtoReflect 

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

func (*TopNAggregationRegistryServiceGetRequest) Reset 

func (x *TopNAggregationRegistryServiceGetRequest) Reset()

func (*TopNAggregationRegistryServiceGetRequest) String 

func (x *TopNAggregationRegistryServiceGetRequest) String() string

type TopNAggregationRegistryServiceGetResponse 

type TopNAggregationRegistryServiceGetResponse struct {
	TopNAggregation *TopNAggregation `protobuf:"bytes,1,opt,name=top_n_aggregation,json=topNAggregation,proto3" json:"top_n_aggregation,omitempty"`
	// contains filtered or unexported fields
}

func (*TopNAggregationRegistryServiceGetResponse) Descriptor deprecated 

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

Deprecated: Use TopNAggregationRegistryServiceGetResponse.ProtoReflect.Descriptor instead.

func (*TopNAggregationRegistryServiceGetResponse) GetTopNAggregation 

func (x *TopNAggregationRegistryServiceGetResponse) GetTopNAggregation() *TopNAggregation

func (*TopNAggregationRegistryServiceGetResponse) ProtoMessage 

func (*TopNAggregationRegistryServiceGetResponse) ProtoMessage()

func (*TopNAggregationRegistryServiceGetResponse) ProtoReflect 

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

func (*TopNAggregationRegistryServiceGetResponse) Reset 

func (x *TopNAggregationRegistryServiceGetResponse) Reset()

func (*TopNAggregationRegistryServiceGetResponse) String 

func (x *TopNAggregationRegistryServiceGetResponse) String() string

type TopNAggregationRegistryServiceListRequest 

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

func (*TopNAggregationRegistryServiceListRequest) Descriptor deprecated 

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

Deprecated: Use TopNAggregationRegistryServiceListRequest.ProtoReflect.Descriptor instead.

func (*TopNAggregationRegistryServiceListRequest) GetGroup 

func (x *TopNAggregationRegistryServiceListRequest) GetGroup() string

func (*TopNAggregationRegistryServiceListRequest) ProtoMessage 

func (*TopNAggregationRegistryServiceListRequest) ProtoMessage()

func (*TopNAggregationRegistryServiceListRequest) ProtoReflect 

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

func (*TopNAggregationRegistryServiceListRequest) Reset 

func (x *TopNAggregationRegistryServiceListRequest) Reset()

func (*TopNAggregationRegistryServiceListRequest) String 

func (x *TopNAggregationRegistryServiceListRequest) String() string

type TopNAggregationRegistryServiceListResponse 

type TopNAggregationRegistryServiceListResponse struct {
	TopNAggregation []*TopNAggregation `protobuf:"bytes,1,rep,name=top_n_aggregation,json=topNAggregation,proto3" json:"top_n_aggregation,omitempty"`
	// contains filtered or unexported fields
}

func (*TopNAggregationRegistryServiceListResponse) Descriptor deprecated 

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

Deprecated: Use TopNAggregationRegistryServiceListResponse.ProtoReflect.Descriptor instead.

func (*TopNAggregationRegistryServiceListResponse) GetTopNAggregation 

func (x *TopNAggregationRegistryServiceListResponse) GetTopNAggregation() []*TopNAggregation

func (*TopNAggregationRegistryServiceListResponse) ProtoMessage 

func (*TopNAggregationRegistryServiceListResponse) ProtoMessage()

func (*TopNAggregationRegistryServiceListResponse) ProtoReflect 

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

func (*TopNAggregationRegistryServiceListResponse) Reset 

func (x *TopNAggregationRegistryServiceListResponse) Reset()

func (*TopNAggregationRegistryServiceListResponse) String 

func (x *TopNAggregationRegistryServiceListResponse) String() string

type TopNAggregationRegistryServiceServer 

type TopNAggregationRegistryServiceServer interface {
	Create(context.Context, *TopNAggregationRegistryServiceCreateRequest) (*TopNAggregationRegistryServiceCreateResponse, error)
	Update(context.Context, *TopNAggregationRegistryServiceUpdateRequest) (*TopNAggregationRegistryServiceUpdateResponse, error)
	Delete(context.Context, *TopNAggregationRegistryServiceDeleteRequest) (*TopNAggregationRegistryServiceDeleteResponse, error)
	Get(context.Context, *TopNAggregationRegistryServiceGetRequest) (*TopNAggregationRegistryServiceGetResponse, error)
	List(context.Context, *TopNAggregationRegistryServiceListRequest) (*TopNAggregationRegistryServiceListResponse, error)
	// contains filtered or unexported methods
}

TopNAggregationRegistryServiceServer is the server API for TopNAggregationRegistryService service. All implementations must embed UnimplementedTopNAggregationRegistryServiceServer for forward compatibility

type TopNAggregationRegistryServiceUpdateRequest 

type TopNAggregationRegistryServiceUpdateRequest struct {
	TopNAggregation *TopNAggregation `protobuf:"bytes,1,opt,name=top_n_aggregation,json=topNAggregation,proto3" json:"top_n_aggregation,omitempty"`
	// contains filtered or unexported fields
}

func (*TopNAggregationRegistryServiceUpdateRequest) Descriptor deprecated 

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

Deprecated: Use TopNAggregationRegistryServiceUpdateRequest.ProtoReflect.Descriptor instead.

func (*TopNAggregationRegistryServiceUpdateRequest) GetTopNAggregation 

func (x *TopNAggregationRegistryServiceUpdateRequest) GetTopNAggregation() *TopNAggregation

func (*TopNAggregationRegistryServiceUpdateRequest) ProtoMessage 

func (*TopNAggregationRegistryServiceUpdateRequest) ProtoMessage()

func (*TopNAggregationRegistryServiceUpdateRequest) ProtoReflect 

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

func (*TopNAggregationRegistryServiceUpdateRequest) Reset 

func (x *TopNAggregationRegistryServiceUpdateRequest) Reset()

func (*TopNAggregationRegistryServiceUpdateRequest) String 

func (x *TopNAggregationRegistryServiceUpdateRequest) String() string

type TopNAggregationRegistryServiceUpdateResponse 

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

func (*TopNAggregationRegistryServiceUpdateResponse) Descriptor deprecated 

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

Deprecated: Use TopNAggregationRegistryServiceUpdateResponse.ProtoReflect.Descriptor instead.

func (*TopNAggregationRegistryServiceUpdateResponse) ProtoMessage 

func (*TopNAggregationRegistryServiceUpdateResponse) ProtoMessage()

func (*TopNAggregationRegistryServiceUpdateResponse) ProtoReflect 

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

func (*TopNAggregationRegistryServiceUpdateResponse) Reset 

func (x *TopNAggregationRegistryServiceUpdateResponse) Reset()

func (*TopNAggregationRegistryServiceUpdateResponse) String 

func (x *TopNAggregationRegistryServiceUpdateResponse) String() string

type UnimplementedGroupRegistryServiceServer 

type UnimplementedGroupRegistryServiceServer struct {
}

UnimplementedGroupRegistryServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedGroupRegistryServiceServer) Create 

func (UnimplementedGroupRegistryServiceServer) Create(context.Context, *GroupRegistryServiceCreateRequest) (*GroupRegistryServiceCreateResponse, error)

func (UnimplementedGroupRegistryServiceServer) Delete 

func (UnimplementedGroupRegistryServiceServer) Delete(context.Context, *GroupRegistryServiceDeleteRequest) (*GroupRegistryServiceDeleteResponse, error)

func (UnimplementedGroupRegistryServiceServer) Get 

func (UnimplementedGroupRegistryServiceServer) Get(context.Context, *GroupRegistryServiceGetRequest) (*GroupRegistryServiceGetResponse, error)

func (UnimplementedGroupRegistryServiceServer) List 

func (UnimplementedGroupRegistryServiceServer) List(context.Context, *GroupRegistryServiceListRequest) (*GroupRegistryServiceListResponse, error)

func (UnimplementedGroupRegistryServiceServer) Update 

func (UnimplementedGroupRegistryServiceServer) Update(context.Context, *GroupRegistryServiceUpdateRequest) (*GroupRegistryServiceUpdateResponse, error)

type UnimplementedIndexRuleBindingRegistryServiceServer 

type UnimplementedIndexRuleBindingRegistryServiceServer struct {
}

UnimplementedIndexRuleBindingRegistryServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedIndexRuleBindingRegistryServiceServer) Create 

func (UnimplementedIndexRuleBindingRegistryServiceServer) Create(context.Context, *IndexRuleBindingRegistryServiceCreateRequest) (*IndexRuleBindingRegistryServiceCreateResponse, error)

func (UnimplementedIndexRuleBindingRegistryServiceServer) Delete 

func (UnimplementedIndexRuleBindingRegistryServiceServer) Delete(context.Context, *IndexRuleBindingRegistryServiceDeleteRequest) (*IndexRuleBindingRegistryServiceDeleteResponse, error)

func (UnimplementedIndexRuleBindingRegistryServiceServer) Get 

func (UnimplementedIndexRuleBindingRegistryServiceServer) Get(context.Context, *IndexRuleBindingRegistryServiceGetRequest) (*IndexRuleBindingRegistryServiceGetResponse, error)

func (UnimplementedIndexRuleBindingRegistryServiceServer) List 

func (UnimplementedIndexRuleBindingRegistryServiceServer) List(context.Context, *IndexRuleBindingRegistryServiceListRequest) (*IndexRuleBindingRegistryServiceListResponse, error)

func (UnimplementedIndexRuleBindingRegistryServiceServer) Update 

func (UnimplementedIndexRuleBindingRegistryServiceServer) Update(context.Context, *IndexRuleBindingRegistryServiceUpdateRequest) (*IndexRuleBindingRegistryServiceUpdateResponse, error)

type UnimplementedIndexRuleRegistryServiceServer 

type UnimplementedIndexRuleRegistryServiceServer struct {
}

UnimplementedIndexRuleRegistryServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedIndexRuleRegistryServiceServer) Create 

func (UnimplementedIndexRuleRegistryServiceServer) Create(context.Context, *IndexRuleRegistryServiceCreateRequest) (*IndexRuleRegistryServiceCreateResponse, error)

func (UnimplementedIndexRuleRegistryServiceServer) Delete 

func (UnimplementedIndexRuleRegistryServiceServer) Delete(context.Context, *IndexRuleRegistryServiceDeleteRequest) (*IndexRuleRegistryServiceDeleteResponse, error)

func (UnimplementedIndexRuleRegistryServiceServer) Get 

func (UnimplementedIndexRuleRegistryServiceServer) Get(context.Context, *IndexRuleRegistryServiceGetRequest) (*IndexRuleRegistryServiceGetResponse, error)

func (UnimplementedIndexRuleRegistryServiceServer) List 

func (UnimplementedIndexRuleRegistryServiceServer) List(context.Context, *IndexRuleRegistryServiceListRequest) (*IndexRuleRegistryServiceListResponse, error)

func (UnimplementedIndexRuleRegistryServiceServer) Update 

func (UnimplementedIndexRuleRegistryServiceServer) Update(context.Context, *IndexRuleRegistryServiceUpdateRequest) (*IndexRuleRegistryServiceUpdateResponse, error)

type UnimplementedMeasureRegistryServiceServer 

type UnimplementedMeasureRegistryServiceServer struct {
}

UnimplementedMeasureRegistryServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedMeasureRegistryServiceServer) Create 

func (UnimplementedMeasureRegistryServiceServer) Create(context.Context, *MeasureRegistryServiceCreateRequest) (*MeasureRegistryServiceCreateResponse, error)

func (UnimplementedMeasureRegistryServiceServer) Delete 

func (UnimplementedMeasureRegistryServiceServer) Delete(context.Context, *MeasureRegistryServiceDeleteRequest) (*MeasureRegistryServiceDeleteResponse, error)

func (UnimplementedMeasureRegistryServiceServer) Get 

func (UnimplementedMeasureRegistryServiceServer) Get(context.Context, *MeasureRegistryServiceGetRequest) (*MeasureRegistryServiceGetResponse, error)

func (UnimplementedMeasureRegistryServiceServer) List 

func (UnimplementedMeasureRegistryServiceServer) List(context.Context, *MeasureRegistryServiceListRequest) (*MeasureRegistryServiceListResponse, error)

func (UnimplementedMeasureRegistryServiceServer) Update 

func (UnimplementedMeasureRegistryServiceServer) Update(context.Context, *MeasureRegistryServiceUpdateRequest) (*MeasureRegistryServiceUpdateResponse, error)

type UnimplementedStreamRegistryServiceServer 

type UnimplementedStreamRegistryServiceServer struct {
}

UnimplementedStreamRegistryServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedStreamRegistryServiceServer) Create 

func (UnimplementedStreamRegistryServiceServer) Create(context.Context, *StreamRegistryServiceCreateRequest) (*StreamRegistryServiceCreateResponse, error)

func (UnimplementedStreamRegistryServiceServer) Delete 

func (UnimplementedStreamRegistryServiceServer) Delete(context.Context, *StreamRegistryServiceDeleteRequest) (*StreamRegistryServiceDeleteResponse, error)

func (UnimplementedStreamRegistryServiceServer) Get 

func (UnimplementedStreamRegistryServiceServer) Get(context.Context, *StreamRegistryServiceGetRequest) (*StreamRegistryServiceGetResponse, error)

func (UnimplementedStreamRegistryServiceServer) List 

func (UnimplementedStreamRegistryServiceServer) List(context.Context, *StreamRegistryServiceListRequest) (*StreamRegistryServiceListResponse, error)

func (UnimplementedStreamRegistryServiceServer) Update 

func (UnimplementedStreamRegistryServiceServer) Update(context.Context, *StreamRegistryServiceUpdateRequest) (*StreamRegistryServiceUpdateResponse, error)

type UnimplementedTopNAggregationRegistryServiceServer 

type UnimplementedTopNAggregationRegistryServiceServer struct {
}

UnimplementedTopNAggregationRegistryServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedTopNAggregationRegistryServiceServer) Create 

func (UnimplementedTopNAggregationRegistryServiceServer) Create(context.Context, *TopNAggregationRegistryServiceCreateRequest) (*TopNAggregationRegistryServiceCreateResponse, error)

func (UnimplementedTopNAggregationRegistryServiceServer) Delete 

func (UnimplementedTopNAggregationRegistryServiceServer) Delete(context.Context, *TopNAggregationRegistryServiceDeleteRequest) (*TopNAggregationRegistryServiceDeleteResponse, error)

func (UnimplementedTopNAggregationRegistryServiceServer) Get 

func (UnimplementedTopNAggregationRegistryServiceServer) Get(context.Context, *TopNAggregationRegistryServiceGetRequest) (*TopNAggregationRegistryServiceGetResponse, error)

func (UnimplementedTopNAggregationRegistryServiceServer) List 

func (UnimplementedTopNAggregationRegistryServiceServer) List(context.Context, *TopNAggregationRegistryServiceListRequest) (*TopNAggregationRegistryServiceListResponse, error)

func (UnimplementedTopNAggregationRegistryServiceServer) Update 

func (UnimplementedTopNAggregationRegistryServiceServer) Update(context.Context, *TopNAggregationRegistryServiceUpdateRequest) (*TopNAggregationRegistryServiceUpdateResponse, error)

type UnsafeGroupRegistryServiceServer 

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

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

type UnsafeIndexRuleBindingRegistryServiceServer 

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

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

type UnsafeIndexRuleRegistryServiceServer 

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

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

type UnsafeMeasureRegistryServiceServer 

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

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

type UnsafeStreamRegistryServiceServer 

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

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

type UnsafeTopNAggregationRegistryServiceServer 

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

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

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.