service

package

v1.0.1 Latest Latest Go to latest Published: Nov 9, 2023 License: Apache-2.0, BSD-2-Clause, BSD-3-Clause, + 3 more Imports: 29 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/lsutils/nocalhost

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func CreateNamespaceINE(client *clientgo.GoClient, ns string) error
func CreateOrUpdateClusterRoleBindingINE(client *clientgo.GoClient, saName, saNs, crb, role string) error
func CreateOrUpdateRoleBindingINE(client *clientgo.GoClient, ns, saName, saNs, rb, role string) error
func CreateUsers(ctx context.Context, list []*model.UserBaseModel) int
func CronJobTrigger()
func Init()
func RemoveClusterRoleBindingIfPresent(client *clientgo.GoClient, saName, saNs, crb string) error
func RemoveRoleBindingIfPresent(client *clientgo.GoClient, ns, saName, saNs, rb string) error
func StartJob()
func ToMailMapping(es []*ldap.Entry, emailAttr string) map[string]*ldap.Entry
type Report
- func DoSyncFromLDAP(ctx context.Context, ldapServer string, tls, md5 bool, ldapGen uint64, ...) (*Report, error)
- func (r *Report) ActivateSync(deletes, inserts, updates int)
- func (r *Report) Sum(r1 *Report)
type Service
- func New() (s *Service)

Constants ¶

This section is empty.

Variables ¶

View Source

var IDLE = "IDLE"

View Source

var RUNNING = "RUNNING"

Functions ¶

func CreateNamespaceINE ¶

func CreateNamespaceINE(client *clientgo.GoClient, ns string) error

func CreateOrUpdateClusterRoleBindingINE ¶

func CreateOrUpdateClusterRoleBindingINE(client *clientgo.GoClient, saName, saNs, crb, role string) error

func CreateOrUpdateRoleBindingINE ¶

func CreateOrUpdateRoleBindingINE(client *clientgo.GoClient, ns, saName, saNs, rb, role string) error

nocalhost use nocalhost-saName for role binding storage container and nocalhost create a role binding for each dev space

func CreateUsers ¶

func CreateUsers(ctx context.Context, list []*model.UserBaseModel) int

func CronJobTrigger ¶

func CronJobTrigger()

func Init ¶

func Init()

func RemoveClusterRoleBindingIfPresent ¶

func RemoveClusterRoleBindingIfPresent(client *clientgo.GoClient, saName, saNs, crb string) error

func RemoveRoleBindingIfPresent ¶

func RemoveRoleBindingIfPresent(client *clientgo.GoClient, ns, saName, saNs, rb string) error

func StartJob ¶

func StartJob()

func ToMailMapping ¶

func ToMailMapping(es []*ldap.Entry, emailAttr string) map[string]*ldap.Entry

Types ¶

type Report ¶

type Report struct {
	Entries int
	Inserts int
	Updates int
	Deletes int
	Fails   int
	Costs   int64
}

func DoSyncFromLDAP ¶

func DoSyncFromLDAP(ctx context.Context, ldapServer string, tls, md5 bool, ldapGen uint64, username, password string,
	baseDN, filter,
	adminBaseDn, adminFilter,
	emailAttr, userNameAttr string) (*Report, error)

func (*Report) ActivateSync ¶

func (r *Report) ActivateSync(deletes, inserts, updates int)

We generally only care about valid updates, so if these three are 0, then the last valid update data is taken

func (*Report) Sum ¶

func (r *Report) Sum(r1 *Report)

type Service ¶

type Service struct {
	UserSvc               *user.User
	ClusterSvc            *cluster.Cluster
	ApplicationSvc        *application.Application
	ApplicationClusterSvc *application_cluster.ApplicationCluster
	ClusterUserSvc        *cluster_user.ClusterUser
	PrePullSvc            *pre_pull.PrePull
	ApplicationUserSvc    *application_user.ApplicationUser
	LdapSvc               *ldap.Ldap
}

Service struct

var (
	// Svc global service var
	Svc *Service
)

func New ¶

func New() (s *Service)

New init service

func (*Service) AuthorizeClusterToUser ¶

func (s *Service) AuthorizeClusterToUser(clusterId, userId uint64) error

func (*Service) AuthorizeNsToDefaultSa ¶

func (s *Service) AuthorizeNsToDefaultSa(clusterId, userId uint64, ns string) error

func (*Service) AuthorizeNsToUser ¶

func (s *Service) AuthorizeNsToUser(clusterId, userId uint64, ns string) error

func (*Service) Close ¶

func (s *Service) Close()

Close service

func (*Service) Ping ¶

func (s *Service) Ping() error

Ping service

func (*Service) PrepareServiceAccountAndClientGo ¶

func (s *Service) PrepareServiceAccountAndClientGo(clusterId, userId uint64) (
	clientGo *clientgo.GoClient, saName string, err error,
)

func (*Service) UnAuthorizeClusterToUser ¶

func (s *Service) UnAuthorizeClusterToUser(clusterId, userId uint64) error

func (*Service) UnAuthorizeNsToUser ¶

func (s *Service) UnAuthorizeNsToUser(clusterId, userId uint64, ns string) error

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
application
application_cluster
application_user
cluster
cluster_user
cooperator
cluster_scope
ns_scope
util
ldap
pre_pull
user

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