deployer

Documentation

Index

• func FetchAvailablePermissionIDs(ctx context.Context, client *http.Client, url string) ([]string, error)
• func NewClient(info account.AccountInfo, client *accounts.Client, ...) *accountManagementClient
• func WithMaxConcurrentDeploys(maxConcurrentDeploys int) func(*AccountDeployer)
• type AccountDeployer
  • func NewAccountDeployer(client client, opts ...func(*AccountDeployer)) *AccountDeployer
  • func (d *AccountDeployer) Deploy(res *account.Resources) error
• type Dispatcher
  • func NewDispatcher(maxWorkers int) *Dispatcher
  • func (d *Dispatcher) AddJob(j Runnable)
  • func (d *Dispatcher) Run()
  • func (d *Dispatcher) Stop()
  • func (d *Dispatcher) Wait() error
• type Group
• type ManagementZone
• type Options
• type Permissions
• type Policy
• type Runnable

Functions

func FetchAvailablePermissionIDs

func FetchAvailablePermissionIDs(ctx context.Context, client *http.Client, url string) ([]string, error)

func NewClient

func NewClient(info account.AccountInfo, client *accounts.Client, supportedPermissions []remoteId) *accountManagementClient

func WithMaxConcurrentDeploys

func WithMaxConcurrentDeploys(maxConcurrentDeploys int) func(*AccountDeployer)

Types

type AccountDeployer

type AccountDeployer struct {
	// contains filtered or unexported fields
}

func NewAccountDeployer

func NewAccountDeployer(client client, opts ...func(*AccountDeployer)) *AccountDeployer

func (*AccountDeployer) Deploy

func (d *AccountDeployer) Deploy(res *account.Resources) error

type Dispatcher

type Dispatcher struct {
	// contains filtered or unexported fields
}

func NewDispatcher

func NewDispatcher(maxWorkers int) *Dispatcher

NewDispatcher creates a dispatcher that will use the specified amount of workers to dispatch its work loads. If maxWorkers is equal or less than 0, the dispatcher will dynamically create workers. Otherwise, there will be the specified fixed amount of workers available in the pool.

func (*Dispatcher) AddJob

func (d *Dispatcher) AddJob(j Runnable)

func (*Dispatcher) Run

func (d *Dispatcher) Run()

func (*Dispatcher) Stop

func (d *Dispatcher) Stop()

func (*Dispatcher) Wait

func (d *Dispatcher) Wait() error

type Group

type Group = accountmanagement.PutGroupDto

type ManagementZone

type ManagementZone = accountmanagement.ManagementZoneResourceDto

type Options

type Options struct {
	DryRun bool
}

type Permissions

type Permissions = accountmanagement.PermissionsDto

type Policy

type Policy = accountmanagement.CreateOrUpdateLevelPolicyRequestDto

type Runnable

type Runnable func(group *sync.WaitGroup, errCh chan error)