limits

Dec 28, 2023

Changes in this version

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

Oct 1, 2023

Changes in this version

type GetResponse

+ Expires *timestamppb.Timestamp

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

May 23, 2023

Changes in this version

+ var File_api_grpc_limits_service_proto protoreflect.FileDescriptor

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

+ type GetRequest struct

+ Subj subject.Subject

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

+ func (*GetRequest) ProtoMessage()

+ func (x *GetRequest) GetSubj() subject.Subject

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

+ func (x *GetRequest) Reset()

+ func (x *GetRequest) String() string

+ type GetResponse struct

+ Count int64

+ UserId string

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

+ func (*GetResponse) ProtoMessage()

+ func (x *GetResponse) GetCount() int64

+ func (x *GetResponse) GetUserId() string

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

+ func (x *GetResponse) Reset()

+ func (x *GetResponse) String() string

+ type ServiceClient interface

+ Get func(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error)

+ func NewServiceClient(cc grpc.ClientConnInterface) ServiceClient

+ type ServiceServer interface

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

+ type UnimplementedServiceServer struct

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

May 21, 2023

Changes in this version

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

+ var ErrReached = errors.New("usage limit reached")

+ type Service interface

+ Get func(ctx context.Context, userId string, subj usage.Subject) (l usage.Limit, err error)

+ func NewService(client ServiceClient) Service

+ func NewServiceMock() Service