connectorrunner

func WithActionsEnabled ¶ added in v0.3.25

func WithActionsEnabled() Option

func WithBulkCreateTicket ¶ added in v0.2.43

func WithBulkCreateTicket(templatePath string) Option

func WithClientCredentials ¶

func WithClientCredentials(clientID string, clientSecret string) Option

func WithCreateTicket ¶ added in v0.1.36

func WithCreateTicket(templatePath string) Option

func WithDiffSyncs ¶ added in v0.3.2

func WithDiffSyncs(c1zPath string, baseSyncID string, newSyncID string) Option

func WithExternalLimiter ¶

func WithExternalLimiter(address string, opts map[string]string) Option

WithExternalLimiter configures the connector to use an external rate limiter. The `opts` map is injected into the environment in order for the service to be configured.

func WithExternalResourceC1Z ¶ added in v0.2.84

func WithExternalResourceC1Z(externalResourceC1Z string) Option

func WithExternalResourceEntitlementFilter ¶ added in v0.2.84

func WithExternalResourceEntitlementFilter(entitlementId string) Option

func WithFixedMemoryLimiter ¶

func WithFixedMemoryLimiter(rate int64, period time.Duration) Option

WithFixedMemoryLimiter configures to use a fixed-memory limiter. `rate` is a number on how many times it should be in the given period executed. `period` represents the elapsed time between two instants as an int64 nanosecond count.

func WithFullSyncDisabled ¶ added in v0.2.15

func WithFullSyncDisabled() Option

func WithGetTicket ¶ added in v0.1.36

func WithGetTicket(ticketID string) Option

func WithListTicketSchemas ¶ added in v0.1.36

func WithListTicketSchemas() Option

func WithOnDemandCreateAccount ¶ added in v0.1.15

func WithOnDemandCreateAccount(c1zPath string, login string, email string, profile *structpb.Struct, resourceTypeId string) Option

func WithOnDemandDeleteResource ¶ added in v0.1.15

func WithOnDemandDeleteResource(c1zPath string, resourceId string, resourceType string) Option

func WithOnDemandEventStream ¶ added in v0.1.16

func WithOnDemandEventStream(feedId string, startAt time.Time, cursor string) Option

func WithOnDemandGrant ¶

func WithOnDemandGrant(c1zPath string, entitlementID string, principalID string, principalType string) Option

func WithOnDemandInvokeAction ¶ added in v0.3.25

func WithOnDemandInvokeAction(c1zPath string, action string, resourceTypeID string, args *structpb.Struct) Option

WithOnDemandInvokeAction creates an option for invoking an action. If resourceTypeID is provided, it invokes a resource-scoped action.

func WithOnDemandListActionSchemas ¶ added in v0.6.9

func WithOnDemandListActionSchemas(c1zPath string, resourceTypeID string) Option

WithOnDemandListActionSchemas creates an option for listing action schemas. If resourceTypeID is provided, it filters schemas for that specific resource type.

func WithOnDemandRevoke ¶

func WithOnDemandRevoke(c1zPath string, grantID string) Option

func WithOnDemandRotateCredentials ¶ added in v0.1.15

func WithOnDemandRotateCredentials(c1zPath string, resourceId string, resourceType string) Option

func WithOnDemandSync ¶

func WithOnDemandSync(c1zPath string) Option

func WithProvisioningEnabled ¶

func WithProvisioningEnabled() Option

func WithRateLimitDescriptor ¶

func WithRateLimitDescriptor(entry *ratelimitV1.RateLimitDescriptors_Entry) Option

WithRateLimitDescriptor takes a rate limit descriptor and adds it to the list of rate limit descriptors.

func WithRateLimiterConfig ¶

func WithRateLimiterConfig(cfg *ratelimitV1.RateLimiterConfig) Option

WithRateLimiterConfig sets the RateLimiterConfig for a runner.

func WithSessionStoreEnabled ¶ added in v0.5.0

func WithSessionStoreEnabled() Option

func WithSkipEntitlementsAndGrants ¶ added in v0.3.40

func WithSkipEntitlementsAndGrants(skip bool) Option

func WithSkipGrants ¶ added in v0.5.1

func WithSkipGrants(skip bool) Option

func WithSlidingMemoryLimiter ¶

func WithSlidingMemoryLimiter(usePercent int64) Option

WithSlidingMemoryLimiter configures the connector to use an in-memory rate limiter that adjusts to maintain fairness based on request headers. `usePercent` is value between 0 and 100.

func WithSyncCompactor ¶ added in v0.3.3

func WithSyncCompactor(outputPath string, filePaths []string, syncIDs []string) Option

func WithSyncResourceTypeIDs ¶ added in v0.5.0

func WithSyncResourceTypeIDs(resourceTypeIDs []string) Option

func WithTargetedSyncResources ¶ added in v0.6.6

func WithTargetedSyncResources(resourceIDs []string) Option

func WithTempDir ¶ added in v0.1.8

func WithTempDir(tempDir string) Option

func WithTicketingEnabled ¶ added in v0.1.36

func WithTicketingEnabled() Option