identity_store

Documentation

Index

• func SetMetaData(config types.BaseTargetConfig, metadata *identity_store.MetaData) error
• type IdentityStoreImportConfig
• type IdentityStoreImportResult
• type IdentityStoreImporter
  • func NewIdentityStoreImporter(config *IdentityStoreImportConfig, statusUpdater job.TaskEventUpdater) IdentityStoreImporter
• type IdentityStoreSync
  • func (s *IdentityStoreSync) GetParts() []job.TaskPart
  • func (s *IdentityStoreSync) GetResultObject() interface{}
  • func (s *IdentityStoreSync) GetTaskResults() []job.TaskResult
  • func (s *IdentityStoreSync) IsClientValid(ctx context.Context, c plugin.PluginClient) (bool, error)
  • func (s *IdentityStoreSync) ProcessResults(results interface{}) error
  • func (s *IdentityStoreSync) StartSyncAndQueueTaskPart(ctx context.Context, client plugin.PluginClient, ...) (job.JobStatus, string, error)
• type PostProcessor
  • func NewPostProcessor(config *PostProcessorConfig) PostProcessor
  • func (p *PostProcessor) NeedsUserPostProcessing() bool
  • func (p *PostProcessor) PostProcessUsers(usersInputFilePath string, usersOutputFile string) (*PostProcessorResult, error)
• type PostProcessorConfig
• type PostProcessorResult
• type QueryResponse
• type Response

Functions

func SetMetaData

func SetMetaData(config types.BaseTargetConfig, metadata *identity_store.MetaData) error

Types

type IdentityStoreImportConfig

type IdentityStoreImportConfig struct {
	types.BaseTargetConfig
	UserFile        string
	GroupFile       string
	DeleteUntouched bool
	ReplaceGroups   bool

	// TagSourcesScope is the set of sources that will be looked at when merging the tags. Tags with other sources will remain untouched.
	// If not specified, the default is to take all sources for which tags are defined in the import file.
	TagSourcesScope []string `json:"tagSourcesScope"`
}

type IdentityStoreImportResult

type IdentityStoreImportResult struct {
	UsersAdded    int `json:"usersAdded"`
	UsersUpdated  int `json:"usersUpdated"`
	UsersRemoved  int `json:"usersRemoved"`
	GroupsAdded   int `json:"groupsAdded"`
	GroupsUpdated int `json:"groupsUpdated"`
	GroupsRemoved int `json:"groupsRemoved"`

	Warnings []string `json:"warnings"`
}

type IdentityStoreImporter

type IdentityStoreImporter interface {
	TriggerImport(ctx context.Context, jobId string) (job.JobStatus, string, error)
}

func NewIdentityStoreImporter

func NewIdentityStoreImporter(config *IdentityStoreImportConfig, statusUpdater job.TaskEventUpdater) IdentityStoreImporter

type IdentityStoreSync

type IdentityStoreSync struct {
	TargetConfig *types.BaseTargetConfig
	JobId        string
	// contains filtered or unexported fields
}

func (*IdentityStoreSync) GetParts

func (s *IdentityStoreSync) GetParts() []job.TaskPart

func (*IdentityStoreSync) GetResultObject

func (s *IdentityStoreSync) GetResultObject() interface{}

func (*IdentityStoreSync) GetTaskResults

func (s *IdentityStoreSync) GetTaskResults() []job.TaskResult

func (*IdentityStoreSync) IsClientValid

func (s *IdentityStoreSync) IsClientValid(ctx context.Context, c plugin.PluginClient) (bool, error)

func (*IdentityStoreSync) ProcessResults

func (s *IdentityStoreSync) ProcessResults(results interface{}) error

func (*IdentityStoreSync) StartSyncAndQueueTaskPart

func (s *IdentityStoreSync) StartSyncAndQueueTaskPart(ctx context.Context, client plugin.PluginClient, statusUpdater job.TaskEventUpdater) (job.JobStatus, string, error)

type PostProcessor

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

func NewPostProcessor

func NewPostProcessor(config *PostProcessorConfig) PostProcessor

func (*PostProcessor) NeedsUserPostProcessing

func (p *PostProcessor) NeedsUserPostProcessing() bool

func (*PostProcessor) PostProcessUsers

func (p *PostProcessor) PostProcessUsers(usersInputFilePath string, usersOutputFile string) (*PostProcessorResult, error)

type PostProcessorConfig

type PostProcessorConfig struct {
	TagKeyAndValueForUserIsMachine string
	TargetLogger                   hclog.Logger
}

type PostProcessorResult

type PostProcessorResult struct {
	UsersTouchedCount int
}

type QueryResponse

type QueryResponse struct {
	Subtask subtaskResponse `json:"subtask"`
}

type Response

type Response struct {
	Respose QueryResponse `json:"importIdentityRequest"`
}