resource_provider

package
v0.0.5-dev0 Latest Latest
Warning

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

Go to latest
Published: Jun 13, 2024 License: Apache-2.0 Imports: 22 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

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

func (*DbtService) RunDbt

func (s *DbtService) RunDbt(ctx context.Context, dbtFile string, fullnamePrefix string) (uint32, uint32, uint32, uint32, error)

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

type RoleClient

type RoleClient interface {
	UpdateRoleAssigneesOnAccessProvider(ctx context.Context, accessProviderId string, roleId string, assignees ...string) (*sdkTypes.Role, error)
}

type UserRepo

type UserRepo interface {
	GetCurrentUser(ctx context.Context) (*sdkTypes.User, error)
	GetUserByEmail(ctx context.Context, email string) (*sdkTypes.User, error)
}

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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