proto

type Config struct {
	Policy []*Policy `protobuf:"bytes,1,rep,name=policy,proto3" json:"policy,omitempty"`
	// contains filtered or unexported fields
}

type DecoratedQuotaAdmin struct {
	// Service is the service to decorate.
	Service QuotaAdminServer
	// Prelude is called for each method before forwarding the call to Service.
	// If Prelude returns an error, then the call is skipped and the error is
	// processed via the Postlude (if one is defined), or it is returned directly.
	Prelude func(ctx context.Context, methodName string, req proto.Message) (context.Context, error)
	// Postlude is called for each method after Service has processed the call, or
	// after the Prelude has returned an error. This takes the Service's
	// response proto (which may be nil) and/or any error. The decorated
	// service will return the response (possibly mutated) and error that Postlude
	// returns.
	Postlude func(ctx context.Context, methodName string, rsp proto.Message, err error) error
}

type GetRequest struct {

	// The named policy. Valid names depend on the policies enumerated in this
	// service's config.proto.
	//
	// Required.
	Policy string `protobuf:"bytes,1,opt,name=policy,proto3" json:"policy,omitempty"`
	// The user to fetch the named quota policy for. Must be specified when the
	// policy contains the substring "${user}".
	User string `protobuf:"bytes,2,opt,name=user,proto3" json:"user,omitempty"`
	// contains filtered or unexported fields
}

type Policy struct {

	// A globally unique name.
	//
	// Must start with a letter. Allowed characters (no spaces): A-Z a-z 0-9 - _ /
	// The substring "${user}" can be used in this name to define identical
	// per-user policies. Must not exceed 64 characters.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// The amount of resources available. Must not be negative.
	Resources int64 `protobuf:"varint,2,opt,name=resources,proto3" json:"resources,omitempty"`
	// The amount of resources to replenish every second. Must not be negative.
	Replenishment int64 `protobuf:"varint,3,opt,name=replenishment,proto3" json:"replenishment,omitempty"`
	// contains filtered or unexported fields
}

type QuotaAdminClient interface {
	// Get returns the available resources for the given policy.
	Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*QuotaEntry, error)
	// Set updates the available resources for the given policy.
	Set(ctx context.Context, in *SetRequest, opts ...grpc.CallOption) (*QuotaEntry, error)
}

type QuotaAdminServer interface {
	// Get returns the available resources for the given policy.
	Get(context.Context, *GetRequest) (*QuotaEntry, error)
	// Set updates the available resources for the given policy.
	Set(context.Context, *SetRequest) (*QuotaEntry, error)
}

type QuotaEntry struct {

	// The name of this quota entry.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// The raw name of this entry in the redis database.
	DbName string `protobuf:"bytes,2,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	// The amount of resources available.
	Resources int64 `protobuf:"varint,3,opt,name=resources,proto3" json:"resources,omitempty"`
	// contains filtered or unexported fields
}

type SetRequest struct {

	// The named policy. Valid names depend on the policies enumerated in this
	// service's config.proto.
	//
	// Required.
	Policy string `protobuf:"bytes,1,opt,name=policy,proto3" json:"policy,omitempty"`
	// The user to fetch the named quota policy for. Must be specified when the
	// policy contains the substring "${user}".
	User string `protobuf:"bytes,2,opt,name=user,proto3" json:"user,omitempty"`
	// The amount of resources that should be available. Must be non-negative.
	// Values exceeding the max specified in the policy config will be capped.
	Resources int64 `protobuf:"varint,3,opt,name=resources,proto3" json:"resources,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedQuotaAdminServer struct {
}