permits

Documentation

Index

• Variables
• func RegisterServiceServer(s *grpc.Server, srv ServiceServer)
• type GetUsageRequest
  • func (*GetUsageRequest) Descriptor() ([]byte, []int)
  • func (x *GetUsageRequest) GetSubj() subject.Subject
  • func (*GetUsageRequest) ProtoMessage()
  • func (x *GetUsageRequest) ProtoReflect() protoreflect.Message
  • func (x *GetUsageRequest) Reset()
  • func (x *GetUsageRequest) String() string
• type GetUsageResponse
  • func (*GetUsageResponse) Descriptor() ([]byte, []int)
  • func (x *GetUsageResponse) GetCount() int64
  • func (x *GetUsageResponse) GetCountTotal() int64
  • func (x *GetUsageResponse) GetSince() *timestamppb.Timestamp
  • func (*GetUsageResponse) ProtoMessage()
  • func (x *GetUsageResponse) ProtoReflect() protoreflect.Message
  • func (x *GetUsageResponse) Reset()
  • func (x *GetUsageResponse) String() string
• type Service
  • func NewService(client ServiceClient) Service
  • func NewServiceMock() Service
• type ServiceClient
  • func NewServiceClient(cc grpc.ClientConnInterface) ServiceClient
• type ServiceServer
• type UnimplementedServiceServer
  • func (*UnimplementedServiceServer) GetUsage(context.Context, *GetUsageRequest) (*GetUsageResponse, error)

Variables

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

var ErrUnavailable = errors.New("unavailable")

var File_api_grpc_permits_service_proto protoreflect.FileDescriptor

Functions

func RegisterServiceServer

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

Types

type GetUsageRequest

type GetUsageRequest 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 (*GetUsageRequest) Descriptor

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

Deprecated: Use GetUsageRequest.ProtoReflect.Descriptor instead.

func (*GetUsageRequest) GetSubj

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

func (*GetUsageRequest) ProtoMessage

func (*GetUsageRequest) ProtoMessage()

func (*GetUsageRequest) ProtoReflect

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

func (*GetUsageRequest) Reset

func (x *GetUsageRequest) Reset()

func (*GetUsageRequest) String

func (x *GetUsageRequest) String() string

type GetUsageResponse

type GetUsageResponse struct {
	Count      int64                  `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	CountTotal int64                  `protobuf:"varint,2,opt,name=countTotal,proto3" json:"countTotal,omitempty"`
	Since      *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=since,proto3" json:"since,omitempty"`
	// contains filtered or unexported fields
}

func (*GetUsageResponse) Descriptor

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

Deprecated: Use GetUsageResponse.ProtoReflect.Descriptor instead.

func (*GetUsageResponse) GetCount

func (x *GetUsageResponse) GetCount() int64

func (*GetUsageResponse) GetCountTotal

func (x *GetUsageResponse) GetCountTotal() int64

func (*GetUsageResponse) GetSince

func (x *GetUsageResponse) GetSince() *timestamppb.Timestamp

func (*GetUsageResponse) ProtoMessage

func (*GetUsageResponse) ProtoMessage()

func (*GetUsageResponse) ProtoReflect

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

func (*GetUsageResponse) Reset

func (x *GetUsageResponse) Reset()

func (*GetUsageResponse) String

func (x *GetUsageResponse) String() string

type Service

type Service interface {

	// GetUsage returns the current group/user spent counts for the specified subject.
	// A client should specify the empty user id to get the group-level value.
	GetUsage(ctx context.Context, userId string, subj usage.Subject) (u usage.Usage, err error)
}

func NewService

func NewService(client ServiceClient) Service

func NewServiceMock

func NewServiceMock() Service

type ServiceClient

type ServiceClient interface {
	GetUsage(ctx context.Context, in *GetUsageRequest, opts ...grpc.CallOption) (*GetUsageResponse, 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 NewServiceClient

func NewServiceClient(cc grpc.ClientConnInterface) ServiceClient

type ServiceServer

type ServiceServer interface {
	GetUsage(context.Context, *GetUsageRequest) (*GetUsageResponse, 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) GetUsage

func (*UnimplementedServiceServer) GetUsage(context.Context, *GetUsageRequest) (*GetUsageResponse, error)