Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ApUpdateTriggerHandler ¶ added in v0.45.1
type ApUpdateTriggerHandler struct {
// contains filtered or unexported fields
}
func NewApUpdateTrigger ¶ added in v0.45.1
func NewApUpdateTrigger(cliTrigger CliTrigger) *ApUpdateTriggerHandler
func NewApUpdateTriggerHandler ¶ added in v0.45.1
func NewApUpdateTriggerHandler() *ApUpdateTriggerHandler
func (*ApUpdateTriggerHandler) Close ¶ added in v0.45.1
func (h *ApUpdateTriggerHandler) Close()
func (*ApUpdateTriggerHandler) HandleTriggerEvent ¶ added in v0.45.1
func (h *ApUpdateTriggerHandler) HandleTriggerEvent(_ context.Context, triggerEvent *TriggerEvent)
func (*ApUpdateTriggerHandler) Pop ¶ added in v0.45.1
func (h *ApUpdateTriggerHandler) Pop() *ApUpdate
func (*ApUpdateTriggerHandler) TriggerChannel ¶ added in v0.45.1
func (h *ApUpdateTriggerHandler) TriggerChannel() <-chan struct{}
type CliTrigger ¶
type CliTrigger interface {
Start(ctx context.Context)
Subscribe(handler TriggerHandler)
Reset()
Wait()
}
func CreateCliTrigger ¶
func CreateCliTrigger(config *types.BaseConfig) (CliTrigger, error)
type DummyCliTrigger ¶ added in v0.39.4
type DummyCliTrigger struct {
}
func (DummyCliTrigger) Reset ¶ added in v0.39.4
func (d DummyCliTrigger) Reset()
func (DummyCliTrigger) Start ¶ added in v0.45.1
func (d DummyCliTrigger) Start(_ context.Context)
func (DummyCliTrigger) Subscribe ¶ added in v0.45.1
func (d DummyCliTrigger) Subscribe(_ TriggerHandler)
func (DummyCliTrigger) Wait ¶ added in v0.39.4
func (d DummyCliTrigger) Wait()
type SyncTrigger ¶ added in v0.54.0
type SyncTrigger struct {
// Domain represents the domain of the customer
Domain string `json:"domain"`
// The id of the datasource to sync. Note: this should be set if data source, usage or access needs to be synced
DataSource *string `json:"dataSource"`
// The id of the identity store to sync. Note: this should be set if identity store needs to be synced
IdentityStore *string `json:"identityStore"`
// Boolean to indicate if the identity store needs to be synced or not
IdentityStoreSync bool `json:"identityStoreSync"`
// Boolean to indicate if the data source needs to be synced or not
DataSourceSync bool `json:"dataSourceSync"`
// Boolean to indicate if access needs to be synced or not
DataAccessSync bool `json:"accessSync"`
// Boolean to indicate if usage needs to be synced or not
DataUsageSync bool `json:"usageSync"`
// Optional: the fullName of the data object to sync.
// That means that, if this is specified, the import will be run with `DeleteUntouched=false`, so no cleanup will be done of removed data objects.
DataObjectParent *string `json:"dataObjectParent"`
// Optional: the list of data object names (as child of the DataObjectParent) which can be excluded during the sync
// When DataObjectParent is provided, it is expected that this list contains all the child data objects that Raito already know about and so can be skipped during the sync.
DataObjectExcludes []string `json:"dataObjectExcludes"`
}
type SyncTriggerHandler ¶ added in v0.54.0
type SyncTriggerHandler struct {
// contains filtered or unexported fields
}
func NewSyncTrigger ¶ added in v0.54.0
func NewSyncTrigger(cliTrigger CliTrigger) *SyncTriggerHandler
func NewSyncTriggerHandler ¶ added in v0.54.0
func NewSyncTriggerHandler() *SyncTriggerHandler
func (*SyncTriggerHandler) Close ¶ added in v0.54.0
func (h *SyncTriggerHandler) Close()
func (*SyncTriggerHandler) HandleTriggerEvent ¶ added in v0.54.0
func (h *SyncTriggerHandler) HandleTriggerEvent(_ context.Context, triggerEvent *TriggerEvent)
func (*SyncTriggerHandler) Pop ¶ added in v0.54.0
func (h *SyncTriggerHandler) Pop() *SyncTrigger
func (*SyncTriggerHandler) TriggerChannel ¶ added in v0.54.0
func (h *SyncTriggerHandler) TriggerChannel() <-chan struct{}
type TriggerEvent ¶
type TriggerEvent struct {
ApUpdate *ApUpdate `json:"apUpdate,omitempty"`
SyncTrigger *SyncTrigger `json:"syncTrigger,omitempty"`
}
type TriggerHandler ¶ added in v0.45.1
type TriggerHandler interface {
HandleTriggerEvent(ctx context.Context, triggerEvent *TriggerEvent)
}
type WebsocketCliTrigger ¶
type WebsocketCliTrigger struct {
// contains filtered or unexported fields
}
func NewWebsocketCliTrigger ¶
func NewWebsocketCliTrigger(config *types.BaseConfig, websocketUrl string) *WebsocketCliTrigger
func (*WebsocketCliTrigger) Reset ¶ added in v0.36.1
func (s *WebsocketCliTrigger) Reset()
func (*WebsocketCliTrigger) Start ¶ added in v0.45.1
func (s *WebsocketCliTrigger) Start(ctx context.Context)
func (*WebsocketCliTrigger) Subscribe ¶ added in v0.45.1
func (s *WebsocketCliTrigger) Subscribe(handler TriggerHandler)
func (*WebsocketCliTrigger) Wait ¶
func (s *WebsocketCliTrigger) Wait()
type WebsocketClient ¶
type WebsocketClient struct {
// contains filtered or unexported fields
}
func NewWebsocketClient ¶
func NewWebsocketClient(config *types.BaseConfig, websocketUrl string) *WebsocketClient
func (*WebsocketClient) Start ¶
func (s *WebsocketClient) Start(ctx context.Context) (<-chan interface{}, error)
func (*WebsocketClient) Wait ¶
func (s *WebsocketClient) Wait()
type WebsocketMessageError ¶ added in v0.36.1
type WebsocketMessageError struct {
// contains filtered or unexported fields
}
func (*WebsocketMessageError) Error ¶ added in v0.36.1
func (e *WebsocketMessageError) Error() string
Click to show internal directories.
Click to hide internal directories.