Versions in this module Expand all Collapse all v0 v0.1.1 Jan 23, 2021 v0.1.0 Jan 19, 2021 Changes in this version + var Comparator_name = map[int32]string + var Comparator_value = map[string]int32 + var File_query_proto protoreflect.FileDescriptor + var File_result_proto protoreflect.FileDescriptor + var File_service_proto protoreflect.FileDescriptor + var GroupOperator_name = map[int32]string + var GroupOperator_value = map[string]int32 + func RegisterDataSourceServer(s *grpc.Server, srv DataSourceServer) + type Comparator int32 + const Comparator_EQUAL + const Comparator_FUZZY_EQUAL + const Comparator_GREATER_THAN + const Comparator_GREATER_THAN_OR_EQUAL + const Comparator_IS_NULL + const Comparator_LESS_THAN + const Comparator_LESS_THAN_OR_EQUAL + const Comparator_UNKNOWN_COMPARATOR + func (Comparator) Descriptor() protoreflect.EnumDescriptor + func (Comparator) EnumDescriptor() ([]byte, []int) + func (Comparator) Type() protoreflect.EnumType + func (x Comparator) Enum() *Comparator + func (x Comparator) Number() protoreflect.EnumNumber + func (x Comparator) String() string + type DataSourceClient interface + Execute func(ctx context.Context, in *Query, opts ...grpc.CallOption) (*Result, error) + ExecuteBatch func(ctx context.Context, opts ...grpc.CallOption) (DataSource_ExecuteBatchClient, error) + func NewDataSourceClient(cc grpc.ClientConnInterface) DataSourceClient + type DataSourceServer interface + Execute func(context.Context, *Query) (*Result, error) + ExecuteBatch func(DataSource_ExecuteBatchServer) error + type DataSource_ExecuteBatchClient interface + Recv func() (*StreamResult, error) + Send func(*Query) error + type DataSource_ExecuteBatchServer interface + Recv func() (*Query, error) + Send func(*StreamResult) error + type DomainJoins struct + func (*DomainJoins) Descriptor() ([]byte, []int) + func (*DomainJoins) ProtoMessage() + func (x *DomainJoins) ProtoReflect() protoreflect.Message + func (x *DomainJoins) Reset() + func (x *DomainJoins) String() string + type GroupOperator int32 + const GroupOperator_AND + const GroupOperator_OR + const GroupOperator_UNKNOWN_GROUPOPERATOR + const GroupOperator_XOR + func (GroupOperator) Descriptor() protoreflect.EnumDescriptor + func (GroupOperator) EnumDescriptor() ([]byte, []int) + func (GroupOperator) Type() protoreflect.EnumType + func (x GroupOperator) Enum() *GroupOperator + func (x GroupOperator) Number() protoreflect.EnumNumber + func (x GroupOperator) String() string + type Ordering struct + Descending bool + Priority uint32 + func (*Ordering) Descriptor() ([]byte, []int) + func (*Ordering) ProtoMessage() + func (x *Ordering) GetDescending() bool + func (x *Ordering) GetPriority() uint32 + func (x *Ordering) ProtoReflect() protoreflect.Message + func (x *Ordering) Reset() + func (x *Ordering) String() string + type Paging struct + Limit uint64 + Offset uint64 + func (*Paging) Descriptor() ([]byte, []int) + func (*Paging) ProtoMessage() + func (x *Paging) GetLimit() uint64 + func (x *Paging) GetOffset() uint64 + func (x *Paging) ProtoReflect() protoreflect.Message + func (x *Paging) Reset() + func (x *Paging) String() string + type Query struct + DomainSpace isQuery_DomainSpace + Id string + Paging *Paging + Where *WhereGroup + func (*Query) Descriptor() ([]byte, []int) + func (*Query) ProtoMessage() + func (m *Query) GetDomainSpace() isQuery_DomainSpace + func (x *Query) GetDomain() string + func (x *Query) GetId() string + func (x *Query) GetPaging() *Paging + func (x *Query) GetWhere() *WhereGroup + func (x *Query) ProtoReflect() protoreflect.Message + func (x *Query) Reset() + func (x *Query) String() string + type Query_Domain struct + Domain string + type Result struct + Data []*_struct.Struct + func (*Result) Descriptor() ([]byte, []int) + func (*Result) ProtoMessage() + func (x *Result) GetData() []*_struct.Struct + func (x *Result) ProtoReflect() protoreflect.Message + func (x *Result) Reset() + func (x *Result) String() string + type StreamResult struct + Data []*_struct.Struct + Id string + func (*StreamResult) Descriptor() ([]byte, []int) + func (*StreamResult) ProtoMessage() + func (x *StreamResult) GetData() []*_struct.Struct + func (x *StreamResult) GetId() string + func (x *StreamResult) ProtoReflect() protoreflect.Message + func (x *StreamResult) Reset() + func (x *StreamResult) String() string + type UnimplementedDataSourceServer struct + func (UnimplementedDataSourceServer) Execute(context.Context, *Query) (*Result, error) + func (UnimplementedDataSourceServer) ExecuteBatch(DataSource_ExecuteBatchServer) error + type UnsafeDataSourceServer interface + type WhereField struct + Comparator Comparator + DomainName string + FieldName string + NegateComparator bool + Ordering *Ordering + Value isWhereField_Value + func (*WhereField) Descriptor() ([]byte, []int) + func (*WhereField) ProtoMessage() + func (m *WhereField) GetValue() isWhereField_Value + func (x *WhereField) GetBoolValue() bool + func (x *WhereField) GetBytesValue() []byte + func (x *WhereField) GetComparator() Comparator + func (x *WhereField) GetDomainName() string + func (x *WhereField) GetDoubleValue() float64 + func (x *WhereField) GetFieldName() string + func (x *WhereField) GetInt64Value() int64 + func (x *WhereField) GetNegateComparator() bool + func (x *WhereField) GetOrdering() *Ordering + func (x *WhereField) GetStringValue() string + func (x *WhereField) GetTimeValue() *timestamp.Timestamp + func (x *WhereField) GetUint64Value() uint64 + func (x *WhereField) ProtoReflect() protoreflect.Message + func (x *WhereField) Reset() + func (x *WhereField) String() string + type WhereField_BoolValue struct + BoolValue bool + type WhereField_BytesValue struct + BytesValue []byte + type WhereField_DoubleValue struct + DoubleValue float64 + type WhereField_Int64Value struct + Int64Value int64 + type WhereField_StringValue struct + StringValue string + type WhereField_TimeValue struct + TimeValue *timestamp.Timestamp + type WhereField_Uint64Value struct + Uint64Value uint64 + type WhereGroup struct + Elements []*WhereGroupElement + NegateOperator bool + Operator GroupOperator + func (*WhereGroup) Descriptor() ([]byte, []int) + func (*WhereGroup) ProtoMessage() + func (x *WhereGroup) GetElements() []*WhereGroupElement + func (x *WhereGroup) GetNegateOperator() bool + func (x *WhereGroup) GetOperator() GroupOperator + func (x *WhereGroup) ProtoReflect() protoreflect.Message + func (x *WhereGroup) Reset() + func (x *WhereGroup) String() string + type WhereGroupElement struct + Element isWhereGroupElement_Element + func (*WhereGroupElement) Descriptor() ([]byte, []int) + func (*WhereGroupElement) ProtoMessage() + func (m *WhereGroupElement) GetElement() isWhereGroupElement_Element + func (x *WhereGroupElement) GetField() *WhereField + func (x *WhereGroupElement) GetGroup() *WhereGroup + func (x *WhereGroupElement) ProtoReflect() protoreflect.Message + func (x *WhereGroupElement) Reset() + func (x *WhereGroupElement) String() string + type WhereGroupElement_Field struct + Field *WhereField + type WhereGroupElement_Group struct + Group *WhereGroup
Go to main page