identity_store

Documentation

Index

• func SetMetaData(config target.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) IsClientValid(ctx context.Context, c plugin.PluginClient) (bool, error)
  • func (s *IdentityStoreSync) ProcessResults(results interface{}) error
  • func (s *IdentityStoreSync) StartSyncAndQueueTaskPart(client plugin.PluginClient, statusUpdater job.TaskEventUpdater) (job.JobStatus, string, error)
• type QueryResponse
• type Response

Functions

func SetMetaData

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

Types

type IdentityStoreImportConfig

type IdentityStoreImportConfig struct {
	target.BaseTargetConfig
	UserFile        string
	GroupFile       string
	DeleteUntouched bool
	ReplaceGroups   bool
	ReplaceTags     bool
}

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(jobId string) (job.JobStatus, string, error)
}

func NewIdentityStoreImporter

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

type IdentityStoreSync

type IdentityStoreSync struct {
	TargetConfig *target.BaseTargetConfig
	JobId        string
}

func (*IdentityStoreSync) GetParts

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

func (*IdentityStoreSync) GetResultObject

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

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(client plugin.PluginClient, statusUpdater job.TaskEventUpdater) (job.JobStatus, string, error)

type QueryResponse

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

type Response

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