repo

Documentation

Index

• type SysAccountRepo
  • func NewAuthRepo(l logging.Logger, db *coredb.CoreDB, cfg *service.SysAccountConfig, ...) (*SysAccountRepo, error)
  • func (ad *SysAccountRepo) AssignAccountToRole(ctx context.Context, in *rpc.AssignAccountToRoleRequest) (*rpc.Account, error)
  • func (ad *SysAccountRepo) DefaultInterceptor(ctx context.Context) (context.Context, error)
  • func (ad *SysAccountRepo) DeleteAccount(ctx context.Context, in *rpc.DisableAccountRequest) (*emptypb.Empty, error)
  • func (ad *SysAccountRepo) DeleteOrg(ctx context.Context, in *rpc.IdRequest) (*emptypb.Empty, error)
  • func (ad *SysAccountRepo) DeleteProject(ctx context.Context, in *rpc.IdRequest) (*emptypb.Empty, error)
  • func (ad *SysAccountRepo) DisableAccount(ctx context.Context, in *rpc.DisableAccountRequest) (*rpc.Account, error)
  • func (ad *SysAccountRepo) ForgotPassword(ctx context.Context, in *rpc.ForgotPasswordRequest) (*rpc.ForgotPasswordResponse, error)
  • func (ad *SysAccountRepo) GetAccount(ctx context.Context, in *rpc.IdRequest) (*rpc.Account, error)
  • func (ad *SysAccountRepo) GetAuthenticatedRoutes() map[string]func(claims sharedAuth.TokenClaims) error
  • func (ad *SysAccountRepo) GetLogger() logging.Logger
  • func (ad *SysAccountRepo) GetOrg(ctx context.Context, in *rpc.IdRequest) (*rpc.Org, error)
  • func (ad *SysAccountRepo) GetProject(ctx context.Context, in *rpc.IdRequest) (*rpc.Project, error)
  • func (ad *SysAccountRepo) GetTokenConfig() *sharedAuth.TokenConfig
  • func (ad *SysAccountRepo) GetUnauthenticatedRoutes() []string
  • func (ad *SysAccountRepo) ListAccounts(ctx context.Context, in *rpc.ListAccountsRequest) (*rpc.ListAccountsResponse, error)
  • func (ad *SysAccountRepo) ListNonSubscribedOrgs(ctx context.Context, in *rpc.ListRequest) (*rpc.ListResponse, error)
  • func (ad *SysAccountRepo) ListOrg(ctx context.Context, in *rpc.ListRequest) (*rpc.ListResponse, error)
  • func (ad *SysAccountRepo) ListProject(ctx context.Context, in *rpc.ListRequest) (*rpc.ListResponse, error)
  • func (ad *SysAccountRepo) Login(ctx context.Context, in *rpc.LoginRequest) (*rpc.LoginResponse, error)
  • func (ad *SysAccountRepo) NewAccount(ctx context.Context, in *rpc.AccountNewRequest) (*rpc.Account, error)
  • func (ad *SysAccountRepo) NewOrg(ctx context.Context, in *rpc.OrgRequest) (*rpc.Org, error)
  • func (ad *SysAccountRepo) NewProject(ctx context.Context, in *rpc.ProjectRequest) (*rpc.Project, error)
  • func (ad *SysAccountRepo) ObtainAccessClaimsFromMetadata(ctx context.Context, isAccess bool) (claims sharedAuth.TokenClaims, err error)
  • func (ad *SysAccountRepo) RefreshAccessToken(ctx context.Context, in *rpc.RefreshAccessTokenRequest) (*rpc.RefreshAccessTokenResponse, error)
  • func (ad *SysAccountRepo) Register(ctx context.Context, in *rpc.RegisterRequest) (*rpc.RegisterResponse, error)
  • func (ad *SysAccountRepo) ResetPassword(ctx context.Context, in *rpc.ResetPasswordRequest) (*rpc.ResetPasswordResponse, error)
  • func (ad *SysAccountRepo) SearchAccounts(ctx context.Context, in *rpc.SearchAccountsRequest) (*rpc.SearchAccountsResponse, error)
  • func (ad *SysAccountRepo) UpdateAccount(ctx context.Context, in *rpc.AccountUpdateRequest) (*rpc.Account, error)
  • func (ad *SysAccountRepo) UpdateOrg(ctx context.Context, in *rpc.OrgUpdateRequest) (*rpc.Org, error)
  • func (ad *SysAccountRepo) UpdateProject(ctx context.Context, in *rpc.ProjectUpdateRequest) (*rpc.Project, error)
  • func (ad *SysAccountRepo) VerifyAccount(ctx context.Context, in *rpc.VerifyAccountRequest) (*emptypb.Empty, error)

Types

type SysAccountRepo

type SysAccountRepo struct {
	*rpc.UnimplementedAccountServiceServer
	*rpc.UnimplementedAuthServiceServer
	*rpc.UnimplementedOrgProjServiceServer
	// contains filtered or unexported fields
}

SysAccountRepo is the repository layer of the authn & authz && accounts

func NewAuthRepo

func NewAuthRepo(l logging.Logger, db *coredb.CoreDB, cfg *service.SysAccountConfig, bus *corebus.CoreBus, mail *coremail.MailSvc, frepo *corefile.SysFileRepo, domain string, superUserFilePath string, bizmetrics *telemetry.SysAccountMetrics) (*SysAccountRepo, error)

func (*SysAccountRepo) AssignAccountToRole

func (ad *SysAccountRepo) AssignAccountToRole(ctx context.Context, in *rpc.AssignAccountToRoleRequest) (*rpc.Account, error)

func (*SysAccountRepo) DefaultInterceptor

func (ad *SysAccountRepo) DefaultInterceptor(ctx context.Context) (context.Context, error)

DefaultInterceptor is default authN/authZ interceptor, validates only token & claims correctness without performing any role specific authorization.

func (*SysAccountRepo) DeleteAccount

func (ad *SysAccountRepo) DeleteAccount(ctx context.Context, in *rpc.DisableAccountRequest) (*emptypb.Empty, error)

func (*SysAccountRepo) DeleteOrg

func (ad *SysAccountRepo) DeleteOrg(ctx context.Context, in *rpc.IdRequest) (*emptypb.Empty, error)

func (*SysAccountRepo) DeleteProject

func (ad *SysAccountRepo) DeleteProject(ctx context.Context, in *rpc.IdRequest) (*emptypb.Empty, error)

func (*SysAccountRepo) DisableAccount

func (ad *SysAccountRepo) DisableAccount(ctx context.Context, in *rpc.DisableAccountRequest) (*rpc.Account, error)

func (*SysAccountRepo) ForgotPassword

func (ad *SysAccountRepo) ForgotPassword(ctx context.Context, in *rpc.ForgotPasswordRequest) (*rpc.ForgotPasswordResponse, error)

func (*SysAccountRepo) GetAccount

func (ad *SysAccountRepo) GetAccount(ctx context.Context, in *rpc.IdRequest) (*rpc.Account, error)

func (*SysAccountRepo) GetAuthenticatedRoutes

func (ad *SysAccountRepo) GetAuthenticatedRoutes() map[string]func(claims sharedAuth.TokenClaims) error

func (*SysAccountRepo) GetLogger

func (ad *SysAccountRepo) GetLogger() logging.Logger

func (*SysAccountRepo) GetOrg

func (ad *SysAccountRepo) GetOrg(ctx context.Context, in *rpc.IdRequest) (*rpc.Org, error)

func (*SysAccountRepo) GetProject

func (ad *SysAccountRepo) GetProject(ctx context.Context, in *rpc.IdRequest) (*rpc.Project, error)

func (*SysAccountRepo) GetTokenConfig

func (ad *SysAccountRepo) GetTokenConfig() *sharedAuth.TokenConfig

func (*SysAccountRepo) GetUnauthenticatedRoutes

func (ad *SysAccountRepo) GetUnauthenticatedRoutes() []string

Satisfies sharedAuth.ServerAuuthzInterceptor

func (*SysAccountRepo) ListAccounts

func (ad *SysAccountRepo) ListAccounts(ctx context.Context, in *rpc.ListAccountsRequest) (*rpc.ListAccountsResponse, error)

func (*SysAccountRepo) ListNonSubscribedOrgs

func (ad *SysAccountRepo) ListNonSubscribedOrgs(ctx context.Context, in *rpc.ListRequest) (*rpc.ListResponse, error)

func (*SysAccountRepo) ListOrg

func (ad *SysAccountRepo) ListOrg(ctx context.Context, in *rpc.ListRequest) (*rpc.ListResponse, error)

func (*SysAccountRepo) ListProject

func (ad *SysAccountRepo) ListProject(ctx context.Context, in *rpc.ListRequest) (*rpc.ListResponse, error)

func (*SysAccountRepo) Login

func (ad *SysAccountRepo) Login(ctx context.Context, in *rpc.LoginRequest) (*rpc.LoginResponse, error)

func (*SysAccountRepo) NewAccount

func (ad *SysAccountRepo) NewAccount(ctx context.Context, in *rpc.AccountNewRequest) (*rpc.Account, error)

func (*SysAccountRepo) NewOrg

func (ad *SysAccountRepo) NewOrg(ctx context.Context, in *rpc.OrgRequest) (*rpc.Org, error)

func (*SysAccountRepo) NewProject

func (ad *SysAccountRepo) NewProject(ctx context.Context, in *rpc.ProjectRequest) (*rpc.Project, error)

func (*SysAccountRepo) ObtainAccessClaimsFromMetadata

func (ad *SysAccountRepo) ObtainAccessClaimsFromMetadata(ctx context.Context, isAccess bool) (claims sharedAuth.TokenClaims, err error)

ObtainAccessClaimsFromMetadata obtains token claims from given context with gRPC metadata.

func (*SysAccountRepo) RefreshAccessToken

func (ad *SysAccountRepo) RefreshAccessToken(ctx context.Context, in *rpc.RefreshAccessTokenRequest) (*rpc.RefreshAccessTokenResponse, error)

func (*SysAccountRepo) Register

func (ad *SysAccountRepo) Register(ctx context.Context, in *rpc.RegisterRequest) (*rpc.RegisterResponse, error)

Register satisfies rpc.Register function on AuthService proto definition

func (*SysAccountRepo) ResetPassword

func (ad *SysAccountRepo) ResetPassword(ctx context.Context, in *rpc.ResetPasswordRequest) (*rpc.ResetPasswordResponse, error)

func (*SysAccountRepo) SearchAccounts

func (ad *SysAccountRepo) SearchAccounts(ctx context.Context, in *rpc.SearchAccountsRequest) (*rpc.SearchAccountsResponse, error)

TODO @gutterbacon: In the absence of actual enforcement policy function, this method is a stub. We allow everyone to query anything at this point.

func (*SysAccountRepo) UpdateAccount

func (ad *SysAccountRepo) UpdateAccount(ctx context.Context, in *rpc.AccountUpdateRequest) (*rpc.Account, error)

func (*SysAccountRepo) UpdateOrg

func (ad *SysAccountRepo) UpdateOrg(ctx context.Context, in *rpc.OrgUpdateRequest) (*rpc.Org, error)

func (*SysAccountRepo) UpdateProject

func (ad *SysAccountRepo) UpdateProject(ctx context.Context, in *rpc.ProjectUpdateRequest) (*rpc.Project, error)

func (*SysAccountRepo) VerifyAccount

func (ad *SysAccountRepo) VerifyAccount(ctx context.Context, in *rpc.VerifyAccountRequest) (*emptypb.Empty, error)