Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ParseConfig ¶
func ParseConfig(input *resource_provider.UpdateResourceInput) *raito.DbtConfig
Types ¶
type AccessProviderClient ¶
type AccessProviderClient interface {
CreateAccessProvider(ctx context.Context, ap sdkTypes.AccessProviderInput) (*sdkTypes.AccessProvider, error)
UpdateAccessProvider(ctx context.Context, id string, ap sdkTypes.AccessProviderInput, ops ...func(options *services.UpdateAccessProviderOptions)) (*sdkTypes.AccessProvider, error)
DeleteAccessProvider(ctx context.Context, id string, ops ...func(options *services.UpdateAccessProviderOptions)) error
ListAccessProviders(ctx context.Context, ops ...func(options *services.AccessProviderListOptions)) <-chan sdkTypes.ListItem[sdkTypes.AccessProvider]
}
type AccessProviderInput ¶
type AccessProviderInput struct {
Input sdkTypes.AccessProviderInput
Owners set.Set[string]
}
type DbtService ¶
type DbtService struct {
// contains filtered or unexported fields
}
func NewDbtService ¶
func NewDbtService(config *resource_provider.UpdateResourceInput, accessProviderClient AccessProviderClient, userRepo UserRepo, roleClient RoleClient, manifestParser manifest.Parser, logger hclog.Logger) *DbtService
type ResourceStatus ¶
type ResourceStatus int
const ( ResourceStatusFailure ResourceStatus = iota ResourceStatusCreated ResourceStatusUpdated ResourceStatusDeleted )
type ResourceSyncer ¶
type ResourceSyncer struct {
// contains filtered or unexported fields
}
func NewResourceSyncer ¶
func NewResourceSyncer(service *DbtService) *ResourceSyncer
func (ResourceSyncer) UpdateResources ¶
func (r ResourceSyncer) UpdateResources(ctx context.Context, config *resource_provider.UpdateResourceInput) (*resource_provider.UpdateResourceResult, error)
type RoleClient ¶
Click to show internal directories.
Click to hide internal directories.