service

package

Go to main page

Versions in this module

v1

v1.0.0

Jul 1, 2022

Changes in this version

+ const TypeAuthExternal

+ const TypeAuthInternal

+ const TypeProviderOIDC

+ func ExtraConfigKey(key string) string

+ func InitUserRoleCollector(db *gorm.DB)

+ func NewCollectValue(val *structpb.Value) (*tdtl.Collect, error)

+ func NewStructValue(cc *tdtl.Collect) *structpb.Value

type ConfigService

+ func (s *ConfigService) DelPlatformConfig(ctx context.Context, req *pb.PlatformConfigRequest) (*structpb.Value, error)

+ func (s *ConfigService) GetPlatformConfig(ctx context.Context, req *pb.PlatformConfigRequest) (*structpb.Value, error)

+ func (s *ConfigService) SetPlatformExtraConfig(ctx context.Context, req *pb.SetPlatformExtraConfigRequest) (*structpb.Value, error)

type EToken

+ TenantID string

+ type MetricsService struct

+ MetricsHandler http.Handler

+ func NewMetricsService(mtrCollectors ...prometheus.Collector) *MetricsService

+ func (svc *MetricsService) Metrics(req *go_restful.Request, resp *go_restful.Response)

type OauthService

+ RBACOp *casbin.SyncedEnforcer

+ func (s *OauthService) GetIdentityProvider(ctx context.Context, req *pb.GetIdentityProviderRequest) (*pb.GetIdentityProviderResponse, error)

+ func (s *OauthService) IdentityProviderRegister(ctx context.Context, req *pb.IdProviderRegisterRequest) (*pb.IdProviderRegisterResponse, error)

+ func (s *OauthService) IdentityProviderTemplate(ctx context.Context, req *pb.IdProviderTemplateRequest) (*pb.IdProviderTemplateResponse, error)

type PluginServiceV1

+ func (s *PluginServiceV1) TMRegisterPlugin(ctx context.Context, req *pb.TMRegisterPluginRequest) (*emptypb.Empty, error)

+ func (s *PluginServiceV1) TMTenantDisable(ctx context.Context, req *pb.TMTenantDisableRequest) (*emptypb.Empty, error)

+ func (s *PluginServiceV1) TMTenantEnable(ctx context.Context, req *pb.TMTenantEnableRequest) (*emptypb.Empty, error)

+ func (s *PluginServiceV1) UpgradePlugin(ctx context.Context, req *pb.UpgradePluginRequest) (*pb.UpgradePluginResponse, error)

+ type ProfileService struct

+ ProfileOp plgprofile.ProfileOperator

+ func NewProfileService(plgOp plugin.Operator, profileOp plgprofile.ProfileOperator, ...) *ProfileService

+ func (s *ProfileService) GetProfileSchema(ctx context.Context, request *pb.GetProfileSchemaRequest) (*pb.GetProfileSchemaResponse, error)

+ func (s *ProfileService) GetTenantProfileData(ctx context.Context, request *pb.GetTenantProfileDataRequest) (*pb.GetTenantProfileDataResponse, error)

+ func (s *ProfileService) SetTenantProfileData(ctx context.Context, request *pb.SetTenantPluginProfileRequest) (*pb.SetTenantPluginProfileResponse, error)

type TenantService

+ DaprClient dapr.Client

+ DaprStore string

v0

v0.4.1

Mar 6, 2022

v0.4.0

Mar 4, 2022

Changes in this version

+ const DefaultClient

+ const DefaultClientDomain

+ const DefaultClientSecurity

+ const TokenTypeBearer

+ var DefaultGrantType = []oauth2v4.GrantType

+ func KeyOfTenantIdentityProvider(tenantID string) string

+ func ProviderRegister(ctx context.Context, data []byte) error

+ type AuthenticationService struct

+ func NewAuthenticationService(m *manage.Manager, userDB *gorm.DB, conf *TokenConf, ...) *AuthenticationService

+ func (s *AuthenticationService) Authenticate(ctx context.Context, req *pb.AuthenticateRequest) (*pb.AuthenticateResponse, error)

+ type AuthorizeRequest struct

+ AccessTokenExp time.Duration

+ ClientID string

+ CodeChallenge string

+ CodeChallengeMethod oauth2v4.CodeChallengeMethod

+ RedirectURI string

+ Request *http.Request

+ ResponseType oauth2v4.ResponseType

+ Scope string

+ State string

+ UserID string

+ type ConfigService struct

+ func NewConfigService(k8s *kubernetes.Client) *ConfigService

+ func (s *ConfigService) GetDeploymentConfig(ctx context.Context, req *emptypb.Empty) (*pb.GetDeploymentConfigResponse, error)

+ type EToken struct

+ CreatedAt int64

+ EntityID string

+ EntityType string

+ ExpiredAt int64

+ Owner string

+ func (token *EToken) MD5ID(i *int) string

+ type EntityTokenService struct

+ EntityTokenOp TokenOperator

+ func NewEntityTokenService(operator TokenOperator) *EntityTokenService

+ func (s *EntityTokenService) CreateEntityToken(ctx context.Context, req *pb.CreateEntityTokenRequest) (*pb.CreateEntityTokenResponse, error)

+ func (s *EntityTokenService) DeleteEntityToken(ctx context.Context, req *pb.TokenInfoRequest) (*emptypb.Empty, error)

+ func (s *EntityTokenService) TokenInfo(ctx context.Context, req *pb.TokenInfoRequest) (*pb.TokenInfoResponse, error)

type Oauth2ServiceV1

+ func (s *Oauth2ServiceV1) UpdateAdminPassword(ctx context.Context, req *pb.UpdateAdminPasswordRequest) (*emptypb.Empty, error)

+ func (s *Oauth2ServiceV1) VerifyToken(ctx context.Context, empty *emptypb.Empty) (*emptypb.Empty, error)

+ type OauthService struct

+ Config *TokenConf

+ DaprClient dapr.Client

+ DaprStore string

+ Manager *manage.Manager

+ UserDB *gorm.DB

+ func NewOauthService(m *manage.Manager, userDB *gorm.DB, conf *TokenConf, daprClient dapr.Client, ...) *OauthService

+ func (s *OauthService) Authenticate(ctx context.Context, empty *emptypb.Empty) (*pb.AuthenticateResponse, error)

+ func (s *OauthService) Authorize(ctx context.Context, req *pb.AuthorizeRequest) (*pb.AuthorizeResponse, error)

+ func (s *OauthService) CheckGrantType(gt oauth2v4.GrantType) bool

+ func (s *OauthService) GetAccessToken(ctx context.Context, gt oauth2v4.GrantType, tgr *oauth2v4.TokenGenerateRequest) (oauth2v4.TokenInfo, error)

+ func (s *OauthService) GetAuthorizeToken(ctx context.Context, req *AuthorizeRequest) (oauth2v4.TokenInfo, error)

+ func (s *OauthService) OIDCRegister(ctx context.Context, req *pb.OIDCRegisterRequest) (*pb.OIDCRegisterResponse, error)

+ func (s *OauthService) ResetPassword(ctx context.Context, req *pb.ResetPasswordRequest) (*pb.ResetPasswordResponse, error)

+ func (s *OauthService) Token(ctx context.Context, req *pb.TokenRequest) (*pb.TokenResponse, error)

+ func (s *OauthService) TokenRevoke(ctx context.Context, req *pb.TokenRevokeRequest) (*pb.TokenRevokeResponse, error)

+ func (s *OauthService) UpdatePassword(ctx context.Context, req *pb.UpdatePasswordRequest) (*pb.UpdatePasswordResponse, error)

+ func (s *OauthService) ValidationTokenRequest(r *pb.TokenRequest) (oauth2v4.GrantType, *oauth2v4.TokenGenerateRequest, error)

type PluginServiceV1

+ func (s *PluginServiceV1) ListEnabledTenants(ctx context.Context, req *pb.ListEnabledTenantsRequest) (*pb.ListEnabledTenantsResponse, error)

+ func (s *PluginServiceV1) TMUpdatePluginIdentify(ctx context.Context, req *pb.TMUpdatePluginIdentifyRequest) (*emptypb.Empty, error)

+ func (s *PluginServiceV1) TenantDisable(ctx context.Context, req *pb.TenantDisableRequest) (*emptypb.Empty, error)

+ func (s *PluginServiceV1) TenantEnable(ctx context.Context, req *pb.TenantEnableRequest) (*emptypb.Empty, error)

+ type RBACService struct

+ func NewRBACService(db *gorm.DB, rbac *casbin.SyncedEnforcer, tenantPluginOp rbac.TenantPluginMgr) *RBACService

+ func (s *RBACService) CheckRolePermission(ctx context.Context, req *pb.CheckRolePermissionRequest) (*pb.CheckRolePermissionResponse, error)

+ func (s *RBACService) CreateRoleBinding(ctx context.Context, req *pb.CreateRoleBindingRequest) (*emptypb.Empty, error)

+ func (s *RBACService) CreateRoles(ctx context.Context, req *pb.CreateRoleRequest) (*pb.CreateRoleResponse, error)

+ func (s *RBACService) DeleteRole(ctx context.Context, req *pb.DeleteRoleRequest) (*pb.DeleteRoleResponse, error)

+ func (s *RBACService) DeleteRoleBinding(ctx context.Context, req *pb.DeleteRoleBindingRequest) (*emptypb.Empty, error)

+ func (s *RBACService) GetRole(ctx context.Context, req *pb.GetRoleRequest) (*pb.GetRoleResponse, error)

+ func (s *RBACService) ListPermissions(ctx context.Context, req *pb.ListPermissionRequest) (*pb.ListPermissionResponse, error)

+ func (s *RBACService) ListRole(ctx context.Context, req *pb.ListRolesRequest) (*pb.ListRolesResponse, error)

+ func (s *RBACService) TMAddPolicy(ctx context.Context, req *pb.TMPolicyRequest) (*emptypb.Empty, error)

+ func (s *RBACService) TMAddRoleBinding(ctx context.Context, req *pb.TMRoleBindingRequest) (*emptypb.Empty, error)

+ func (s *RBACService) TMDeletePolicy(ctx context.Context, req *pb.TMPolicyRequest) (*emptypb.Empty, error)

+ func (s *RBACService) TMDeleteRoleBinding(ctx context.Context, req *pb.TMRoleBindingRequest) (*emptypb.Empty, error)

+ func (s *RBACService) UpdateRole(ctx context.Context, req *pb.UpdateRoleRequest) (*pb.UpdateRoleResponse, error)

+ func (s *RBACService) UpdateUserRoleBinding(ctx context.Context, req *pb.UpdateUserRoleBindingRequest) (*emptypb.Empty, error)

type RepoService

+ func (s *RepoService) ListAllRepoInstaller(ctx context.Context, req *pb.ListAllRepoInstallerRequest) (*pb.ListAllRepoInstallerResponse, error)

+ type TenantService struct

+ DB *gorm.DB

+ RBACOp *casbin.SyncedEnforcer

+ TenantPluginOp rbac.TenantPluginMgr

+ func NewTenantService(db *gorm.DB, tenantPluginOp rbac.TenantPluginMgr, ...) *TenantService

+ func (s *TenantService) AddTenantPlugin(ctx context.Context, req *pb.AddTenantPluginRequest) (*pb.AddTenantPluginResponse, error)

+ func (s *TenantService) CreateTenant(ctx context.Context, req *pb.CreateTenantRequest) (*pb.CreateTenantResponse, error)

+ func (s *TenantService) CreateUser(ctx context.Context, req *pb.CreateUserRequest) (*pb.CreateUserResponse, error)

+ func (s *TenantService) DeleteTenant(ctx context.Context, req *pb.DeleteTenantRequest) (*emptypb.Empty, error)

+ func (s *TenantService) DeleteTenantPlugin(ctx context.Context, req *pb.DeleteTenantPluginRequest) (*pb.DeleteTenantPluginResponse, error)

+ func (s *TenantService) DeleteUser(ctx context.Context, req *pb.DeleteUserRequest) (*emptypb.Empty, error)

+ func (s *TenantService) GetResetPasswordKey(ctx context.Context, req *pb.GetResetPasswordKeyRequest) (*pb.GetResetPasswordKeyResponse, error)

+ func (s *TenantService) GetTenant(ctx context.Context, req *pb.GetTenantRequest) (*pb.GetTenantResponse, error)

+ func (s *TenantService) GetUser(ctx context.Context, req *pb.GetUserRequest) (*pb.GetUserResponse, error)

+ func (s *TenantService) ListTenant(ctx context.Context, req *pb.ListTenantRequest) (*pb.ListTenantResponse, error)

+ func (s *TenantService) ListTenantPlugin(ctx context.Context, req *pb.ListTenantPluginRequest) (*pb.ListTenantPluginResponse, error)

+ func (s *TenantService) ListUser(ctx context.Context, req *pb.ListUserRequest) (*pb.ListUserResponse, error)

+ func (s *TenantService) ResetPasswordKeyInfo(ctx context.Context, req *pb.RPKInfoRequest) (*pb.RPKInfoResponse, error)

+ func (s *TenantService) TenantByExactSearch(ctx context.Context, req *pb.ExactTenantRequest) (*pb.ExactTenantResponse, error)

+ func (s *TenantService) TenantPluginPermissible(ctx context.Context, req *pb.PluginPermissibleRequest) (*pb.PluginPermissibleResponse, error)

+ func (s *TenantService) UpdateTenant(ctx context.Context, req *pb.UpdateTenantRequest) (*pb.UpdateTenantResponse, error)

+ func (s *TenantService) UpdateUser(ctx context.Context, req *pb.UpdateUserRequest) (*pb.UpdateUserResponse, error)

+ type TokenConf struct

+ AccessTokenExp time.Duration

+ AllowedGrantTypes []oauth2v4.GrantType

+ RefreshTokenExp time.Duration

+ TokenType string

+ type TokenOp struct

+ func NewEntityTokenOperator(storeName string, client dapr.Client) *TokenOp

+ func (e *TokenOp) CreateToken(ctx context.Context, entity *EToken) (token string, err error)

+ func (e *TokenOp) DeleteToken(ctx context.Context, key string) (err error)

+ func (e *TokenOp) GetEntityInfo(ctx context.Context, key string) (entity *EToken, err error)

+ type TokenOperator interface

+ CreateToken func(ctx context.Context, entity *EToken) (token string, err error)

+ DeleteToken func(ctx context.Context, token string) (err error)

+ GetEntityInfo func(ctx context.Context, token string) (entity *EToken, err error)

v0.3.0

Jan 7, 2022

Changes in this version

+ const AuthorizationHeader

+ var ErrNotActiveUpstream = errors.New("not active upstream plugin")

+ var ErrNotFoundAddons = errors.New("not found addons")

+ var ErrNotFoundUpstream = errors.New("not found upstream plugin")

+ type EntryService struct

+ func NewEntryService(kvOp kv.Operator, pOp plugin.Operator) *EntryService

+ func (s *EntryService) GetEntries(ctx context.Context, req *emptypb.Empty) (*pb.GetEntriesResponse, error)

+ type KeelServiceV1 struct

+ func NewKeelServiceV1(interval string, conf *config.Configuration, client t_dapr.Client, ...) *KeelServiceV1

+ func (s *KeelServiceV1) Filter() restful.FilterFunction

+ func (s *KeelServiceV1) ProxyAddons(resp http.ResponseWriter, req *http.Request) error

+ func (s *KeelServiceV1) ProxyCore(resp http.ResponseWriter, req *http.Request) error

+ func (s *KeelServiceV1) ProxyPlugin(resp http.ResponseWriter, req *http.Request) error

+ func (s *KeelServiceV1) ProxyRudder(resp http.ResponseWriter, req *http.Request) error

+ func (s *KeelServiceV1) ProxySecurity(resp http.ResponseWriter, req *http.Request) error

type Oauth2ServiceV1

+ func (s *Oauth2ServiceV1) AddPluginWhiteList(ctx context.Context, req *pb.AddPluginWhiteListRequest) (*emptypb.Empty, error)

+ func (s *Oauth2ServiceV1) IssueAdminToken(ctx context.Context, req *pb.IssueAdminTokenRequest) (*pb.IssueTokenResponse, error)

+ func (s *Oauth2ServiceV1) IssuePluginToken(ctx context.Context, req *pb.IssuePluginTokenRequest) (*pb.IssueTokenResponse, error)

type PluginServiceV1

+ func (s *PluginServiceV1) BindTenants(ctx context.Context, req *pb.BindTenantsRequest) (*emptypb.Empty, error)

+ func (s *PluginServiceV1) InstallPlugin(ctx context.Context, req *pb.InstallPluginRequest) (*pb.InstallPluginResponse, error)

+ func (s *PluginServiceV1) ListBindTenants(ctx context.Context, req *pb.ListBindTenantsRequest) (*pb.ListBindTenantsResponse, error)

+ func (s *PluginServiceV1) UnbindTenants(ctx context.Context, req *pb.UnbindTenantsRequest) (*emptypb.Empty, error)

+ func (s *PluginServiceV1) UninstallPlugin(ctx context.Context, req *pb.UninstallPluginRequest) (*pb.UninstallPluginResponse, error)

+ func (s *PluginServiceV1) UnregisterPlugin(ctx context.Context, req *pb.UnregisterPluginRequest) (*pb.UnregisterPluginResponse, error)

+ type RepoService struct

+ func NewRepoService() *RepoService

+ func (s *RepoService) CreateRepo(ctx context.Context, req *pb.CreateRepoRequest) (*emptypb.Empty, error)

+ func (s *RepoService) DeleteRepo(ctx context.Context, req *pb.DeleteRepoRequest) (*pb.DeleteRepoResponse, error)

+ func (s *RepoService) GetRepoInstaller(ctx context.Context, req *pb.GetRepoInstallerRequest) (*pb.GetRepoInstallerResponse, error)

+ func (s *RepoService) ListRepo(ctx context.Context, req *emptypb.Empty) (*pb.ListRepoResponse, error)

+ func (s *RepoService) ListRepoInstaller(ctx context.Context, req *pb.ListRepoInstallerRequest) (*pb.ListRepoInstallerResponse, error)

v0.2.0

Nov 30, 2021

Changes in this version

+ var ErrGetOpenapiIdentify = errors.New("error get openapi identify")

+ var ErrPluginRegistered = errors.New("plugin is registered")

+ var ErrSecretNotMatch = errors.New("secret not match")

+ type Oauth2ServiceV1 struct

+ func NewOauth2ServiceV1(secret string, pluginOperator plugin.Operator) *Oauth2ServiceV1

+ func (s *Oauth2ServiceV1) AddWhiteList(ctx context.Context, req *pb.AddWhiteListRequest) (*emptypb.Empty, error)

+ func (s *Oauth2ServiceV1) IssueOauth2Token(ctx context.Context, req *pb.IssueOauth2TokenRequest) (*pb.IssueOauth2TokenResponse, error)

+ type PluginServiceV1 struct

+ func NewPluginServiceV1(conf *config.TkeelConf, pluginOperator plugin.Operator, ...) *PluginServiceV1

+ func (s *PluginServiceV1) DeletePlugin(ctx context.Context, req *pb.DeletePluginRequest) (*pb.DeletePluginResponse, error)

+ func (s *PluginServiceV1) GetPlugin(ctx context.Context, req *pb.GetPluginRequest) (*pb.GetPluginResponse, error)

+ func (s *PluginServiceV1) ListPlugin(ctx context.Context, req *emptypb.Empty) (*pb.ListPluginResponse, error)

+ func (s *PluginServiceV1) RegisterPlugin(ctx context.Context, req *pb.RegisterPluginRequest) (retResp *emptypb.Empty, err error)

+ type ProxyServiceV1 struct

+ func NewProxyServiceV1(interval string, conf *config.ProxyConf, client t_dapr.Client, ...) *ProxyServiceV1

+ func (s *ProxyServiceV1) ProxyCore(ctx context.Context, resp http.ResponseWriter, req *http.Request) error

+ func (s *ProxyServiceV1) ProxyPlugin(ctx context.Context, resp http.ResponseWriter, req *proxy.Reqeust) error

+ func (s *ProxyServiceV1) ProxyRudder(ctx context.Context, resp http.ResponseWriter, req *http.Request) error

+ func (s *ProxyServiceV1) ProxySecurity(ctx context.Context, resp http.ResponseWriter, req *http.Request) error

+ func (s *ProxyServiceV1) Watch(ctx context.Context, cb func(ppm model.PluginProxyRouteMap) error) error

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL