queryv1alpha1

package
v0.4.0 Latest Latest
Warning

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

 Go to latest Published: Apr 7, 2023 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Overview

Code generated by protoc-gen-go-pulsar. DO NOT EDIT.

Index

Constants

View Source 
const (
	Query_Get_FullMethodName  = "/cosmos.orm.query.v1alpha1.Query/Get"
	Query_List_FullMethodName = "/cosmos.orm.query.v1alpha1.Query/List"
)

Variables

View Source 
var File_cosmos_orm_query_v1alpha1_query_proto protoreflect.FileDescriptor
View Source 
var Query_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "cosmos.orm.query.v1alpha1.Query",
	HandlerType: (*QueryServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Get",
			Handler:    _Query_Get_Handler,
		},
		{
			MethodName: "List",
			Handler:    _Query_List_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "cosmos/orm/query/v1alpha1/query.proto",
}

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

Functions

func RegisterQueryServer 

func RegisterQueryServer(s grpc.ServiceRegistrar, srv QueryServer)

Types

type GetRequest 

type GetRequest struct {

	// message_name is the fully-qualified message name of the ORM table being queried.
	MessageName string `protobuf:"bytes,1,opt,name=message_name,json=messageName,proto3" json:"message_name,omitempty"`
	// index is the index fields expression used in orm definitions. If it
	// is empty, the table's primary key is assumed. If it is non-empty, it must
	// refer to an unique index.
	Index string `protobuf:"bytes,2,opt,name=index,proto3" json:"index,omitempty"`
	// values are the values of the fields corresponding to the requested index.
	// There must be as many values provided as there are fields in the index and
	// these values must correspond to the index field types.
	Values []*IndexValue `protobuf:"bytes,3,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

GetRequest is the Query/Get request type.

func (*GetRequest) Descriptor deprecated 

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

Deprecated: Use GetRequest.ProtoReflect.Descriptor instead.

func (*GetRequest) GetIndex 

func (x *GetRequest) GetIndex() string

func (*GetRequest) GetMessageName 

func (x *GetRequest) GetMessageName() string

func (*GetRequest) GetValues 

func (x *GetRequest) GetValues() []*IndexValue

func (*GetRequest) ProtoMessage 

func (*GetRequest) ProtoMessage()

func (*GetRequest) ProtoReflect 

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

func (*GetRequest) Reset 

func (x *GetRequest) Reset()

func (*GetRequest) String 

func (x *GetRequest) String() string

type GetResponse 

type GetResponse struct {

	// result is the result of the get query. If no value is found, the gRPC
	// status code NOT_FOUND will be returned.
	Result *anypb.Any `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

GetResponse is the Query/Get response type.

func (*GetResponse) Descriptor deprecated 

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

Deprecated: Use GetResponse.ProtoReflect.Descriptor instead.

func (*GetResponse) GetResult 

func (x *GetResponse) GetResult() *anypb.Any

func (*GetResponse) ProtoMessage 

func (*GetResponse) ProtoMessage()

func (*GetResponse) ProtoReflect 

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

func (*GetResponse) Reset 

func (x *GetResponse) Reset()

func (*GetResponse) String 

func (x *GetResponse) String() string

type IndexValue 

type IndexValue struct {

	// value specifies the index value
	//
	// Types that are assignable to Value:
	//
	//	*IndexValue_Uint
	//	*IndexValue_Int
	//	*IndexValue_Str
	//	*IndexValue_Bytes
	//	*IndexValue_Enum
	//	*IndexValue_Bool
	//	*IndexValue_Timestamp
	//	*IndexValue_Duration
	Value isIndexValue_Value `protobuf_oneof:"value"`
	// contains filtered or unexported fields
}

IndexValue represents the value of a field in an ORM index expression.

func (*IndexValue) Descriptor deprecated 

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

Deprecated: Use IndexValue.ProtoReflect.Descriptor instead.

func (*IndexValue) GetBool 

func (x *IndexValue) GetBool() bool

func (*IndexValue) GetBytes 

func (x *IndexValue) GetBytes() []byte

func (*IndexValue) GetDuration 

func (x *IndexValue) GetDuration() *durationpb.Duration

func (*IndexValue) GetEnum 

func (x *IndexValue) GetEnum() string

func (*IndexValue) GetInt 

func (x *IndexValue) GetInt() int64

func (*IndexValue) GetStr 

func (x *IndexValue) GetStr() string

func (*IndexValue) GetTimestamp 

func (x *IndexValue) GetTimestamp() *timestamppb.Timestamp

func (*IndexValue) GetUint 

func (x *IndexValue) GetUint() uint64

func (*IndexValue) GetValue 

func (x *IndexValue) GetValue() isIndexValue_Value

func (*IndexValue) ProtoMessage 

func (*IndexValue) ProtoMessage()

func (*IndexValue) ProtoReflect 

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

func (*IndexValue) Reset 

func (x *IndexValue) Reset()

func (*IndexValue) String 

func (x *IndexValue) String() string

type IndexValue_Bool 

type IndexValue_Bool struct {
	// bool specifies a value for a bool index field.
	Bool bool `protobuf:"varint,6,opt,name=bool,proto3,oneof"`
}

type IndexValue_Bytes 

type IndexValue_Bytes struct {
	// bytes specifies a value for a bytes index field.
	Bytes []byte `protobuf:"bytes,4,opt,name=bytes,proto3,oneof"`
}

type IndexValue_Duration 

type IndexValue_Duration struct {
	// duration specifies a value for a duration index field.
	Duration *durationpb.Duration `protobuf:"bytes,8,opt,name=duration,proto3,oneof"`
}

type IndexValue_Enum 

type IndexValue_Enum struct {
	// enum specifies a value for an enum index field.
	Enum string `protobuf:"bytes,5,opt,name=enum,proto3,oneof"`
}

type IndexValue_Int 

type IndexValue_Int struct {
	// int64 specifies a value for an int32, sfixed32, int64, or sfixed64
	// index field.
	Int int64 `protobuf:"varint,2,opt,name=int,proto3,oneof"`
}

type IndexValue_Str 

type IndexValue_Str struct {
	// str specifies a value for a string index field.
	Str string `protobuf:"bytes,3,opt,name=str,proto3,oneof"`
}

type IndexValue_Timestamp 

type IndexValue_Timestamp struct {
	// timestamp specifies a value for a timestamp index field.
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=timestamp,proto3,oneof"`
}

type IndexValue_Uint 

type IndexValue_Uint struct {
	// uint specifies a value for an uint32, fixed32, uint64, or fixed64
	// index field.
	Uint uint64 `protobuf:"varint,1,opt,name=uint,proto3,oneof"`
}

type ListRequest 

type ListRequest struct {

	// message_name is the fully-qualified message name of the ORM table being queried.
	MessageName string `protobuf:"bytes,1,opt,name=message_name,json=messageName,proto3" json:"message_name,omitempty"`
	// index is the index fields expression used in orm definitions. If it
	// is empty, the table's primary key is assumed.
	Index string `protobuf:"bytes,2,opt,name=index,proto3" json:"index,omitempty"`
	// query is the query expression corresponding to the provided index. If
	// neither prefix nor range is specified, the query will list all the fields
	// in the index.
	//
	// Types that are assignable to Query:
	//
	//	*ListRequest_Prefix_
	//	*ListRequest_Range_
	Query isListRequest_Query `protobuf_oneof:"query"`
	// pagination is the pagination request.
	Pagination *v1beta1.PageRequest `protobuf:"bytes,5,opt,name=pagination,proto3" json:"pagination,omitempty"`
	// contains filtered or unexported fields
}

ListRequest is the Query/List request type.

func (*ListRequest) Descriptor deprecated 

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

Deprecated: Use ListRequest.ProtoReflect.Descriptor instead.

func (*ListRequest) GetIndex 

func (x *ListRequest) GetIndex() string

func (*ListRequest) GetMessageName 

func (x *ListRequest) GetMessageName() string

func (*ListRequest) GetPagination 

func (x *ListRequest) GetPagination() *v1beta1.PageRequest

func (*ListRequest) GetPrefix 

func (x *ListRequest) GetPrefix() *ListRequest_Prefix

func (*ListRequest) GetQuery 

func (x *ListRequest) GetQuery() isListRequest_Query

func (*ListRequest) GetRange_ 

func (x *ListRequest) GetRange_() *ListRequest_Range

func (*ListRequest) ProtoMessage 

func (*ListRequest) ProtoMessage()

func (*ListRequest) ProtoReflect 

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

func (*ListRequest) Reset 

func (x *ListRequest) Reset()

func (*ListRequest) String 

func (x *ListRequest) String() string

type ListRequest_Prefix 

type ListRequest_Prefix struct {

	// values specifies the index values for the prefix query.
	// It is valid to special a partial prefix with fewer values than
	// the number of fields in the index.
	Values []*IndexValue `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

Prefix specifies the arguments to a prefix query.

func (*ListRequest_Prefix) Descriptor deprecated 

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

Deprecated: Use ListRequest_Prefix.ProtoReflect.Descriptor instead.

func (*ListRequest_Prefix) GetValues 

func (x *ListRequest_Prefix) GetValues() []*IndexValue

func (*ListRequest_Prefix) ProtoMessage 

func (*ListRequest_Prefix) ProtoMessage()

func (*ListRequest_Prefix) ProtoReflect 

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

func (*ListRequest_Prefix) Reset 

func (x *ListRequest_Prefix) Reset()

func (*ListRequest_Prefix) String 

func (x *ListRequest_Prefix) String() string

type ListRequest_Prefix_ 

type ListRequest_Prefix_ struct {
	// prefix defines a prefix query.
	Prefix *ListRequest_Prefix `protobuf:"bytes,3,opt,name=prefix,proto3,oneof"`
}

type ListRequest_Range 

type ListRequest_Range struct {

	// start specifies the starting index values for the range query.
	// It is valid to provide fewer values than the number of fields in the
	// index.
	Start []*IndexValue `protobuf:"bytes,1,rep,name=start,proto3" json:"start,omitempty"`
	// end specifies the inclusive ending index values for the range query.
	// It is valid to provide fewer values than the number of fields in the
	// index.
	End []*IndexValue `protobuf:"bytes,2,rep,name=end,proto3" json:"end,omitempty"`
	// contains filtered or unexported fields
}

Range specifies the arguments to a range query.

func (*ListRequest_Range) Descriptor deprecated 

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

Deprecated: Use ListRequest_Range.ProtoReflect.Descriptor instead.

func (*ListRequest_Range) GetEnd 

func (x *ListRequest_Range) GetEnd() []*IndexValue

func (*ListRequest_Range) GetStart 

func (x *ListRequest_Range) GetStart() []*IndexValue

func (*ListRequest_Range) ProtoMessage 

func (*ListRequest_Range) ProtoMessage()

func (*ListRequest_Range) ProtoReflect 

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

func (*ListRequest_Range) Reset 

func (x *ListRequest_Range) Reset()

func (*ListRequest_Range) String 

func (x *ListRequest_Range) String() string

type ListRequest_Range_ 

type ListRequest_Range_ struct {
	// range defines a range query.
	Range_ *ListRequest_Range `protobuf:"bytes,4,opt,name=range,proto3,oneof"`
}

type ListResponse 

type ListResponse struct {

	// results are the results of the query.
	Results []*anypb.Any `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
	// pagination is the pagination response.
	Pagination *v1beta1.PageResponse `protobuf:"bytes,5,opt,name=pagination,proto3" json:"pagination,omitempty"`
	// contains filtered or unexported fields
}

ListResponse is the Query/List response type.

func (*ListResponse) Descriptor deprecated 

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

Deprecated: Use ListResponse.ProtoReflect.Descriptor instead.

func (*ListResponse) GetPagination 

func (x *ListResponse) GetPagination() *v1beta1.PageResponse

func (*ListResponse) GetResults 

func (x *ListResponse) GetResults() []*anypb.Any

func (*ListResponse) ProtoMessage 

func (*ListResponse) ProtoMessage()

func (*ListResponse) ProtoReflect 

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

func (*ListResponse) Reset 

func (x *ListResponse) Reset()

func (*ListResponse) String 

func (x *ListResponse) String() string

type QueryClient 

type QueryClient interface {
	// Get queries an ORM table against an unique index.
	Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error)
	// List queries an ORM table against an index.
	List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListResponse, error)
}

QueryClient is the client API for Query 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 NewQueryClient 

func NewQueryClient(cc grpc.ClientConnInterface) QueryClient

type QueryServer 

type QueryServer interface {
	// Get queries an ORM table against an unique index.
	Get(context.Context, *GetRequest) (*GetResponse, error)
	// List queries an ORM table against an index.
	List(context.Context, *ListRequest) (*ListResponse, error)
	// contains filtered or unexported methods
}

QueryServer is the server API for Query service. All implementations must embed UnimplementedQueryServer for forward compatibility

type UnimplementedQueryServer 

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer must be embedded to have forward compatible implementations.

func (UnimplementedQueryServer) Get 

func (UnimplementedQueryServer) Get(context.Context, *GetRequest) (*GetResponse, error)

func (UnimplementedQueryServer) List 

func (UnimplementedQueryServer) List(context.Context, *ListRequest) (*ListResponse, error)

type UnsafeQueryServer 

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

UnsafeQueryServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to QueryServer 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.