subscriptions

Sep 23, 2024

Changes in this version

type ServiceClient

+ func NewClientConnPool(connPool *grpcpool.Pool) ServiceClient

Jul 1, 2024

Changes in this version

+ var Order_name = map[int32]string

+ var Order_value = map[string]int32

+ var Sort_name = map[int32]string

+ var Sort_value = map[string]int32

type CreateRequest

+ Public bool

+ func (x *CreateRequest) GetPublic() bool

+ type Cursor struct

+ Followers int64

+ Id string

+ func (*Cursor) Descriptor() ([]byte, []int)

+ func (*Cursor) ProtoMessage()

+ func (x *Cursor) GetFollowers() int64

+ func (x *Cursor) GetId() string

+ func (x *Cursor) ProtoReflect() protoreflect.Message

+ func (x *Cursor) Reset()

+ func (x *Cursor) String() string

+ type Order int32

+ const Order_ASC

+ const Order_DESC

+ func (Order) Descriptor() protoreflect.EnumDescriptor

+ func (Order) EnumDescriptor() ([]byte, []int)

+ func (Order) Type() protoreflect.EnumType

+ func (x Order) Enum() *Order

+ func (x Order) Number() protoreflect.EnumNumber

+ func (x Order) String() string

type ReadResponse

+ Created *timestamppb.Timestamp

+ Followers int64

+ Public bool

+ Updated *timestamppb.Timestamp

+ func (x *ReadResponse) GetCreated() *timestamppb.Timestamp

+ func (x *ReadResponse) GetFollowers() int64

+ func (x *ReadResponse) GetPublic() bool

+ func (x *ReadResponse) GetUpdated() *timestamppb.Timestamp

type SearchOwnRequest

+ Order Order

+ Pattern string

+ func (x *SearchOwnRequest) GetOrder() Order

+ func (x *SearchOwnRequest) GetPattern() string

+ type SearchRequest struct

+ Cursor *Cursor

+ Limit uint32

+ Order Order

+ Pattern string

+ Sort Sort

+ func (*SearchRequest) Descriptor() ([]byte, []int)

+ func (*SearchRequest) ProtoMessage()

+ func (x *SearchRequest) GetCursor() *Cursor

+ func (x *SearchRequest) GetLimit() uint32

+ func (x *SearchRequest) GetOrder() Order

+ func (x *SearchRequest) GetPattern() string

+ func (x *SearchRequest) GetSort() Sort

+ func (x *SearchRequest) ProtoReflect() protoreflect.Message

+ func (x *SearchRequest) Reset()

+ func (x *SearchRequest) String() string

+ type SearchResponse struct

+ Ids []string

+ func (*SearchResponse) Descriptor() ([]byte, []int)

+ func (*SearchResponse) ProtoMessage()

+ func (x *SearchResponse) GetIds() []string

+ func (x *SearchResponse) ProtoReflect() protoreflect.Message

+ func (x *SearchResponse) Reset()

+ func (x *SearchResponse) String() string

type Service

+ Search func(ctx context.Context, userId string, q subscription.Query, ...) (ids []string, err error)

type ServiceClient

+ Search func(ctx context.Context, in *SearchRequest, opts ...grpc.CallOption) (*SearchResponse, error)

type ServiceServer

+ Search func(context.Context, *SearchRequest) (*SearchResponse, error)

+ type Sort int32

+ const Sort_FOLLOWERS

+ const Sort_ID

+ func (Sort) Descriptor() protoreflect.EnumDescriptor

+ func (Sort) EnumDescriptor() ([]byte, []int)

+ func (Sort) Type() protoreflect.EnumType

+ func (x Sort) Enum() *Sort

+ func (x Sort) Number() protoreflect.EnumNumber

+ func (x Sort) String() string

type UnimplementedServiceServer

+ func (*UnimplementedServiceServer) Search(context.Context, *SearchRequest) (*SearchResponse, error)

type UpdateRequest

+ Public bool

+ func (x *UpdateRequest) GetPublic() bool

Dec 28, 2023

Changes in this version

+ var ErrUnavailable = errors.New("unavailable")

Nov 3, 2023

Changes in this version

type UpdateRequest

+ Cond *Condition

+ func (x *UpdateRequest) GetCond() *Condition

Oct 4, 2023

Changes in this version

type CreateRequest

+ Expires *timestamppb.Timestamp

+ func (x *CreateRequest) GetExpires() *timestamppb.Timestamp

type ReadResponse

+ Expires *timestamppb.Timestamp

+ func (x *ReadResponse) GetExpires() *timestamppb.Timestamp

type UpdateRequest

+ Expires *timestamppb.Timestamp

+ func (x *UpdateRequest) GetExpires() *timestamppb.Timestamp

Aug 13, 2023

Changes in this version

+ var Operation_name = map[int32]string

+ var Operation_value = map[string]int32

type Condition

+ func (x *Condition) GetNc() *NumberCondition

+ type Condition_Nc struct

+ Nc *NumberCondition

+ type NumberCondition struct

+ Id string

+ Key string

+ Op Operation

+ Val float64

+ func (*NumberCondition) Descriptor() ([]byte, []int)

+ func (*NumberCondition) ProtoMessage()

+ func (x *NumberCondition) GetId() string

+ func (x *NumberCondition) GetKey() string

+ func (x *NumberCondition) GetOp() Operation

+ func (x *NumberCondition) GetVal() float64

+ func (x *NumberCondition) ProtoReflect() protoreflect.Message

+ func (x *NumberCondition) Reset()

+ func (x *NumberCondition) String() string

+ type Operation int32

+ const Operation_Eq

+ const Operation_Gt

+ const Operation_Gte

+ const Operation_Lt

+ const Operation_Lte

+ const Operation_Undefined

+ func (Operation) Descriptor() protoreflect.EnumDescriptor

+ func (Operation) EnumDescriptor() ([]byte, []int)

+ func (Operation) Type() protoreflect.EnumType

+ func (x Operation) Enum() *Operation

+ func (x Operation) Number() protoreflect.EnumNumber

+ func (x Operation) String() string

Jul 18, 2023

Changes in this version

+ type Condition struct

+ Cond isCondition_Cond

+ Not bool

+ func (*Condition) Descriptor() ([]byte, []int)

+ func (*Condition) ProtoMessage()

+ func (m *Condition) GetCond() isCondition_Cond

+ func (x *Condition) GetGc() *GroupCondition

+ func (x *Condition) GetNot() bool

+ func (x *Condition) GetTc() *TextCondition

+ func (x *Condition) ProtoReflect() protoreflect.Message

+ func (x *Condition) Reset()

+ func (x *Condition) String() string

+ type Condition_Gc struct

+ Gc *GroupCondition

+ type Condition_Tc struct

+ Tc *TextCondition

+ type GroupCondition struct

+ Group []*Condition

+ Logic GroupLogic

+ func (*GroupCondition) Descriptor() ([]byte, []int)

+ func (*GroupCondition) ProtoMessage()

+ func (x *GroupCondition) GetGroup() []*Condition

+ func (x *GroupCondition) GetLogic() GroupLogic

+ func (x *GroupCondition) ProtoReflect() protoreflect.Message

+ func (x *GroupCondition) Reset()

+ func (x *GroupCondition) String() string

+ type TextCondition struct

+ Exact bool

+ Id string

+ Key string

+ Term string

+ func (*TextCondition) Descriptor() ([]byte, []int)

+ func (*TextCondition) ProtoMessage()

+ func (x *TextCondition) GetExact() bool

+ func (x *TextCondition) GetId() string

+ func (x *TextCondition) GetKey() string

+ func (x *TextCondition) GetTerm() string

+ func (x *TextCondition) ProtoReflect() protoreflect.Message

+ func (x *TextCondition) Reset()

+ func (x *TextCondition) String() string

Jul 2, 2023

Changes in this version

type TextConditionInput

+ Exact bool

+ func (x *TextConditionInput) GetExact() bool

type TextConditionOutput

+ Exact bool

+ func (x *TextConditionOutput) GetExact() bool

Jun 30, 2023

Changes in this version

type ConditionInput

+ func (x *ConditionInput) GetTc() *TextConditionInput

+ type ConditionInput_Tc struct

+ Tc *TextConditionInput

type ConditionOutput

+ func (x *ConditionOutput) GetTc() *TextConditionOutput

+ type ConditionOutput_Tc struct

+ Tc *TextConditionOutput

type CreateRequest

+ Description string

+ Enabled bool

+ func (x *CreateRequest) GetDescription() string

+ func (x *CreateRequest) GetEnabled() bool

+ type DeleteResponse struct

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

+ func (*DeleteResponse) ProtoMessage()

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

+ func (x *DeleteResponse) Reset()

+ func (x *DeleteResponse) String() string

type ReadResponse

+ Description string

+ Enabled bool

+ func (x *ReadResponse) GetDescription() string

+ func (x *ReadResponse) GetEnabled() bool

type Service

+ Update func(ctx context.Context, userId, subId string, subData subscription.Data) (err error)

type ServiceClient

+ Update func(ctx context.Context, in *UpdateRequest, opts ...grpc.CallOption) (*UpdateResponse, error)

type ServiceServer

+ Update func(context.Context, *UpdateRequest) (*UpdateResponse, error)

+ type TextConditionInput struct

+ Key string

+ Term string

+ func (*TextConditionInput) Descriptor() ([]byte, []int)

+ func (*TextConditionInput) ProtoMessage()

+ func (x *TextConditionInput) GetKey() string

+ func (x *TextConditionInput) GetTerm() string

+ func (x *TextConditionInput) ProtoReflect() protoreflect.Message

+ func (x *TextConditionInput) Reset()

+ func (x *TextConditionInput) String() string

+ type TextConditionOutput struct

+ Id string

+ Key string

+ Term string

+ func (*TextConditionOutput) Descriptor() ([]byte, []int)

+ func (*TextConditionOutput) ProtoMessage()

+ func (x *TextConditionOutput) GetId() string

+ func (x *TextConditionOutput) GetKey() string

+ func (x *TextConditionOutput) GetTerm() string

+ func (x *TextConditionOutput) ProtoReflect() protoreflect.Message

+ func (x *TextConditionOutput) Reset()

+ func (x *TextConditionOutput) String() string

type UnimplementedServiceServer

+ func (*UnimplementedServiceServer) Update(context.Context, *UpdateRequest) (*UpdateResponse, error)

+ type UpdateRequest struct

+ Description string

+ Enabled bool

+ Id string

+ func (*UpdateRequest) Descriptor() ([]byte, []int)

+ func (*UpdateRequest) ProtoMessage()

+ func (x *UpdateRequest) GetDescription() string

+ func (x *UpdateRequest) GetEnabled() bool

+ func (x *UpdateRequest) GetId() string

+ func (x *UpdateRequest) ProtoReflect() protoreflect.Message

+ func (x *UpdateRequest) Reset()

+ func (x *UpdateRequest) String() string

+ type UpdateResponse struct

+ func (*UpdateResponse) Descriptor() ([]byte, []int)

+ func (*UpdateResponse) ProtoMessage()

+ func (x *UpdateResponse) ProtoReflect() protoreflect.Message

+ func (x *UpdateResponse) Reset()

+ func (x *UpdateResponse) String() string

May 23, 2023

Changes in this version

+ var File_api_grpc_subscriptions_service_proto protoreflect.FileDescriptor

+ var GroupLogic_name = map[int32]string

+ var GroupLogic_value = map[string]int32

+ func RegisterServiceServer(s *grpc.Server, srv ServiceServer)

+ type ConditionInput struct

+ Cond isConditionInput_Cond

+ Not bool

+ func (*ConditionInput) Descriptor() ([]byte, []int)

+ func (*ConditionInput) ProtoMessage()

+ func (m *ConditionInput) GetCond() isConditionInput_Cond

+ func (x *ConditionInput) GetGc() *GroupConditionInput

+ func (x *ConditionInput) GetKtc() *KiwiTreeConditionInput

+ func (x *ConditionInput) GetNot() bool

+ func (x *ConditionInput) ProtoReflect() protoreflect.Message

+ func (x *ConditionInput) Reset()

+ func (x *ConditionInput) String() string

+ type ConditionInput_Gc struct

+ Gc *GroupConditionInput

+ type ConditionInput_Ktc struct

+ Ktc *KiwiTreeConditionInput

+ type ConditionOutput struct

+ Cond isConditionOutput_Cond

+ Not bool

+ func (*ConditionOutput) Descriptor() ([]byte, []int)

+ func (*ConditionOutput) ProtoMessage()

+ func (m *ConditionOutput) GetCond() isConditionOutput_Cond

+ func (x *ConditionOutput) GetGc() *GroupConditionOutput

+ func (x *ConditionOutput) GetKc() *KiwiConditionOutput

+ func (x *ConditionOutput) GetNot() bool

+ func (x *ConditionOutput) ProtoReflect() protoreflect.Message

+ func (x *ConditionOutput) Reset()

+ func (x *ConditionOutput) String() string

+ type ConditionOutput_Gc struct

+ Gc *GroupConditionOutput

+ type ConditionOutput_Kc struct

+ Kc *KiwiConditionOutput

+ type CreateRequest struct

+ Cond *ConditionInput

+ Md *Metadata

+ func (*CreateRequest) Descriptor() ([]byte, []int)

+ func (*CreateRequest) ProtoMessage()

+ func (x *CreateRequest) GetCond() *ConditionInput

+ func (x *CreateRequest) GetMd() *Metadata

+ func (x *CreateRequest) ProtoReflect() protoreflect.Message

+ func (x *CreateRequest) Reset()

+ func (x *CreateRequest) String() string

+ type CreateResponse struct

+ Id string

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

+ func (*CreateResponse) ProtoMessage()

+ func (x *CreateResponse) GetId() string

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

+ func (x *CreateResponse) Reset()

+ func (x *CreateResponse) String() string

+ type DeleteRequest struct

+ Id string

+ func (*DeleteRequest) Descriptor() ([]byte, []int)

+ func (*DeleteRequest) ProtoMessage()

+ func (x *DeleteRequest) GetId() string

+ func (x *DeleteRequest) ProtoReflect() protoreflect.Message

+ func (x *DeleteRequest) Reset()

+ func (x *DeleteRequest) String() string

+ type GroupConditionInput struct

+ Group []*ConditionInput

+ Logic GroupLogic

+ func (*GroupConditionInput) Descriptor() ([]byte, []int)

+ func (*GroupConditionInput) ProtoMessage()

+ func (x *GroupConditionInput) GetGroup() []*ConditionInput

+ func (x *GroupConditionInput) GetLogic() GroupLogic

+ func (x *GroupConditionInput) ProtoReflect() protoreflect.Message

+ func (x *GroupConditionInput) Reset()

+ func (x *GroupConditionInput) String() string

+ type GroupConditionOutput struct

+ Group []*ConditionOutput

+ Logic GroupLogic

+ func (*GroupConditionOutput) Descriptor() ([]byte, []int)

+ func (*GroupConditionOutput) ProtoMessage()

+ func (x *GroupConditionOutput) GetGroup() []*ConditionOutput

+ func (x *GroupConditionOutput) GetLogic() GroupLogic

+ func (x *GroupConditionOutput) ProtoReflect() protoreflect.Message

+ func (x *GroupConditionOutput) Reset()

+ func (x *GroupConditionOutput) String() string

+ type GroupLogic int32

+ const GroupLogic_And

+ const GroupLogic_Or

+ const GroupLogic_Xor

+ func (GroupLogic) Descriptor() protoreflect.EnumDescriptor

+ func (GroupLogic) EnumDescriptor() ([]byte, []int)

+ func (GroupLogic) Type() protoreflect.EnumType

+ func (x GroupLogic) Enum() *GroupLogic

+ func (x GroupLogic) Number() protoreflect.EnumNumber

+ func (x GroupLogic) String() string

+ type KiwiConditionOutput struct

+ Id string

+ Key string

+ Partial bool

+ Pattern string

+ func (*KiwiConditionOutput) Descriptor() ([]byte, []int)

+ func (*KiwiConditionOutput) ProtoMessage()

+ func (x *KiwiConditionOutput) GetId() string

+ func (x *KiwiConditionOutput) GetKey() string

+ func (x *KiwiConditionOutput) GetPartial() bool

+ func (x *KiwiConditionOutput) GetPattern() string

+ func (x *KiwiConditionOutput) ProtoReflect() protoreflect.Message

+ func (x *KiwiConditionOutput) Reset()

+ func (x *KiwiConditionOutput) String() string

+ type KiwiTreeConditionInput struct

+ Key string

+ Partial bool

+ Pattern string

+ func (*KiwiTreeConditionInput) Descriptor() ([]byte, []int)

+ func (*KiwiTreeConditionInput) ProtoMessage()

+ func (x *KiwiTreeConditionInput) GetKey() string

+ func (x *KiwiTreeConditionInput) GetPartial() bool

+ func (x *KiwiTreeConditionInput) GetPattern() string

+ func (x *KiwiTreeConditionInput) ProtoReflect() protoreflect.Message

+ func (x *KiwiTreeConditionInput) Reset()

+ func (x *KiwiTreeConditionInput) String() string

+ type Metadata struct

+ Description string

+ Enabled bool

+ func (*Metadata) Descriptor() ([]byte, []int)

+ func (*Metadata) ProtoMessage()

+ func (x *Metadata) GetDescription() string

+ func (x *Metadata) GetEnabled() bool

+ func (x *Metadata) ProtoReflect() protoreflect.Message

+ func (x *Metadata) Reset()

+ func (x *Metadata) String() string

+ type ReadRequest struct

+ Id string

+ func (*ReadRequest) Descriptor() ([]byte, []int)

+ func (*ReadRequest) ProtoMessage()

+ func (x *ReadRequest) GetId() string

+ func (x *ReadRequest) ProtoReflect() protoreflect.Message

+ func (x *ReadRequest) Reset()

+ func (x *ReadRequest) String() string

+ type ReadResponse struct

+ Cond *ConditionOutput

+ Md *Metadata

+ func (*ReadResponse) Descriptor() ([]byte, []int)

+ func (*ReadResponse) ProtoMessage()

+ func (x *ReadResponse) GetCond() *ConditionOutput

+ func (x *ReadResponse) GetMd() *Metadata

+ func (x *ReadResponse) ProtoReflect() protoreflect.Message

+ func (x *ReadResponse) Reset()

+ func (x *ReadResponse) String() string

+ type SearchOwnRequest struct

+ Cursor string

+ Limit uint32

+ func (*SearchOwnRequest) Descriptor() ([]byte, []int)

+ func (*SearchOwnRequest) ProtoMessage()

+ func (x *SearchOwnRequest) GetCursor() string

+ func (x *SearchOwnRequest) GetLimit() uint32

+ func (x *SearchOwnRequest) ProtoReflect() protoreflect.Message

+ func (x *SearchOwnRequest) Reset()

+ func (x *SearchOwnRequest) String() string

+ type SearchOwnResponse struct

+ Ids []string

+ func (*SearchOwnResponse) Descriptor() ([]byte, []int)

+ func (*SearchOwnResponse) ProtoMessage()

+ func (x *SearchOwnResponse) GetIds() []string

+ func (x *SearchOwnResponse) ProtoReflect() protoreflect.Message

+ func (x *SearchOwnResponse) Reset()

+ func (x *SearchOwnResponse) String() string

+ type ServiceClient interface

+ Create func(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*CreateResponse, error)

+ Delete func(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ Read func(ctx context.Context, in *ReadRequest, opts ...grpc.CallOption) (*ReadResponse, error)

+ SearchOwn func(ctx context.Context, in *SearchOwnRequest, opts ...grpc.CallOption) (*SearchOwnResponse, error)

+ UpdateMetadata func(ctx context.Context, in *UpdateMetadataRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ func NewServiceClient(cc grpc.ClientConnInterface) ServiceClient

+ type ServiceServer interface

+ Create func(context.Context, *CreateRequest) (*CreateResponse, error)

+ Delete func(context.Context, *DeleteRequest) (*emptypb.Empty, error)

+ Read func(context.Context, *ReadRequest) (*ReadResponse, error)

+ SearchOwn func(context.Context, *SearchOwnRequest) (*SearchOwnResponse, error)

+ UpdateMetadata func(context.Context, *UpdateMetadataRequest) (*emptypb.Empty, error)

+ type UnimplementedServiceServer struct

+ func (*UnimplementedServiceServer) Create(context.Context, *CreateRequest) (*CreateResponse, error)

+ func (*UnimplementedServiceServer) Delete(context.Context, *DeleteRequest) (*emptypb.Empty, error)

+ func (*UnimplementedServiceServer) Read(context.Context, *ReadRequest) (*ReadResponse, error)

+ func (*UnimplementedServiceServer) SearchOwn(context.Context, *SearchOwnRequest) (*SearchOwnResponse, error)

+ func (*UnimplementedServiceServer) UpdateMetadata(context.Context, *UpdateMetadataRequest) (*emptypb.Empty, error)

+ type UpdateMetadataRequest struct

+ Id string

+ Md *Metadata

+ func (*UpdateMetadataRequest) Descriptor() ([]byte, []int)

+ func (*UpdateMetadataRequest) ProtoMessage()

+ func (x *UpdateMetadataRequest) GetId() string

+ func (x *UpdateMetadataRequest) GetMd() *Metadata

+ func (x *UpdateMetadataRequest) ProtoReflect() protoreflect.Message

+ func (x *UpdateMetadataRequest) Reset()

+ func (x *UpdateMetadataRequest) String() string

May 21, 2023

Changes in this version

+ var ErrBusy = errors.New("subscription is busy, retry the operation")

+ var ErrInternal = errors.New("internal failure")

+ var ErrInvalid = errors.New("invalid subscription")

+ var ErrNotFound = errors.New("subscription was not found")

+ type Service interface

+ Create func(ctx context.Context, userId string, subData subscription.Data) (id string, err error)

+ Delete func(ctx context.Context, userId, subId string) (err error)

+ Read func(ctx context.Context, userId, subId string) (subData subscription.Data, err error)

+ SearchOwn func(ctx context.Context, userId string, limit uint32, cursor string) (ids []string, err error)

+ UpdateMetadata func(ctx context.Context, userId, subId string, md subscription.Metadata) (err error)

+ func NewService(client ServiceClient) Service

+ func NewServiceMock() Service