TT-10623 Adds gRPC support for Tyk and MDCB to replace goRPC #6463
Conversation
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
|
API Changes --- prev.txt 2024-08-15 07:07:03.018620485 +0000
+++ current.txt 2024-08-15 07:06:59.726568948 +0000
@@ -5374,11 +5374,9 @@
// A policy can be defined in a file (Open Source installations) or from the same database as the Dashboard.
Policies PoliciesConfig `json:"policies"`
- // Defines the ports that will be available for the API services to bind to in the format
- // documented here https://tyk.io/docs/key-concepts/tcp-proxy/#allowing-specific-ports.
- // Ports can be configured per protocol, e.g. https, tls etc.
- // If configuring via environment variable `TYK_GW_PORTWHITELIST` then remember to escape
- // JSON strings.
+ // Defines the ports that will be available for the API services to bind to in the following format: `"{“":“”}"`. Remember to escape JSON strings.
+ // This is a map of protocol to PortWhiteList. This allows per protocol
+ // configurations.
PortWhiteList PortsWhiteList `json:"ports_whitelist"`
// Disable port whilisting, essentially allowing you to use any port for your API.
@@ -6196,7 +6194,9 @@
type SlaveOptionsConfig struct {
// Set to `true` to connect a worker Gateway using RPC.
- UseRPC bool `json:"use_rpc"`
+ UseRPC bool `json:"use_rpc"`
+ RPCType string `json:"rpc_type"`
+ GRPCForceJSON bool `json:"grpc_force_json"`
// Set this option to `true` to use an SSL RPC connection.
UseSSL bool `json:"use_ssl"`
@@ -7209,6 +7209,835 @@
CacheOptions
OASDefinition
)
+# Package: ./dispatcher
+
+package dispatcher // import "github.com/TykTechnologies/tyk/dispatcher"
+
+
+CONSTANTS
+
+const (
+ Handler_Login_FullMethodName = "/handler.Handler/Login"
+ Handler_LoginWithGroup_FullMethodName = "/handler.Handler/LoginWithGroup"
+ Handler_GetKey_FullMethodName = "/handler.Handler/GetKey"
+ Handler_SetKey_FullMethodName = "/handler.Handler/SetKey"
+ Handler_GetExp_FullMethodName = "/handler.Handler/GetExp"
+ Handler_GetKeys_FullMethodName = "/handler.Handler/GetKeys"
+ Handler_DeleteKey_FullMethodName = "/handler.Handler/DeleteKey"
+ Handler_DeleteRawKey_FullMethodName = "/handler.Handler/DeleteRawKey"
+ Handler_GetKeysAndValues_FullMethodName = "/handler.Handler/GetKeysAndValues"
+ Handler_GetKeysAndValuesWithFilter_FullMethodName = "/handler.Handler/GetKeysAndValuesWithFilter"
+ Handler_DeleteKeys_FullMethodName = "/handler.Handler/DeleteKeys"
+ Handler_Decrement_FullMethodName = "/handler.Handler/Decrement"
+ Handler_IncrementWithExpire_FullMethodName = "/handler.Handler/IncrementWithExpire"
+ Handler_AppendToSet_FullMethodName = "/handler.Handler/AppendToSet"
+ Handler_SetRollingWindow_FullMethodName = "/handler.Handler/SetRollingWindow"
+ Handler_GetApiDefinitions_FullMethodName = "/handler.Handler/GetApiDefinitions"
+ Handler_GetPolicies_FullMethodName = "/handler.Handler/GetPolicies"
+ Handler_PurgeAnalyticsData_FullMethodName = "/handler.Handler/PurgeAnalyticsData"
+ Handler_PurgeAnalyticsDataAggregated_FullMethodName = "/handler.Handler/PurgeAnalyticsDataAggregated"
+ Handler_CheckReload_FullMethodName = "/handler.Handler/CheckReload"
+ Handler_GetKeySpaceUpdate_FullMethodName = "/handler.Handler/GetKeySpaceUpdate"
+ Handler_GetGroupKeySpaceUpdate_FullMethodName = "/handler.Handler/GetGroupKeySpaceUpdate"
+ Handler_Ping_FullMethodName = "/handler.Handler/Ping"
+ Handler_Disconnect_FullMethodName = "/handler.Handler/Disconnect"
+)
+
+VARIABLES
+
+var File_handler_proto protoreflect.FileDescriptor
+var Handler_ServiceDesc = grpc.ServiceDesc{
+ ServiceName: "handler.Handler",
+ HandlerType: (*HandlerServer)(nil),
+ Methods: []grpc.MethodDesc{
+ {
+ MethodName: "Login",
+ Handler: _Handler_Login_Handler,
+ },
+ {
+ MethodName: "LoginWithGroup",
+ Handler: _Handler_LoginWithGroup_Handler,
+ },
+ {
+ MethodName: "GetKey",
+ Handler: _Handler_GetKey_Handler,
+ },
+ {
+ MethodName: "SetKey",
+ Handler: _Handler_SetKey_Handler,
+ },
+ {
+ MethodName: "GetExp",
+ Handler: _Handler_GetExp_Handler,
+ },
+ {
+ MethodName: "GetKeys",
+ Handler: _Handler_GetKeys_Handler,
+ },
+ {
+ MethodName: "DeleteKey",
+ Handler: _Handler_DeleteKey_Handler,
+ },
+ {
+ MethodName: "DeleteRawKey",
+ Handler: _Handler_DeleteRawKey_Handler,
+ },
+ {
+ MethodName: "GetKeysAndValues",
+ Handler: _Handler_GetKeysAndValues_Handler,
+ },
+ {
+ MethodName: "GetKeysAndValuesWithFilter",
+ Handler: _Handler_GetKeysAndValuesWithFilter_Handler,
+ },
+ {
+ MethodName: "DeleteKeys",
+ Handler: _Handler_DeleteKeys_Handler,
+ },
+ {
+ MethodName: "Decrement",
+ Handler: _Handler_Decrement_Handler,
+ },
+ {
+ MethodName: "IncrementWithExpire",
+ Handler: _Handler_IncrementWithExpire_Handler,
+ },
+ {
+ MethodName: "AppendToSet",
+ Handler: _Handler_AppendToSet_Handler,
+ },
+ {
+ MethodName: "SetRollingWindow",
+ Handler: _Handler_SetRollingWindow_Handler,
+ },
+ {
+ MethodName: "GetApiDefinitions",
+ Handler: _Handler_GetApiDefinitions_Handler,
+ },
+ {
+ MethodName: "GetPolicies",
+ Handler: _Handler_GetPolicies_Handler,
+ },
+ {
+ MethodName: "PurgeAnalyticsData",
+ Handler: _Handler_PurgeAnalyticsData_Handler,
+ },
+ {
+ MethodName: "PurgeAnalyticsDataAggregated",
+ Handler: _Handler_PurgeAnalyticsDataAggregated_Handler,
+ },
+ {
+ MethodName: "CheckReload",
+ Handler: _Handler_CheckReload_Handler,
+ },
+ {
+ MethodName: "GetKeySpaceUpdate",
+ Handler: _Handler_GetKeySpaceUpdate_Handler,
+ },
+ {
+ MethodName: "GetGroupKeySpaceUpdate",
+ Handler: _Handler_GetGroupKeySpaceUpdate_Handler,
+ },
+ {
+ MethodName: "Ping",
+ Handler: _Handler_Ping_Handler,
+ },
+ {
+ MethodName: "Disconnect",
+ Handler: _Handler_Disconnect_Handler,
+ },
+ },
+ Streams: []grpc.StreamDesc{},
+ Metadata: "handler.proto",
+}
+ Handler_ServiceDesc is the grpc.ServiceDesc for Handler service.
+ It's only intended for direct use with grpc.RegisterService, and not to be
+ introspected or modified (even as a copy)
+
+
+FUNCTIONS
+
+func RegisterHandlerServer(s grpc.ServiceRegistrar, srv HandlerServer)
+
+TYPES
+
+type AnalyticsDataRequest struct {
+ ClientId string `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
+ Data string `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
+ // Has unexported fields.
+}
+
+func (*AnalyticsDataRequest) Descriptor() ([]byte, []int)
+ Deprecated: Use AnalyticsDataRequest.ProtoReflect.Descriptor instead.
+
+func (x *AnalyticsDataRequest) GetClientId() string
+
+func (x *AnalyticsDataRequest) GetData() string
+
+func (*AnalyticsDataRequest) ProtoMessage()
+
+func (x *AnalyticsDataRequest) ProtoReflect() protoreflect.Message
+
+func (x *AnalyticsDataRequest) Reset()
+
+func (x *AnalyticsDataRequest) String() string
+
+type ApiDefinitionsResponse struct {
+ Definitions string `protobuf:"bytes,1,opt,name=definitions,proto3" json:"definitions,omitempty"`
+ // Has unexported fields.
+}
+
+func (*ApiDefinitionsResponse) Descriptor() ([]byte, []int)
+ Deprecated: Use ApiDefinitionsResponse.ProtoReflect.Descriptor instead.
+
+func (x *ApiDefinitionsResponse) GetDefinitions() string
+
+func (*ApiDefinitionsResponse) ProtoMessage()
+
+func (x *ApiDefinitionsResponse) ProtoReflect() protoreflect.Message
+
+func (x *ApiDefinitionsResponse) Reset()
+
+func (x *ApiDefinitionsResponse) String() string
+
+type AppendToSetRequest struct {
+ ClientId string `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
+ Data *InboundData `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
+ // Has unexported fields.
+}
+
+func (*AppendToSetRequest) Descriptor() ([]byte, []int)
+ Deprecated: Use AppendToSetRequest.ProtoReflect.Descriptor instead.
+
+func (x *AppendToSetRequest) GetClientId() string
+
+func (x *AppendToSetRequest) GetData() *InboundData
+
+func (*AppendToSetRequest) ProtoMessage()
+
+func (x *AppendToSetRequest) ProtoReflect() protoreflect.Message
+
+func (x *AppendToSetRequest) Reset()
+
+func (x *AppendToSetRequest) String() string
+
+type DefRequest struct {
+ OrgId string `protobuf:"bytes,1,opt,name=org_id,json=orgId,proto3" json:"org_id,omitempty"`
+ Tags []string `protobuf:"bytes,2,rep,name=tags,proto3" json:"tags,omitempty"`
+ LoadOas bool `protobuf:"varint,3,opt,name=load_oas,json=loadOas,proto3" json:"load_oas,omitempty"`
+ // Has unexported fields.
+}
+
+func (*DefRequest) Descriptor() ([]byte, []int)
+ Deprecated: Use DefRequest.ProtoReflect.Descriptor instead.
+
+func (x *DefRequest) GetLoadOas() bool
+
+func (x *DefRequest) GetOrgId() string
+
+func (x *DefRequest) GetTags() []string
+
+func (*DefRequest) ProtoMessage()
+
+func (x *DefRequest) ProtoReflect() protoreflect.Message
+
+func (x *DefRequest) Reset()
+
+func (x *DefRequest) String() string
+
+type DeleteKeysRequest struct {
+ ClientId string `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
+ Keys []string `protobuf:"bytes,2,rep,name=keys,proto3" json:"keys,omitempty"`
+ // Has unexported fields.
+}
+
+func (*DeleteKeysRequest) Descriptor() ([]byte, []int)
+ Deprecated: Use DeleteKeysRequest.ProtoReflect.Descriptor instead.
+
+func (x *DeleteKeysRequest) GetClientId() string
+
+func (x *DeleteKeysRequest) GetKeys() []string
+
+func (*DeleteKeysRequest) ProtoMessage()
+
+func (x *DeleteKeysRequest) ProtoReflect() protoreflect.Message
+
+func (x *DeleteKeysRequest) Reset()
+
+func (x *DeleteKeysRequest) String() string
+
+type DeleteResponse struct {
+ Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
+ // Has unexported fields.
+}
+
+func (*DeleteResponse) Descriptor() ([]byte, []int)
+ Deprecated: Use DeleteResponse.ProtoReflect.Descriptor instead.
+
+func (x *DeleteResponse) GetSuccess() bool
+
+func (*DeleteResponse) ProtoMessage()
+
+func (x *DeleteResponse) ProtoReflect() protoreflect.Message
+
+func (x *DeleteResponse) Reset()
+
+func (x *DeleteResponse) String() string
+
+type ExpResponse struct {
+ Expiration int64 `protobuf:"varint,1,opt,name=expiration,proto3" json:"expiration,omitempty"`
+ // Has unexported fields.
+}
+
+func (*ExpResponse) Descriptor() ([]byte, []int)
+ Deprecated: Use ExpResponse.ProtoReflect.Descriptor instead.
+
+func (x *ExpResponse) GetExpiration() int64
+
+func (*ExpResponse) ProtoMessage()
+
+func (x *ExpResponse) ProtoReflect() protoreflect.Message
+
+func (x *ExpResponse) Reset()
+
+func (x *ExpResponse) String() string
+
+type GroupKeySpaceRequest struct {
+ OrgId string `protobuf:"bytes,1,opt,name=org_id,json=orgId,proto3" json:"org_id,omitempty"`
+ GroupId string `protobuf:"bytes,2,opt,name=group_id,json=groupId,proto3" json:"group_id,omitempty"`
+ // Has unexported fields.
+}
+
+func (*GroupKeySpaceRequest) Descriptor() ([]byte, []int)
+ Deprecated: Use GroupKeySpaceRequest.ProtoReflect.Descriptor instead.
+
+func (x *GroupKeySpaceRequest) GetGroupId() string
+
+func (x *GroupKeySpaceRequest) GetOrgId() string
+
+func (*GroupKeySpaceRequest) ProtoMessage()
+
+func (x *GroupKeySpaceRequest) ProtoReflect() protoreflect.Message
+
+func (x *GroupKeySpaceRequest) Reset()
+
+func (x *GroupKeySpaceRequest) String() string
+
+type GroupLoginRequest struct {
+ UserKey string `protobuf:"bytes,1,opt,name=user_key,json=userKey,proto3" json:"user_key,omitempty"`
+ GroupId string `protobuf:"bytes,2,opt,name=group_id,json=groupId,proto3" json:"group_id,omitempty"`
+ ForceSync bool `protobuf:"varint,3,opt,name=force_sync,json=forceSync,proto3" json:"force_sync,omitempty"`
+ Node []byte `protobuf:"bytes,4,opt,name=node,proto3" json:"node,omitempty"`
+ // Has unexported fields.
+}
+
+func (*GroupLoginRequest) Descriptor() ([]byte, []int)
+ Deprecated: Use GroupLoginRequest.ProtoReflect.Descriptor instead.
+
+func (x *GroupLoginRequest) GetForceSync() bool
+
+func (x *GroupLoginRequest) GetGroupId() string
+
+func (x *GroupLoginRequest) GetNode() []byte
+
+func (x *GroupLoginRequest) GetUserKey() string
+
+func (*GroupLoginRequest) ProtoMessage()
+
+func (x *GroupLoginRequest) ProtoReflect() protoreflect.Message
+
+func (x *GroupLoginRequest) Reset()
+
+func (x *GroupLoginRequest) String() string
+
+type HandlerClient interface {
+ Login(ctx context.Context, in *LoginRequest, opts ...grpc.CallOption) (*LoginResponse, error)
+ LoginWithGroup(ctx context.Context, in *GroupLoginRequest, opts ...grpc.CallOption) (*LoginResponse, error)
+ GetKey(ctx context.Context, in *KeyRequest, opts ...grpc.CallOption) (*KeyResponse, error)
+ SetKey(ctx context.Context, in *SetKeyRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
+ GetExp(ctx context.Context, in *KeyRequest, opts ...grpc.CallOption) (*ExpResponse, error)
+ GetKeys(ctx context.Context, in *KeyRequest, opts ...grpc.CallOption) (*KeysResponse, error)
+ DeleteKey(ctx context.Context, in *KeyRequest, opts ...grpc.CallOption) (*DeleteResponse, error)
+ DeleteRawKey(ctx context.Context, in *KeyRequest, opts ...grpc.CallOption) (*DeleteResponse, error)
+ GetKeysAndValues(ctx context.Context, in *SearchRequest, opts ...grpc.CallOption) (*KeysValuesResponse, error)
+ GetKeysAndValuesWithFilter(ctx context.Context, in *SearchRequest, opts ...grpc.CallOption) (*KeysValuesResponse, error)
+ DeleteKeys(ctx context.Context, in *DeleteKeysRequest, opts ...grpc.CallOption) (*DeleteResponse, error)
+ Decrement(ctx context.Context, in *KeyRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
+ IncrementWithExpire(ctx context.Context, in *IncrementRequest, opts ...grpc.CallOption) (*IncrementResponse, error)
+ AppendToSet(ctx context.Context, in *AppendToSetRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
+ SetRollingWindow(ctx context.Context, in *SetRollingWindowRequest, opts ...grpc.CallOption) (*SetRollingWindowResponse, error)
+ GetApiDefinitions(ctx context.Context, in *DefRequest, opts ...grpc.CallOption) (*ApiDefinitionsResponse, error)
+ GetPolicies(ctx context.Context, in *OrgIdRequest, opts ...grpc.CallOption) (*PoliciesResponse, error)
+ PurgeAnalyticsData(ctx context.Context, in *AnalyticsDataRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
+ PurgeAnalyticsDataAggregated(ctx context.Context, in *AnalyticsDataRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
+ CheckReload(ctx context.Context, in *OrgIdRequest, opts ...grpc.CallOption) (*ReloadResponse, error)
+ GetKeySpaceUpdate(ctx context.Context, in *OrgIdRequest, opts ...grpc.CallOption) (*KeySpaceUpdateResponse, error)
+ GetGroupKeySpaceUpdate(ctx context.Context, in *GroupKeySpaceRequest, opts ...grpc.CallOption) (*KeySpaceUpdateResponse, error)
+ Ping(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*PingResponse, error)
+ Disconnect(ctx context.Context, in *GroupLoginRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
+}
+ HandlerClient is the client API for Handler 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 NewHandlerClient(cc grpc.ClientConnInterface) HandlerClient
+
+type HandlerServer interface {
+ Login(context.Context, *LoginRequest) (*LoginResponse, error)
+ LoginWithGroup(context.Context, *GroupLoginRequest) (*LoginResponse, error)
+ GetKey(context.Context, *KeyRequest) (*KeyResponse, error)
+ SetKey(context.Context, *SetKeyRequest) (*emptypb.Empty, error)
+ GetExp(context.Context, *KeyRequest) (*ExpResponse, error)
+ GetKeys(context.Context, *KeyRequest) (*KeysResponse, error)
+ DeleteKey(context.Context, *KeyRequest) (*DeleteResponse, error)
+ DeleteRawKey(context.Context, *KeyRequest) (*DeleteResponse, error)
+ GetKeysAndValues(context.Context, *SearchRequest) (*KeysValuesResponse, error)
+ GetKeysAndValuesWithFilter(context.Context, *SearchRequest) (*KeysValuesResponse, error)
+ DeleteKeys(context.Context, *DeleteKeysRequest) (*DeleteResponse, error)
+ Decrement(context.Context, *KeyRequest) (*emptypb.Empty, error)
+ IncrementWithExpire(context.Context, *IncrementRequest) (*IncrementResponse, error)
+ AppendToSet(context.Context, *AppendToSetRequest) (*emptypb.Empty, error)
+ SetRollingWindow(context.Context, *SetRollingWindowRequest) (*SetRollingWindowResponse, error)
+ GetApiDefinitions(context.Context, *DefRequest) (*ApiDefinitionsResponse, error)
+ GetPolicies(context.Context, *OrgIdRequest) (*PoliciesResponse, error)
+ PurgeAnalyticsData(context.Context, *AnalyticsDataRequest) (*emptypb.Empty, error)
+ PurgeAnalyticsDataAggregated(context.Context, *AnalyticsDataRequest) (*emptypb.Empty, error)
+ CheckReload(context.Context, *OrgIdRequest) (*ReloadResponse, error)
+ GetKeySpaceUpdate(context.Context, *OrgIdRequest) (*KeySpaceUpdateResponse, error)
+ GetGroupKeySpaceUpdate(context.Context, *GroupKeySpaceRequest) (*KeySpaceUpdateResponse, error)
+ Ping(context.Context, *emptypb.Empty) (*PingResponse, error)
+ Disconnect(context.Context, *GroupLoginRequest) (*emptypb.Empty, error)
+ // Has unexported methods.
+}
+ HandlerServer is the server API for Handler service. All implementations
+ must embed UnimplementedHandlerServer for forward compatibility.
+
+type InboundData struct {
+ KeyName string `protobuf:"bytes,1,opt,name=key_name,json=keyName,proto3" json:"key_name,omitempty"`
+ Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
+ SessionState string `protobuf:"bytes,3,opt,name=session_state,json=sessionState,proto3" json:"session_state,omitempty"`
+ Timeout int64 `protobuf:"varint,4,opt,name=timeout,proto3" json:"timeout,omitempty"`
+ Per int64 `protobuf:"varint,5,opt,name=per,proto3" json:"per,omitempty"`
+ Expire int64 `protobuf:"varint,6,opt,name=expire,proto3" json:"expire,omitempty"`
+ // Has unexported fields.
+}
+
+func (*InboundData) Descriptor() ([]byte, []int)
+ Deprecated: Use InboundData.ProtoReflect.Descriptor instead.
+
+func (x *InboundData) GetExpire() int64
+
+func (x *InboundData) GetKeyName() string
+
+func (x *InboundData) GetPer() int64
+
+func (x *InboundData) GetSessionState() string
+
+func (x *InboundData) GetTimeout() int64
+
+func (x *InboundData) GetValue() string
+
+func (*InboundData) ProtoMessage()
+
+func (x *InboundData) ProtoReflect() protoreflect.Message
+
+func (x *InboundData) Reset()
+
+func (x *InboundData) String() string
+
+type IncrementRequest struct {
+ ClientId string `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
+ Data *InboundData `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
+ // Has unexported fields.
+}
+
+func (*IncrementRequest) Descriptor() ([]byte, []int)
+ Deprecated: Use IncrementRequest.ProtoReflect.Descriptor instead.
+
+func (x *IncrementRequest) GetClientId() string
+
+func (x *IncrementRequest) GetData() *InboundData
+
+func (*IncrementRequest) ProtoMessage()
+
+func (x *IncrementRequest) ProtoReflect() protoreflect.Message
+
+func (x *IncrementRequest) Reset()
+
+func (x *IncrementRequest) String() string
+
+type IncrementResponse struct {
+ Value int64 `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"`
+ // Has unexported fields.
+}
+
+func (*IncrementResponse) Descriptor() ([]byte, []int)
+ Deprecated: Use IncrementResponse.ProtoReflect.Descriptor instead.
+
+func (x *IncrementResponse) GetValue() int64
+
+func (*IncrementResponse) ProtoMessage()
+
+func (x *IncrementResponse) ProtoReflect() protoreflect.Message
+
+func (x *IncrementResponse) Reset()
+
+func (x *IncrementResponse) String() string
+
+type KeyRequest struct {
+ ClientId string `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
+ KeyName string `protobuf:"bytes,2,opt,name=key_name,json=keyName,proto3" json:"key_name,omitempty"`
+ // Has unexported fields.
+}
+
+func (*KeyRequest) Descriptor() ([]byte, []int)
+ Deprecated: Use KeyRequest.ProtoReflect.Descriptor instead.
+
+func (x *KeyRequest) GetClientId() string
+
+func (x *KeyRequest) GetKeyName() string
+
+func (*KeyRequest) ProtoMessage()
+
+func (x *KeyRequest) ProtoReflect() protoreflect.Message
+
+func (x *KeyRequest) Reset()
+
+func (x *KeyRequest) String() string
+
+type KeyResponse struct {
+ Value string `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
+ // Has unexported fields.
+}
+
+func (*KeyResponse) Descriptor() ([]byte, []int)
+ Deprecated: Use KeyResponse.ProtoReflect.Descriptor instead.
+
+func (x *KeyResponse) GetValue() string
+
+func (*KeyResponse) ProtoMessage()
+
+func (x *KeyResponse) ProtoReflect() protoreflect.Message
+
+func (x *KeyResponse) Reset()
+
+func (x *KeyResponse) String() string
+
+type KeySpaceUpdateResponse struct {
+ Updates []string `protobuf:"bytes,1,rep,name=updates,proto3" json:"updates,omitempty"`
+ // Has unexported fields.
+}
+
+func (*KeySpaceUpdateResponse) Descriptor() ([]byte, []int)
+ Deprecated: Use KeySpaceUpdateResponse.ProtoReflect.Descriptor instead.
+
+func (x *KeySpaceUpdateResponse) GetUpdates() []string
+
+func (*KeySpaceUpdateResponse) ProtoMessage()
+
+func (x *KeySpaceUpdateResponse) ProtoReflect() protoreflect.Message
+
+func (x *KeySpaceUpdateResponse) Reset()
+
+func (x *KeySpaceUpdateResponse) String() string
+
+type KeysResponse struct {
+ Keys []string `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"`
+ // Has unexported fields.
+}
+
+func (*KeysResponse) Descriptor() ([]byte, []int)
+ Deprecated: Use KeysResponse.ProtoReflect.Descriptor instead.
+
+func (x *KeysResponse) GetKeys() []string
+
+func (*KeysResponse) ProtoMessage()
+
+func (x *KeysResponse) ProtoReflect() protoreflect.Message
+
+func (x *KeysResponse) Reset()
+
+func (x *KeysResponse) String() string
+
+type KeysValuesResponse struct {
+ Keys []string `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"`
+ Values []string `protobuf:"bytes,2,rep,name=values,proto3" json:"values,omitempty"`
+ // Has unexported fields.
+}
+
+func (*KeysValuesResponse) Descriptor() ([]byte, []int)
+ Deprecated: Use KeysValuesResponse.ProtoReflect.Descriptor instead.
+
+func (x *KeysValuesResponse) GetKeys() []string
+
+func (x *KeysValuesResponse) GetValues() []string
+
+func (*KeysValuesResponse) ProtoMessage()
+
+func (x *KeysValuesResponse) ProtoReflect() protoreflect.Message
+
+func (x *KeysValuesResponse) Reset()
+
+func (x *KeysValuesResponse) String() string
+
+type LoginRequest struct {
+ ClientId string `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
+ UserKey string `protobuf:"bytes,2,opt,name=user_key,json=userKey,proto3" json:"user_key,omitempty"`
+ // Has unexported fields.
+}
+
+func (*LoginRequest) Descriptor() ([]byte, []int)
+ Deprecated: Use LoginRequest.ProtoReflect.Descriptor instead.
+
+func (x *LoginRequest) GetClientId() string
+
+func (x *LoginRequest) GetUserKey() string
+
+func (*LoginRequest) ProtoMessage()
+
+func (x *LoginRequest) ProtoReflect() protoreflect.Message
+
+func (x *LoginRequest) Reset()
+
+func (x *LoginRequest) String() string
+
+type LoginResponse struct {
+ Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
+ // Has unexported fields.
+}
+
+func (*LoginResponse) Descriptor() ([]byte, []int)
+ Deprecated: Use LoginResponse.ProtoReflect.Descriptor instead.
+
+func (x *LoginResponse) GetSuccess() bool
+
+func (*LoginResponse) ProtoMessage()
+
+func (x *LoginResponse) ProtoReflect() protoreflect.Message
+
+func (x *LoginResponse) Reset()
+
+func (x *LoginResponse) String() string
+
+type OrgIdRequest struct {
+ ClientId string `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
+ OrgId string `protobuf:"bytes,2,opt,name=org_id,json=orgId,proto3" json:"org_id,omitempty"`
+ // Has unexported fields.
+}
+
+func (*OrgIdRequest) Descriptor() ([]byte, []int)
+ Deprecated: Use OrgIdRequest.ProtoReflect.Descriptor instead.
+
+func (x *OrgIdRequest) GetClientId() string
+
+func (x *OrgIdRequest) GetOrgId() string
+
+func (*OrgIdRequest) ProtoMessage()
+
+func (x *OrgIdRequest) ProtoReflect() protoreflect.Message
+
+func (x *OrgIdRequest) Reset()
+
+func (x *OrgIdRequest) String() string
+
+type PingResponse struct {
+ Pong bool `protobuf:"varint,1,opt,name=pong,proto3" json:"pong,omitempty"`
+ // Has unexported fields.
+}
+
+func (*PingResponse) Descriptor() ([]byte, []int)
+ Deprecated: Use PingResponse.ProtoReflect.Descriptor instead.
+
+func (x *PingResponse) GetPong() bool
+
+func (*PingResponse) ProtoMessage()
+
+func (x *PingResponse) ProtoReflect() protoreflect.Message
+
+func (x *PingResponse) Reset()
+
+func (x *PingResponse) String() string
+
+type PoliciesResponse struct {
+ Policies string `protobuf:"bytes,1,opt,name=policies,proto3" json:"policies,omitempty"`
+ // Has unexported fields.
+}
+
+func (*PoliciesResponse) Descriptor() ([]byte, []int)
+ Deprecated: Use PoliciesResponse.ProtoReflect.Descriptor instead.
+
+func (x *PoliciesResponse) GetPolicies() string
+
+func (*PoliciesResponse) ProtoMessage()
+
+func (x *PoliciesResponse) ProtoReflect() protoreflect.Message
+
+func (x *PoliciesResponse) Reset()
+
+func (x *PoliciesResponse) String() string
+
+type ReloadResponse struct {
+ ReloadRequired bool `protobuf:"varint,1,opt,name=reload_required,json=reloadRequired,proto3" json:"reload_required,omitempty"`
+ // Has unexported fields.
+}
+
+func (*ReloadResponse) Descriptor() ([]byte, []int)
+ Deprecated: Use ReloadResponse.ProtoReflect.Descriptor instead.
+
+func (x *ReloadResponse) GetReloadRequired() bool
+
+func (*ReloadResponse) ProtoMessage()
+
+func (x *ReloadResponse) ProtoReflect() protoreflect.Message
+
+func (x *ReloadResponse) Reset()
+
+func (x *ReloadResponse) String() string
+
+type SearchRequest struct {
+ ClientId string `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
+ SearchString string `protobuf:"bytes,2,opt,name=search_string,json=searchString,proto3" json:"search_string,omitempty"`
+ // Has unexported fields.
+}
+
+func (*SearchRequest) Descriptor() ([]byte, []int)
+ Deprecated: Use SearchRequest.ProtoReflect.Descriptor instead.
+
+func (x *SearchRequest) GetClientId() string
+
+func (x *SearchRequest) GetSearchString() string
+
+func (*SearchRequest) ProtoMessage()
+
+func (x *SearchRequest) ProtoReflect() protoreflect.Message
+
+func (x *SearchRequest) Reset()
+
+func (x *SearchRequest) String() string
+
+type SetKeyRequest struct {
+ ClientId string `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
+ Data *InboundData `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
+ // Has unexported fields.
+}
+
+func (*SetKeyRequest) Descriptor() ([]byte, []int)
+ Deprecated: Use SetKeyRequest.ProtoReflect.Descriptor instead.
+
+func (x *SetKeyRequest) GetClientId() string
+
+func (x *SetKeyRequest) GetData() *InboundData
+
+func (*SetKeyRequest) ProtoMessage()
+
+func (x *SetKeyRequest) ProtoReflect() protoreflect.Message
+
+func (x *SetKeyRequest) Reset()
+
+func (x *SetKeyRequest) String() string
+
+type SetRollingWindowRequest struct {
+ ClientId string `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
+ Data *InboundData `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
+ // Has unexported fields.
+}
+
+func (*SetRollingWindowRequest) Descriptor() ([]byte, []int)
+ Deprecated: Use SetRollingWindowRequest.ProtoReflect.Descriptor instead.
+
+func (x *SetRollingWindowRequest) GetClientId() string
+
+func (x *SetRollingWindowRequest) GetData() *InboundData
+
+func (*SetRollingWindowRequest) ProtoMessage()
+
+func (x *SetRollingWindowRequest) ProtoReflect() protoreflect.Message
+
+func (x *SetRollingWindowRequest) Reset()
+
+func (x *SetRollingWindowRequest) String() string
+
+type SetRollingWindowResponse struct {
+ Count int32 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
+ // Has unexported fields.
+}
+
+func (*SetRollingWindowResponse) Descriptor() ([]byte, []int)
+ Deprecated: Use SetRollingWindowResponse.ProtoReflect.Descriptor instead.
+
+func (x *SetRollingWindowResponse) GetCount() int32
+
+func (*SetRollingWindowResponse) ProtoMessage()
+
+func (x *SetRollingWindowResponse) ProtoReflect() protoreflect.Message
+
+func (x *SetRollingWindowResponse) Reset()
+
+func (x *SetRollingWindowResponse) String() string
+
+type UnimplementedHandlerServer struct{}
+ UnimplementedHandlerServer must be embedded to have forward compatible
+ implementations.
+
+ NOTE: this should be embedded by value instead of pointer to avoid a nil
+ pointer dereference when methods are called.
+
+func (UnimplementedHandlerServer) AppendToSet(context.Context, *AppendToSetRequest) (*emptypb.Empty, error)
+
+func (UnimplementedHandlerServer) CheckReload(context.Context, *OrgIdRequest) (*ReloadResponse, error)
+
+func (UnimplementedHandlerServer) Decrement(context.Context, *KeyRequest) (*emptypb.Empty, error)
+
+func (UnimplementedHandlerServer) DeleteKey(context.Context, *KeyRequest) (*DeleteResponse, error)
+
+func (UnimplementedHandlerServer) DeleteKeys(context.Context, *DeleteKeysRequest) (*DeleteResponse, error)
+
+func (UnimplementedHandlerServer) DeleteRawKey(context.Context, *KeyRequest) (*DeleteResponse, error)
+
+func (UnimplementedHandlerServer) Disconnect(context.Context, *GroupLoginRequest) (*emptypb.Empty, error)
+
+func (UnimplementedHandlerServer) GetApiDefinitions(context.Context, *DefRequest) (*ApiDefinitionsResponse, error)
+
+func (UnimplementedHandlerServer) GetExp(context.Context, *KeyRequest) (*ExpResponse, error)
+
+func (UnimplementedHandlerServer) GetGroupKeySpaceUpdate(context.Context, *GroupKeySpaceRequest) (*KeySpaceUpdateResponse, error)
+
+func (UnimplementedHandlerServer) GetKey(context.Context, *KeyRequest) (*KeyResponse, error)
+
+func (UnimplementedHandlerServer) GetKeySpaceUpdate(context.Context, *OrgIdRequest) (*KeySpaceUpdateResponse, error)
+
+func (UnimplementedHandlerServer) GetKeys(context.Context, *KeyRequest) (*KeysResponse, error)
+
+func (UnimplementedHandlerServer) GetKeysAndValues(context.Context, *SearchRequest) (*KeysValuesResponse, error)
+
+func (UnimplementedHandlerServer) GetKeysAndValuesWithFilter(context.Context, *SearchRequest) (*KeysValuesResponse, error)
+
+func (UnimplementedHandlerServer) GetPolicies(context.Context, *OrgIdRequest) (*PoliciesResponse, error)
+
+func (UnimplementedHandlerServer) IncrementWithExpire(context.Context, *IncrementRequest) (*IncrementResponse, error)
+
+func (UnimplementedHandlerServer) Login(context.Context, *LoginRequest) (*LoginResponse, error)
+
+func (UnimplementedHandlerServer) LoginWithGroup(context.Context, *GroupLoginRequest) (*LoginResponse, error)
+
+func (UnimplementedHandlerServer) Ping(context.Context, *emptypb.Empty) (*PingResponse, error)
+
+func (UnimplementedHandlerServer) PurgeAnalyticsData(context.Context, *AnalyticsDataRequest) (*emptypb.Empty, error)
+
+func (UnimplementedHandlerServer) PurgeAnalyticsDataAggregated(context.Context, *AnalyticsDataRequest) (*emptypb.Empty, error)
+
+func (UnimplementedHandlerServer) SetKey(context.Context, *SetKeyRequest) (*emptypb.Empty, error)
+
+func (UnimplementedHandlerServer) SetRollingWindow(context.Context, *SetRollingWindowRequest) (*SetRollingWindowResponse, error)
+
+type UnsafeHandlerServer interface {
+ // Has unexported methods.
+}
+ UnsafeHandlerServer may be embedded to opt out of forward compatibility for
+ this service. Use of this interface is not recommended, as added methods to
+ HandlerServer will result in compilation errors.
+
# Package: ./dlpython
package python // import "github.com/TykTechnologies/tyk/dlpython"
@@ -7530,6 +8359,10 @@
ErrOAuthClientDeleted = "oauth.client_deleted"
)
const (
+ GRPCBackend = "grpc"
+ LegacyRPC = "rpc"
+)
+const (
ResetQuota string = "resetQuota"
CertificateRemoved string = "CertificateRemoved"
CertificateAdded string = "CertificateAdded"
@@ -7681,6 +8514,7 @@
func GenerateTestBinaryData() (buf *bytes.Buffer)
func GetAccessDefinitionByAPIIDOrSession(session *user.SessionState, api *APISpec) (accessDef *user.AccessDefinition, allowanceScope string, err error)
+func GetRPCBackendHandler(name string, cfg *rpcInitConfig) storage.Handler
func GetTLSClient(cert *tls.Certificate, caCert []byte) *http.Client
func GetTLSConfig(cert *tls.Certificate, caCert []byte) *tls.Config
func InitTestMain(ctx context.Context, m *testing.M) int
@@ -8428,6 +9262,111 @@
func (g *FileBundleGetter) Get() ([]byte, error)
Get mocks an HTTP(S) GET request.
+type GPCStorageHandler struct {
+ KeyPrefix string
+ HashKeys bool
+ SuppressRegister bool
+ DoReload func()
+ Gw *Gateway `json:"-"`
+
+ // Has unexported fields.
+}
+ GPCStorageHandler is a storage manager that uses gRPC to communicate with
+ the server.
+
+func (r *GPCStorageHandler) AddToSet(keyName string, value string)
+
+func (r *GPCStorageHandler) AddToSortedSet(keyName string, value string, score float64)
+
+func (r *GPCStorageHandler) AppendToSet(keyName, value string)
+
+func (r *GPCStorageHandler) CheckForReload(orgId string) bool
+ CheckForReload checks if a reload is required for the given organization
+
+func (r *GPCStorageHandler) Connect() bool
+
+func (r *GPCStorageHandler) Decrement(keyName string)
+
+func (r *GPCStorageHandler) DeleteAllKeys() bool
+
+func (r *GPCStorageHandler) DeleteKey(keyName string) bool
+
+func (r *GPCStorageHandler) DeleteKeys(keys []string) bool
+
+func (r *GPCStorageHandler) DeleteRawKey(keyName string) bool
+
+func (r *GPCStorageHandler) DeleteScanMatch(pattern string) bool
+
+func (r *GPCStorageHandler) Disconnect() error
+
+func (r *GPCStorageHandler) Exists(keyName string) (bool, error)
+
+func (r *GPCStorageHandler) GetAndDeleteSet(keyName string) []interface{}
+
+func (r *GPCStorageHandler) GetApiDefinitions(orgId string, tags []string) string
+ GetApiDefinitions retrieves API definitions for a given organization ID and
+ set of tags
+
+func (r *GPCStorageHandler) GetExp(keyName string) (int64, error)
+
+func (r *GPCStorageHandler) GetKey(keyName string) (string, error)
+
+func (r *GPCStorageHandler) GetKeyPrefix() string
+
+func (r *GPCStorageHandler) GetKeys(filter string) []string
+
+func (r *GPCStorageHandler) GetKeysAndValues() map[string]string
+
+func (r *GPCStorageHandler) GetKeysAndValuesWithFilter(filter string) map[string]string
+
+func (r *GPCStorageHandler) GetListRange(keyName string, from, to int64) ([]string, error)
+
+func (r *GPCStorageHandler) GetMultiKey(keyNames []string) ([]string, error)
+
+func (r *GPCStorageHandler) GetPolicies(orgId string) string
+ GetPolicies retrieves policies for a given organization ID
+
+func (r *GPCStorageHandler) GetRawKey(keyName string) (string, error)
+
+func (r *GPCStorageHandler) GetRollingWindow(key string, per int64, pipeline bool) (int, []interface{})
+
+func (r *GPCStorageHandler) GetSet(keyName string) (map[string]string, error)
+
+func (r *GPCStorageHandler) GetSortedSetRange(keyName, scoreFrom, scoreTo string) ([]string, []float64, error)
+
+func (r *GPCStorageHandler) IncrememntWithExpire(keyName string, expire int64) int64
+
+func (r *GPCStorageHandler) IsRetriableError(err error) bool
+ IsRetriableError checks if the error is retriable
+
+func (r *GPCStorageHandler) Login(clientID, userKey string) bool
+ Login handles the login process for a single client
+
+func (r *GPCStorageHandler) LoginWithGroup(clientID string, groupData *apidef.GroupLoginRequest) bool
+ LoginWithGroup handles the login process for a client within a group
+
+func (r *GPCStorageHandler) Publish(channel, message string) error
+
+func (r *GPCStorageHandler) RemoveFromList(keyName string, value string) error
+
+func (r *GPCStorageHandler) RemoveFromSet(keyName string, value string)
+
+func (r *GPCStorageHandler) RemoveSortedSetRange(keyName, scoreFrom, scoreTo string) error
+
+func (r *GPCStorageHandler) SetExp(keyName string, timeout int64) error
+
+func (r *GPCStorageHandler) SetKey(keyName, session string, timeout int64) error
+
+func (r *GPCStorageHandler) SetRawKey(keyName, session string, timeout int64) error
+
+func (r *GPCStorageHandler) SetRollingWindow(keyName string, per int64, val string, pipeline bool) (int, []interface{})
+
+func (r *GPCStorageHandler) StartPubSubHandler(channel string, callback func(*temporalmodel.Message)) error
+
+func (r *GPCStorageHandler) StartRPCKeepaliveWatcher()
+
+func (r *GPCStorageHandler) StartRPCLoopCheck(orgId string)
+
type GRPCDispatcher struct {
coprocess.Dispatcher
}
@@ -8457,7 +9396,7 @@
DefaultQuotaStore DefaultSessionManager
GlobalSessionManager SessionHandler
MonitoringHandler config.TykEventHandler
- RPCListener RPCStorageHandler
+ RPCListener storage.RPCListener
DashService DashboardServiceSender
CertificateManager certs.CertificateManager
GlobalHostChecker HostCheckerManager
@@ -9117,8 +10056,6 @@
func (l *LDAPStorageHandler) DeleteRawKey(cn string) bool
-func (l *LDAPStorageHandler) DeleteRawKeys([]string) bool
-
func (l LDAPStorageHandler) DeleteScanMatch(pattern string) bool
func (l LDAPStorageHandler) Exists(keyName string) (bool, error)
@@ -9551,8 +10488,6 @@
DeleteKey will remove a key from the database without prefixing, assumes
user knows what they are doing
-func (r *RPCStorageHandler) DeleteRawKeys(keys []string) bool
-
func (r *RPCStorageHandler) DeleteScanMatch(pattern string) bool
func (r *RPCStorageHandler) Disconnect() error
@@ -11097,40 +12032,19 @@
FUNCTIONS
-func CloseConnections()
-func Connect(connConfig Config, suppressRegister bool, dispatcherFuncs map[string]interface{},
- getGroupLoginFunc func(string, string) interface{},
- emergencyModeFunc func(),
- emergencyModeLoadedFunc func()) bool
- Connect will establish a connection to the RPC server specified in
- connection options
-
-func Disconnect() bool
-func EmitErrorEvent(jobName string, funcName string, err error)
-func EmitErrorEventKv(jobName string, funcName string, err error, kv map[string]string)
func ForceConnected(t *testing.T)
ForceConnected only intended to be used in tests do not use it for any other
thing
-func FuncClientSingleton(funcName string, request interface{}) (result interface{}, err error)
- FuncClientSingleton performs RPC call. This might be called before we have
- established RPC connection, in that case we perform a retry with exponential
- backoff ensuring indeed we can't connect to the rpc, this will eventually
- fall into emergency mode( That is handled outside of this function call)
-
-func GroupLogin() bool
+func GetRPCType() string
func IsEmergencyMode() bool
-func LoadCount() int
-func Login() bool
- Login tries to login to the rpc sever. Returns true if it succeeds and false
- if it fails.
-
-func Reset()
func ResetEmergencyMode()
+func SetConnected(connected bool)
func SetEmergencyMode(t *testing.T, value bool)
SetEmergencyMode used in tests to force emergency mode
func SetLoadCounts(t *testing.T, value int)
+func SetRPCType(rpcType string)
TYPES
@@ -11148,6 +12062,43 @@
RPCPoolSize int `json:"rpc_pool_size"`
}
+type GRPCConnectionHandler struct{}
+
+func (g *GRPCConnectionHandler) CloseConnections()
+
+func (g *GRPCConnectionHandler) Connect(_ Config, _ bool, _ map[string]interface{}, _ func(string, string) interface{}, _ func(), _ func()) bool
+
+func (g *GRPCConnectionHandler) Disconnect() bool
+
+func (g *GRPCConnectionHandler) EmitErrorEvent(_ string, _ string, _ error)
+
+func (g *GRPCConnectionHandler) EmitErrorEventKv(_ string, _ string, _ error, _ map[string]string)
+
+func (g *GRPCConnectionHandler) FuncClientSingleton(_ string, _ interface{}) (interface{}, error)
+
+func (g *GRPCConnectionHandler) GroupLogin() bool
+
+func (g *GRPCConnectionHandler) LoadCount() int
+
+func (g *GRPCConnectionHandler) Login() bool
+
+func (g *GRPCConnectionHandler) Reset()
+
+type IRPCClient interface {
+ Connect(Config, bool, map[string]interface{}, func(string, string) interface{}, func(), func()) bool
+ Disconnect() bool
+ FuncClientSingleton(string, interface{}) (interface{}, error)
+ Login() bool
+ GroupLogin() bool
+ LoadCount() int
+ Reset()
+ EmitErrorEvent(string, string, error)
+ EmitErrorEventKv(string, string, error, map[string]string)
+ CloseConnections()
+}
+
+func RPC() IRPCClient
+
type Purger struct {
Store storage.Handler
}
@@ -11358,10 +12309,6 @@
DeleteRawKey removes a specified key from DummyStorage, returning success
status; not yet implemented.
-func (s *DummyStorage) DeleteRawKeys([]string) bool
- DeleteRawKeys removes a set of raw keys from DummyStorage, returning success
- status; not yet implemented.
-
func (s *DummyStorage) DeleteScanMatch(pattern string) bool
DeleteScanMatch deletes keys matching a pattern from DummyStorage, returning
true if successful.
@@ -11477,7 +12424,6 @@
DeleteKey(string) bool
DeleteAllKeys() bool
DeleteRawKey(string) bool
- DeleteRawKeys([]string) bool
Connect() bool
GetKeysAndValues() map[string]string
GetKeysAndValuesWithFilter(string) map[string]string
@@ -11528,8 +12474,6 @@
func (m MdcbStorage) DeleteRawKey(string) bool
-func (m MdcbStorage) DeleteRawKeys([]string) bool
-
func (m MdcbStorage) DeleteScanMatch(key string) bool
func (m MdcbStorage) Exists(key string) (bool, error)
@@ -11577,6 +12521,13 @@
func (m MdcbStorage) SetRollingWindow(key string, per int64, val string, pipeline bool) (int, []interface{})
+type RPCListener interface {
+ Connect() bool
+ CheckForReload(orgId string) bool
+ StartRPCKeepaliveWatcher()
+ StartRPCLoopCheck(orgId string)
+}
+
type RedisCluster struct {
KeyPrefix string
HashKeys bool
@@ -11627,8 +12578,6 @@
DeleteKey will remove a key from the database without prefixing, assumes
user knows what they are doing
-func (r *RedisCluster) DeleteRawKeys(keys []string) bool
-
func (r *RedisCluster) DeleteScanMatch(pattern string) bool
DeleteKeys will remove a group of keys in bulk
|
PR Reviewer Guide 🔍
|
PR Code Suggestions ✨
|
|
caroltyk
changed the title
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
User description
Description
See the internal PR for details on why this exists
Related Issue
This is PoC
Motivation and Context
See the other PR
How This Has Been Tested
Manual
Types of changes
Checklist
PR Type
Enhancement
Description
dispatcher/handler_grpc.pb.go.GPCStorageHandlerfor gRPC-based storage handling ingateway/grpc_storage_handler.go.gateway/rpc_storage_handler.go.rpc/rpc_client.go.gateway/server.go.GRPCConnectionHandlerinrpc/grpcHandler.go.rpc/rpc_analytics_purger.go.rpc/rpc_client_test.goandgateway/testutil.go.config/config.go.Changes walkthrough 📝
10 files
handler_grpc.pb.go
Add gRPC client and server implementationdispatcher/handler_grpc.pb.go
protoc-gen-go-grpc.HandlerClientandHandlerServerinterfaces.Login,GetKey,SetKey, etc.grpc_storage_handler.go
Implement gRPC-based storage handlergateway/grpc_storage_handler.go
GPCStorageHandlerfor gRPC-based storage handling.rpc_storage_handler.go
Add dynamic handler selection for RPC and gRPCgateway/rpc_storage_handler.go
GetRPCBackendHandlerto switch between gRPC and legacy RPChandlers.
rpc.RPC()for dynamic handlerselection.
rpc_client.go
Abstract RPC client with dynamic handler selectionrpc/rpc_client.go
IRPCClientinterface for RPC client abstraction.gorpcClientManagerandGRPCConnectionHandlerimplementations.rpc.RPC()for dynamic handler selection.server.go
Update server setup for gRPC supportgateway/server.go
GetRPCBackendHandler.grpcHandler.go
Implement gRPC connection handlerrpc/grpcHandler.go
GRPCConnectionHandler.gRPC-specific logic.
rpc_analytics_purger.go
Update analytics purger for dynamic RPC handlerrpc/rpc_analytics_purger.go
rpc.RPC()for dynamic handlerselection.
api_loader.go
Update API loader for dynamic RPC handlergateway/api_loader.go
GetRPCBackendHandlerfor dynamic handlerselection.
health_check.go
Update health checks for dynamic RPC handlergateway/health_check.go
rpc.RPC().Login()for dynamic handlerselection.
graphql_request.go
Fix syntax issues in GraphQL request handlinginternal/graphql/graphql_request.go
4 files
rpc_client_test.go
Update RPC client tests for dynamic handlerrpc/rpc_client_test.go
goRPCHandlerfor testingdoLoginWithRetries.testutil.go
Update test utilities for dynamic RPC handlergateway/testutil.go
rpc.RPC().Reset()for resetting the RPCclient.
graphql_request_test.go
Fix syntax issues in GraphQL request testsinternal/graphql/graphql_request_test.go
linter_test.go
Fix syntax issues in linter testsapidef/oas/linter_test.go
1 files
config.go
Add configuration options for gRPC supportconfig/config.go
RPCTypeandGRPCForceJSONfields inSlaveOptionsConfig.1 files
handler.pb.go
...dispatcher/handler.pb.go
...