limits

Documentation

Index

• Variables
• func RegisterServiceServer(s *grpc.Server, srv ServiceServer)
• type GetRequest
  • func (*GetRequest) Descriptor() ([]byte, []int)
  • func (x *GetRequest) GetSubj() subject.Subject
  • func (*GetRequest) ProtoMessage()
  • func (x *GetRequest) ProtoReflect() protoreflect.Message
  • func (x *GetRequest) Reset()
  • func (x *GetRequest) String() string
• type GetResponse
  • func (*GetResponse) Descriptor() ([]byte, []int)
  • func (x *GetResponse) GetCount() int64
  • func (x *GetResponse) GetExpires() *timestamppb.Timestamp
  • func (x *GetResponse) GetUserId() string
  • func (*GetResponse) ProtoMessage()
  • func (x *GetResponse) ProtoReflect() protoreflect.Message
  • func (x *GetResponse) Reset()
  • func (x *GetResponse) String() string
• type Service
  • func NewService(client ServiceClient) Service
  • func NewServiceMock() Service
• type ServiceClient
  • func NewClientConnPool(connPool *grpcpool.Pool) ServiceClient
  • func NewServiceClient(cc grpc.ClientConnInterface) ServiceClient
• type ServiceServer
• type UnimplementedServiceServer
  • func (*UnimplementedServiceServer) Get(context.Context, *GetRequest) (*GetResponse, error)

Variables

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

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

var ErrUnavailable = errors.New("unavailable")

var File_api_grpc_limits_service_proto protoreflect.FileDescriptor

Functions

func RegisterServiceServer

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

Types

type GetRequest

type GetRequest struct {
	Subj subject.Subject `protobuf:"varint,1,opt,name=subj,proto3,enum=awakari.api.subject.Subject" json:"subj,omitempty"`
	// contains filtered or unexported fields
}

func (*GetRequest) Descriptor

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

Deprecated: Use GetRequest.ProtoReflect.Descriptor instead.

func (*GetRequest) GetSubj

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

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 {
	UserId  string                 `protobuf:"bytes,1,opt,name=userId,proto3" json:"userId,omitempty"`
	Count   int64                  `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
	Expires *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=expires,proto3" json:"expires,omitempty"`
	// contains filtered or unexported fields
}

func (*GetResponse) Descriptor

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

Deprecated: Use GetResponse.ProtoReflect.Descriptor instead.

func (*GetResponse) GetCount

func (x *GetResponse) GetCount() int64

func (*GetResponse) GetExpires

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

func (*GetResponse) GetUserId

func (x *GetResponse) GetUserId() string

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 Service

type Service interface {
	Get(ctx context.Context, userId string, subj usage.Subject) (l usage.Limit, err error)
}

func NewService

func NewService(client ServiceClient) Service

func NewServiceMock

func NewServiceMock() Service

type ServiceClient

type ServiceClient interface {
	Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error)
}

ServiceClient is the client API for Service service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewClientConnPool

func NewClientConnPool(connPool *grpcpool.Pool) ServiceClient

func NewServiceClient

func NewServiceClient(cc grpc.ClientConnInterface) ServiceClient

type ServiceServer

type ServiceServer interface {
	Get(context.Context, *GetRequest) (*GetResponse, error)
}

ServiceServer is the server API for Service service.

type UnimplementedServiceServer

type UnimplementedServiceServer struct {
}

UnimplementedServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedServiceServer) Get

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