clitrigger

package
v0.64.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 16, 2024 License: Apache-2.0 Imports: 20 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ApUpdate

type ApUpdate struct {
	Domain          string   `json:"domain"`
	DataSourceNames []string `json:"dataSourceNames"`
}

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"`
	// Boolean to indicate if a resource provider needs to be synced or not
	ResourceProviderSync bool `json:"resourceProviderSync"`
	// 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

Jump to

Keyboard shortcuts

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