console

package
v0.27.0-rc2 Latest Latest
Warning

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

 Go to latest Published: Jun 21, 2022 License: MPL-2.0 Imports: 40 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ParseAndDetect added in v0.25.0 

func ParseAndDetect(policyPath string) (policy.Policies, error)

Types

type Bar 

type Bar struct {
	Name    string
	Message string
	Status  string
	Total   int64
	// contains filtered or unexported fields
}

func (*Bar) Done added in v0.16.0 

func (b *Bar) Done()

func (*Bar) SetTotal 

func (b *Bar) SetTotal(total int64, triggerComplete bool)

type Client 

type Client struct {
	Providers     registry.Providers
	Registry      registry.Registry
	PluginManager *plugin.Manager
	Storage       database.Storage
	StateManager  *state.Client
	// contains filtered or unexported fields
}

Client console client is a wrapper around core.Client for console execution of CloudQuery

func CreateClient 

func CreateClient(ctx context.Context, configPath string, allowDefaultConfig bool, configMutator func(*config.Config) error, instanceId uuid.UUID) (*Client, error)

func CreateClientFromConfig 

func CreateClientFromConfig(ctx context.Context, cfg *config.Config, instanceId uuid.UUID) (*Client, error)

func (Client) Close added in v0.23.0 

func (c Client) Close()

func (Client) ConvertRequiredToRegistry added in v0.23.0 

func (c Client) ConvertRequiredToRegistry(providerName string) registry.Provider

func (Client) DescribePolicies added in v0.17.0 

func (c Client) DescribePolicies(ctx context.Context, policySource string) error

func (Client) DownloadPolicy added in v0.13.8 

func (c Client) DownloadPolicy(ctx context.Context, args []string) (diags diag.Diagnostics)

func (Client) DownloadProviders 

func (c Client) DownloadProviders(ctx context.Context) (diags diag.Diagnostics)

func (Client) DropProvider added in v0.14.5 

func (c Client) DropProvider(ctx context.Context, providerName string) (diags diag.Diagnostics)

func (Client) Fetch 

func (c Client) Fetch(ctx context.Context) (*core.FetchResponse, diag.Diagnostics)

func (Client) PrunePolicyExecutions added in v0.24.1 

func (c Client) PrunePolicyExecutions(ctx context.Context, retentionPeriod string) (diags diag.Diagnostics)

func (Client) RemoveStaleData added in v0.22.3 

func (c Client) RemoveStaleData(ctx context.Context, lastUpdate time.Duration, dryRun bool, providers []string) (diags diag.Diagnostics)

func (Client) RunPolicies added in v0.16.0 

func (c Client) RunPolicies(ctx context.Context, policySource, outputDir string, noResults, dbPersistence bool) (diags diag.Diagnostics)

func (Client) SnapshotPolicy added in v0.21.0 

func (c Client) SnapshotPolicy(ctx context.Context, policySource, snapshotDestination string) error

func (Client) SyncProviders added in v0.23.0 

func (c Client) SyncProviders(ctx context.Context, pp ...string) (results []*core.SyncResult, diags diag.Diagnostics)

func (Client) TestPolicies added in v0.21.0 

func (c Client) TestPolicies(ctx context.Context, policySource, snapshotDestination string) error

func (Client) ValidatePolicy added in v0.23.3 

func (c Client) ValidatePolicy(ctx context.Context, policySource string) (diags diag.Diagnostics)

type ModuleCallRequest added in v0.15.10 

type ModuleCallRequest struct {
	// Name of the module
	Name string

	// Params are the invocation parameters specific to the module
	Params interface{}

	// Profile is the selected/overridden name of the profile
	Profile string

	// OutputPath is the filename to save output to
	OutputPath string
}

ModuleCallRequest is the request used to call a module.

type Progress 

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

func NewProgress 

func NewProgress(ctx context.Context, opts ...ProgressOption) *Progress

func (*Progress) AbortAll added in v0.14.5 

func (u *Progress) AbortAll()

func (*Progress) Add 

func (u *Progress) Add(name, displayName, message string, total int64)

func (*Progress) AttachReader 

func (u *Progress) AttachReader(name string, data io.Reader) io.Reader

func (*Progress) GetBar 

func (u *Progress) GetBar(name string) *Bar

func (*Progress) Increment 

func (u *Progress) Increment(name string, n int)

func (*Progress) MarkAllDone added in v0.15.0 

func (u *Progress) MarkAllDone()

func (*Progress) Update 

func (u *Progress) Update(name, status, msg string, n int)

func (*Progress) Wait 

func (u *Progress) Wait()

type ProgressOption 

type ProgressOption func(o *ProgressOptions)

type ProgressOptions 

type ProgressOptions struct {
	Filler           string
	StatusFunc       func(b *Bar, statistics decor.Statistics) string
	MessageHook      func(b *Bar, statistics decor.Statistics) string
	AppendDecorators []decor.Decorator
}

type Table added in v0.17.0 

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

func (Table) Append added in v0.17.0 

func (t Table) Append(i ...interface{})

func (Table) Render added in v0.17.0 

func (t Table) Render()

func (Table) SetHeaders added in v0.17.0 

func (t Table) SetHeaders(headers ...string)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.