usersync

Documentation

Index

• Variables
• type Run
  • func (r *Run) CorrelationID() uuid.UUID
  • func (r *Run) Error() error
  • func (r *Run) Finish()
  • func (r *Run) FinishWithError(err error)
  • func (r *Run) FinishedAt() *time.Time
  • func (r *Run) StartedAt() time.Time
  • func (r *Run) Status() RunStatus
• type RunStatus
• type RunsHandler
  • func NewRunsHandler(maxEntries int) *RunsHandler
  • func (r *RunsHandler) GetRuns() []*Run
  • func (r *RunsHandler) StartNewRun(correlationID uuid.UUID) *Run
• type UserSynchronizer
  • func New(database db.Database, auditLogger auditlogger.AuditLogger, ...) *UserSynchronizer
  • func NewFromConfig(cfg *config.Config, database db.Database, log logger.Logger, ...) (*UserSynchronizer, error)
  • func (s *UserSynchronizer) Sync(ctx context.Context, correlationID uuid.UUID) error

Variables

var DefaultRoleNames = []sqlc.RoleName{
	sqlc.RoleNameTeamcreator,
	sqlc.RoleNameTeamviewer,
	sqlc.RoleNameUserviewer,
	sqlc.RoleNameServiceaccountcreator,
}

Types

type Run

type Run struct {
	// contains filtered or unexported fields
}

func (*Run) CorrelationID

func (r *Run) CorrelationID() uuid.UUID

func (*Run) Error

func (r *Run) Error() error

func (*Run) Finish

func (r *Run) Finish()

func (*Run) FinishWithError

func (r *Run) FinishWithError(err error)

func (*Run) FinishedAt

func (r *Run) FinishedAt() *time.Time

func (*Run) StartedAt

func (r *Run) StartedAt() time.Time

func (*Run) Status

func (r *Run) Status() RunStatus

type RunStatus

type RunStatus int64

const (
	RunInProgress RunStatus = iota
	RunSuccess
	RunFailure
)

type RunsHandler

type RunsHandler struct {
	// contains filtered or unexported fields
}

func NewRunsHandler

func NewRunsHandler(maxEntries int) *RunsHandler

func (*RunsHandler) GetRuns

func (r *RunsHandler) GetRuns() []*Run

func (*RunsHandler) StartNewRun

func (r *RunsHandler) StartNewRun(correlationID uuid.UUID) *Run

type UserSynchronizer

type UserSynchronizer struct {
	// contains filtered or unexported fields
}

func New

func New(database db.Database, auditLogger auditlogger.AuditLogger, adminGroupPrefix, tenantDomain string, service *admin_directory_v1.Service, log logger.Logger, syncRuns *RunsHandler) *UserSynchronizer

func NewFromConfig

func NewFromConfig(cfg *config.Config, database db.Database, log logger.Logger, syncRuns *RunsHandler) (*UserSynchronizer, error)

func (*UserSynchronizer) Sync

func (s *UserSynchronizer) Sync(ctx context.Context, correlationID uuid.UUID) error

Sync Fetch all users from the tenant and add them as local users in teams-backend. If a user already exists in teams-backend the local user will get the name potentially updated. After all users have been upserted, local users that matches the tenant domain that does not exist in the Google Directory will be removed.