Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterRateLimiterServer(s grpc.ServiceRegistrar, srv RateLimiterServer)
- type BlackListAddRequest
- func (*BlackListAddRequest) Descriptor() ([]byte, []int)deprecated
- func (x *BlackListAddRequest) GetIpNet() string
- func (*BlackListAddRequest) ProtoMessage()
- func (x *BlackListAddRequest) ProtoReflect() protoreflect.Message
- func (x *BlackListAddRequest) Reset()
- func (x *BlackListAddRequest) String() string
- type BlackListAddResponse
- type BlackListDeleteRequest
- func (*BlackListDeleteRequest) Descriptor() ([]byte, []int)deprecated
- func (x *BlackListDeleteRequest) GetIpNet() string
- func (*BlackListDeleteRequest) ProtoMessage()
- func (x *BlackListDeleteRequest) ProtoReflect() protoreflect.Message
- func (x *BlackListDeleteRequest) Reset()
- func (x *BlackListDeleteRequest) String() string
- type BlackListDeleteResponse
- type BucketResetRequest
- func (*BucketResetRequest) Descriptor() ([]byte, []int)deprecated
- func (x *BucketResetRequest) GetIp() string
- func (x *BucketResetRequest) GetLogin() string
- func (*BucketResetRequest) ProtoMessage()
- func (x *BucketResetRequest) ProtoReflect() protoreflect.Message
- func (x *BucketResetRequest) Reset()
- func (x *BucketResetRequest) String() string
- type BucketResetResponse
- type LimitCheckRequest
- func (*LimitCheckRequest) Descriptor() ([]byte, []int)deprecated
- func (x *LimitCheckRequest) GetIp() string
- func (x *LimitCheckRequest) GetLogin() string
- func (x *LimitCheckRequest) GetPassword() string
- func (*LimitCheckRequest) ProtoMessage()
- func (x *LimitCheckRequest) ProtoReflect() protoreflect.Message
- func (x *LimitCheckRequest) Reset()
- func (x *LimitCheckRequest) String() string
- type LimitCheckResponse
- func (*LimitCheckResponse) Descriptor() ([]byte, []int)deprecated
- func (x *LimitCheckResponse) GetAllowed() bool
- func (*LimitCheckResponse) ProtoMessage()
- func (x *LimitCheckResponse) ProtoReflect() protoreflect.Message
- func (x *LimitCheckResponse) Reset()
- func (x *LimitCheckResponse) String() string
- type RateLimiterClient
- type RateLimiterServer
- type UnimplementedRateLimiterServer
- func (UnimplementedRateLimiterServer) BlackListAdd(context.Context, *BlackListAddRequest) (*BlackListAddResponse, error)
- func (UnimplementedRateLimiterServer) BlackListDelete(context.Context, *BlackListDeleteRequest) (*BlackListDeleteResponse, error)
- func (UnimplementedRateLimiterServer) BucketReset(context.Context, *BucketResetRequest) (*BucketResetResponse, error)
- func (UnimplementedRateLimiterServer) LimitCheck(context.Context, *LimitCheckRequest) (*LimitCheckResponse, error)
- func (UnimplementedRateLimiterServer) WhiteListAdd(context.Context, *WhiteListAddRequest) (*WhiteListAddResponse, error)
- func (UnimplementedRateLimiterServer) WhiteListDelete(context.Context, *WhiteListDeleteRequest) (*WhiteListDeleteResponse, error)
- type UnsafeRateLimiterServer
- type WhiteListAddRequest
- func (*WhiteListAddRequest) Descriptor() ([]byte, []int)deprecated
- func (x *WhiteListAddRequest) GetIpNet() string
- func (*WhiteListAddRequest) ProtoMessage()
- func (x *WhiteListAddRequest) ProtoReflect() protoreflect.Message
- func (x *WhiteListAddRequest) Reset()
- func (x *WhiteListAddRequest) String() string
- type WhiteListAddResponse
- type WhiteListDeleteRequest
- func (*WhiteListDeleteRequest) Descriptor() ([]byte, []int)deprecated
- func (x *WhiteListDeleteRequest) GetIpNet() string
- func (*WhiteListDeleteRequest) ProtoMessage()
- func (x *WhiteListDeleteRequest) ProtoReflect() protoreflect.Message
- func (x *WhiteListDeleteRequest) Reset()
- func (x *WhiteListDeleteRequest) String() string
- type WhiteListDeleteResponse
Constants ¶
const ( RateLimiter_WhiteListAdd_FullMethodName = "/RateLimiter.RateLimiter/WhiteListAdd" RateLimiter_WhiteListDelete_FullMethodName = "/RateLimiter.RateLimiter/WhiteListDelete" RateLimiter_BlackListAdd_FullMethodName = "/RateLimiter.RateLimiter/BlackListAdd" RateLimiter_BlackListDelete_FullMethodName = "/RateLimiter.RateLimiter/BlackListDelete" RateLimiter_BucketReset_FullMethodName = "/RateLimiter.RateLimiter/BucketReset" RateLimiter_LimitCheck_FullMethodName = "/RateLimiter.RateLimiter/LimitCheck" )
Variables ¶
var File_api_RateLimiter_proto protoreflect.FileDescriptor
var RateLimiter_ServiceDesc = grpc.ServiceDesc{ ServiceName: "RateLimiter.RateLimiter", HandlerType: (*RateLimiterServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "WhiteListAdd", Handler: _RateLimiter_WhiteListAdd_Handler, }, { MethodName: "WhiteListDelete", Handler: _RateLimiter_WhiteListDelete_Handler, }, { MethodName: "BlackListAdd", Handler: _RateLimiter_BlackListAdd_Handler, }, { MethodName: "BlackListDelete", Handler: _RateLimiter_BlackListDelete_Handler, }, { MethodName: "BucketReset", Handler: _RateLimiter_BucketReset_Handler, }, { MethodName: "LimitCheck", Handler: _RateLimiter_LimitCheck_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "api/RateLimiter.proto", }
RateLimiter_ServiceDesc is the grpc.ServiceDesc for RateLimiter service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterRateLimiterServer ¶
func RegisterRateLimiterServer(s grpc.ServiceRegistrar, srv RateLimiterServer)
Types ¶
type BlackListAddRequest ¶
type BlackListAddRequest struct { IpNet string `protobuf:"bytes,1,opt,name=ip_net,json=ipNet,proto3" json:"ip_net,omitempty"` // contains filtered or unexported fields }
func (*BlackListAddRequest) Descriptor
deprecated
func (*BlackListAddRequest) Descriptor() ([]byte, []int)
Deprecated: Use BlackListAddRequest.ProtoReflect.Descriptor instead.
func (*BlackListAddRequest) GetIpNet ¶
func (x *BlackListAddRequest) GetIpNet() string
func (*BlackListAddRequest) ProtoMessage ¶
func (*BlackListAddRequest) ProtoMessage()
func (*BlackListAddRequest) ProtoReflect ¶
func (x *BlackListAddRequest) ProtoReflect() protoreflect.Message
func (*BlackListAddRequest) Reset ¶
func (x *BlackListAddRequest) Reset()
func (*BlackListAddRequest) String ¶
func (x *BlackListAddRequest) String() string
type BlackListAddResponse ¶
type BlackListAddResponse struct {
// contains filtered or unexported fields
}
func (*BlackListAddResponse) Descriptor
deprecated
func (*BlackListAddResponse) Descriptor() ([]byte, []int)
Deprecated: Use BlackListAddResponse.ProtoReflect.Descriptor instead.
func (*BlackListAddResponse) ProtoMessage ¶
func (*BlackListAddResponse) ProtoMessage()
func (*BlackListAddResponse) ProtoReflect ¶
func (x *BlackListAddResponse) ProtoReflect() protoreflect.Message
func (*BlackListAddResponse) Reset ¶
func (x *BlackListAddResponse) Reset()
func (*BlackListAddResponse) String ¶
func (x *BlackListAddResponse) String() string
type BlackListDeleteRequest ¶
type BlackListDeleteRequest struct { IpNet string `protobuf:"bytes,1,opt,name=ip_net,json=ipNet,proto3" json:"ip_net,omitempty"` // contains filtered or unexported fields }
func (*BlackListDeleteRequest) Descriptor
deprecated
func (*BlackListDeleteRequest) Descriptor() ([]byte, []int)
Deprecated: Use BlackListDeleteRequest.ProtoReflect.Descriptor instead.
func (*BlackListDeleteRequest) GetIpNet ¶
func (x *BlackListDeleteRequest) GetIpNet() string
func (*BlackListDeleteRequest) ProtoMessage ¶
func (*BlackListDeleteRequest) ProtoMessage()
func (*BlackListDeleteRequest) ProtoReflect ¶
func (x *BlackListDeleteRequest) ProtoReflect() protoreflect.Message
func (*BlackListDeleteRequest) Reset ¶
func (x *BlackListDeleteRequest) Reset()
func (*BlackListDeleteRequest) String ¶
func (x *BlackListDeleteRequest) String() string
type BlackListDeleteResponse ¶
type BlackListDeleteResponse struct {
// contains filtered or unexported fields
}
func (*BlackListDeleteResponse) Descriptor
deprecated
func (*BlackListDeleteResponse) Descriptor() ([]byte, []int)
Deprecated: Use BlackListDeleteResponse.ProtoReflect.Descriptor instead.
func (*BlackListDeleteResponse) ProtoMessage ¶
func (*BlackListDeleteResponse) ProtoMessage()
func (*BlackListDeleteResponse) ProtoReflect ¶
func (x *BlackListDeleteResponse) ProtoReflect() protoreflect.Message
func (*BlackListDeleteResponse) Reset ¶
func (x *BlackListDeleteResponse) Reset()
func (*BlackListDeleteResponse) String ¶
func (x *BlackListDeleteResponse) String() string
type BucketResetRequest ¶
type BucketResetRequest struct { Login string `protobuf:"bytes,1,opt,name=login,proto3" json:"login,omitempty"` Ip string `protobuf:"bytes,2,opt,name=ip,proto3" json:"ip,omitempty"` // contains filtered or unexported fields }
func (*BucketResetRequest) Descriptor
deprecated
func (*BucketResetRequest) Descriptor() ([]byte, []int)
Deprecated: Use BucketResetRequest.ProtoReflect.Descriptor instead.
func (*BucketResetRequest) GetIp ¶
func (x *BucketResetRequest) GetIp() string
func (*BucketResetRequest) GetLogin ¶
func (x *BucketResetRequest) GetLogin() string
func (*BucketResetRequest) ProtoMessage ¶
func (*BucketResetRequest) ProtoMessage()
func (*BucketResetRequest) ProtoReflect ¶
func (x *BucketResetRequest) ProtoReflect() protoreflect.Message
func (*BucketResetRequest) Reset ¶
func (x *BucketResetRequest) Reset()
func (*BucketResetRequest) String ¶
func (x *BucketResetRequest) String() string
type BucketResetResponse ¶
type BucketResetResponse struct {
// contains filtered or unexported fields
}
func (*BucketResetResponse) Descriptor
deprecated
func (*BucketResetResponse) Descriptor() ([]byte, []int)
Deprecated: Use BucketResetResponse.ProtoReflect.Descriptor instead.
func (*BucketResetResponse) ProtoMessage ¶
func (*BucketResetResponse) ProtoMessage()
func (*BucketResetResponse) ProtoReflect ¶
func (x *BucketResetResponse) ProtoReflect() protoreflect.Message
func (*BucketResetResponse) Reset ¶
func (x *BucketResetResponse) Reset()
func (*BucketResetResponse) String ¶
func (x *BucketResetResponse) String() string
type LimitCheckRequest ¶
type LimitCheckRequest struct { Login string `protobuf:"bytes,1,opt,name=login,proto3" json:"login,omitempty"` Password string `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"` Ip string `protobuf:"bytes,3,opt,name=ip,proto3" json:"ip,omitempty"` // contains filtered or unexported fields }
func (*LimitCheckRequest) Descriptor
deprecated
func (*LimitCheckRequest) Descriptor() ([]byte, []int)
Deprecated: Use LimitCheckRequest.ProtoReflect.Descriptor instead.
func (*LimitCheckRequest) GetIp ¶
func (x *LimitCheckRequest) GetIp() string
func (*LimitCheckRequest) GetLogin ¶
func (x *LimitCheckRequest) GetLogin() string
func (*LimitCheckRequest) GetPassword ¶
func (x *LimitCheckRequest) GetPassword() string
func (*LimitCheckRequest) ProtoMessage ¶
func (*LimitCheckRequest) ProtoMessage()
func (*LimitCheckRequest) ProtoReflect ¶
func (x *LimitCheckRequest) ProtoReflect() protoreflect.Message
func (*LimitCheckRequest) Reset ¶
func (x *LimitCheckRequest) Reset()
func (*LimitCheckRequest) String ¶
func (x *LimitCheckRequest) String() string
type LimitCheckResponse ¶
type LimitCheckResponse struct { Allowed bool `protobuf:"varint,1,opt,name=allowed,proto3" json:"allowed,omitempty"` // contains filtered or unexported fields }
func (*LimitCheckResponse) Descriptor
deprecated
func (*LimitCheckResponse) Descriptor() ([]byte, []int)
Deprecated: Use LimitCheckResponse.ProtoReflect.Descriptor instead.
func (*LimitCheckResponse) GetAllowed ¶
func (x *LimitCheckResponse) GetAllowed() bool
func (*LimitCheckResponse) ProtoMessage ¶
func (*LimitCheckResponse) ProtoMessage()
func (*LimitCheckResponse) ProtoReflect ¶
func (x *LimitCheckResponse) ProtoReflect() protoreflect.Message
func (*LimitCheckResponse) Reset ¶
func (x *LimitCheckResponse) Reset()
func (*LimitCheckResponse) String ¶
func (x *LimitCheckResponse) String() string
type RateLimiterClient ¶
type RateLimiterClient interface { WhiteListAdd(ctx context.Context, in *WhiteListAddRequest, opts ...grpc.CallOption) (*WhiteListAddResponse, error) WhiteListDelete(ctx context.Context, in *WhiteListDeleteRequest, opts ...grpc.CallOption) (*WhiteListDeleteResponse, error) BlackListAdd(ctx context.Context, in *BlackListAddRequest, opts ...grpc.CallOption) (*BlackListAddResponse, error) BlackListDelete(ctx context.Context, in *BlackListDeleteRequest, opts ...grpc.CallOption) (*BlackListDeleteResponse, error) BucketReset(ctx context.Context, in *BucketResetRequest, opts ...grpc.CallOption) (*BucketResetResponse, error) LimitCheck(ctx context.Context, in *LimitCheckRequest, opts ...grpc.CallOption) (*LimitCheckResponse, error) }
RateLimiterClient is the client API for RateLimiter service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewRateLimiterClient ¶
func NewRateLimiterClient(cc grpc.ClientConnInterface) RateLimiterClient
type RateLimiterServer ¶
type RateLimiterServer interface { WhiteListAdd(context.Context, *WhiteListAddRequest) (*WhiteListAddResponse, error) WhiteListDelete(context.Context, *WhiteListDeleteRequest) (*WhiteListDeleteResponse, error) BlackListAdd(context.Context, *BlackListAddRequest) (*BlackListAddResponse, error) BlackListDelete(context.Context, *BlackListDeleteRequest) (*BlackListDeleteResponse, error) BucketReset(context.Context, *BucketResetRequest) (*BucketResetResponse, error) LimitCheck(context.Context, *LimitCheckRequest) (*LimitCheckResponse, error) // contains filtered or unexported methods }
RateLimiterServer is the server API for RateLimiter service. All implementations must embed UnimplementedRateLimiterServer for forward compatibility
type UnimplementedRateLimiterServer ¶
type UnimplementedRateLimiterServer struct { }
UnimplementedRateLimiterServer must be embedded to have forward compatible implementations.
func (UnimplementedRateLimiterServer) BlackListAdd ¶
func (UnimplementedRateLimiterServer) BlackListAdd(context.Context, *BlackListAddRequest) (*BlackListAddResponse, error)
func (UnimplementedRateLimiterServer) BlackListDelete ¶
func (UnimplementedRateLimiterServer) BlackListDelete(context.Context, *BlackListDeleteRequest) (*BlackListDeleteResponse, error)
func (UnimplementedRateLimiterServer) BucketReset ¶
func (UnimplementedRateLimiterServer) BucketReset(context.Context, *BucketResetRequest) (*BucketResetResponse, error)
func (UnimplementedRateLimiterServer) LimitCheck ¶
func (UnimplementedRateLimiterServer) LimitCheck(context.Context, *LimitCheckRequest) (*LimitCheckResponse, error)
func (UnimplementedRateLimiterServer) WhiteListAdd ¶
func (UnimplementedRateLimiterServer) WhiteListAdd(context.Context, *WhiteListAddRequest) (*WhiteListAddResponse, error)
func (UnimplementedRateLimiterServer) WhiteListDelete ¶
func (UnimplementedRateLimiterServer) WhiteListDelete(context.Context, *WhiteListDeleteRequest) (*WhiteListDeleteResponse, error)
type UnsafeRateLimiterServer ¶
type UnsafeRateLimiterServer interface {
// contains filtered or unexported methods
}
UnsafeRateLimiterServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to RateLimiterServer will result in compilation errors.
type WhiteListAddRequest ¶
type WhiteListAddRequest struct { IpNet string `protobuf:"bytes,1,opt,name=ip_net,json=ipNet,proto3" json:"ip_net,omitempty"` // contains filtered or unexported fields }
func (*WhiteListAddRequest) Descriptor
deprecated
func (*WhiteListAddRequest) Descriptor() ([]byte, []int)
Deprecated: Use WhiteListAddRequest.ProtoReflect.Descriptor instead.
func (*WhiteListAddRequest) GetIpNet ¶
func (x *WhiteListAddRequest) GetIpNet() string
func (*WhiteListAddRequest) ProtoMessage ¶
func (*WhiteListAddRequest) ProtoMessage()
func (*WhiteListAddRequest) ProtoReflect ¶
func (x *WhiteListAddRequest) ProtoReflect() protoreflect.Message
func (*WhiteListAddRequest) Reset ¶
func (x *WhiteListAddRequest) Reset()
func (*WhiteListAddRequest) String ¶
func (x *WhiteListAddRequest) String() string
type WhiteListAddResponse ¶
type WhiteListAddResponse struct {
// contains filtered or unexported fields
}
func (*WhiteListAddResponse) Descriptor
deprecated
func (*WhiteListAddResponse) Descriptor() ([]byte, []int)
Deprecated: Use WhiteListAddResponse.ProtoReflect.Descriptor instead.
func (*WhiteListAddResponse) ProtoMessage ¶
func (*WhiteListAddResponse) ProtoMessage()
func (*WhiteListAddResponse) ProtoReflect ¶
func (x *WhiteListAddResponse) ProtoReflect() protoreflect.Message
func (*WhiteListAddResponse) Reset ¶
func (x *WhiteListAddResponse) Reset()
func (*WhiteListAddResponse) String ¶
func (x *WhiteListAddResponse) String() string
type WhiteListDeleteRequest ¶
type WhiteListDeleteRequest struct { IpNet string `protobuf:"bytes,1,opt,name=ip_net,json=ipNet,proto3" json:"ip_net,omitempty"` // contains filtered or unexported fields }
func (*WhiteListDeleteRequest) Descriptor
deprecated
func (*WhiteListDeleteRequest) Descriptor() ([]byte, []int)
Deprecated: Use WhiteListDeleteRequest.ProtoReflect.Descriptor instead.
func (*WhiteListDeleteRequest) GetIpNet ¶
func (x *WhiteListDeleteRequest) GetIpNet() string
func (*WhiteListDeleteRequest) ProtoMessage ¶
func (*WhiteListDeleteRequest) ProtoMessage()
func (*WhiteListDeleteRequest) ProtoReflect ¶
func (x *WhiteListDeleteRequest) ProtoReflect() protoreflect.Message
func (*WhiteListDeleteRequest) Reset ¶
func (x *WhiteListDeleteRequest) Reset()
func (*WhiteListDeleteRequest) String ¶
func (x *WhiteListDeleteRequest) String() string
type WhiteListDeleteResponse ¶
type WhiteListDeleteResponse struct {
// contains filtered or unexported fields
}
func (*WhiteListDeleteResponse) Descriptor
deprecated
func (*WhiteListDeleteResponse) Descriptor() ([]byte, []int)
Deprecated: Use WhiteListDeleteResponse.ProtoReflect.Descriptor instead.
func (*WhiteListDeleteResponse) ProtoMessage ¶
func (*WhiteListDeleteResponse) ProtoMessage()
func (*WhiteListDeleteResponse) ProtoReflect ¶
func (x *WhiteListDeleteResponse) ProtoReflect() protoreflect.Message
func (*WhiteListDeleteResponse) Reset ¶
func (x *WhiteListDeleteResponse) Reset()
func (*WhiteListDeleteResponse) String ¶
func (x *WhiteListDeleteResponse) String() string