client

Apr 27, 2022

Changes in this version

+ type ConfigureDiagnostic struct

+ func (d *ConfigureDiagnostic) IsConfigureDiagnostic() bool

Apr 9, 2022

Changes in this version

+ type GetProviderSchemaOptions struct

+ Provider string

type ProviderSchema

+ func GetProviderSchema(ctx context.Context, plugin *plugin.Manager, request *GetProviderSchemaOptions) (*ProviderSchema, error)

+ type PurgeProviderDataOptions struct

+ DryRun bool

+ LastUpdate time.Duration

+ Providers []string

+ type PurgeProviderDataResult struct

+ AffectedResources map[string]int

+ TotalAffected int

+ func PurgeProviderData(ctx context.Context, storage Storage, plugin *plugin.Manager, ...) (*PurgeProviderDataResult, diag.Diagnostics)

+ func (p PurgeProviderDataResult) Resources() []string

+ type SimpleStorage struct

+ func NewStorage(dsn string) *SimpleStorage

+ func (s SimpleStorage) DSN() string

+ type Storage interface

+ DSN func() string

Feb 28, 2022

Changes in this version

type Client

+ func (c *Client) GetProviderModule(ctx context.Context, providerName string, req cqproto.GetModuleRequest) (*cqproto.GetModuleResponse, error)

Jan 26, 2022

Changes in this version

type Client

+ func (c *Client) SaveFetchSummary(ctx context.Context, fs *FetchSummary) error

type FetchSummary

+ CoreVersion string

+ CreatedAt *time.Time

+ ProviderAlias string

type ProviderFetchSummary

+ ProviderAlias string

+ type ProviderSchema struct

+ ProtocolVersion int

Jan 18, 2022

Changes in this version

+ func SaveFetchSummary(ctx context.Context, pool *pgxpool.Pool, fs *FetchSummary) error

type Client

+ func (c *Client) MigrateCore(ctx context.Context) error

+ type FetchSummary struct

+ CqId uuid.UUID

+ FetchId uuid.UUID

+ Finish time.Time

+ IsSuccess bool

+ ProviderName string

+ ProviderVersion string

+ Resources ResourceFetchSummaries

+ Start time.Time

+ TotalErrorsCount uint64

+ TotalResourceCount uint64

+ type ResourceFetchSummaries []ResourceFetchSummary

+ func (r ResourceFetchSummaries) Value() (driver.Value, error)

+ type ResourceFetchSummary struct

+ Diagnostics diag.Diagnostics

+ Error string

+ FinishedResources map[string]bool

+ PartialFetchFailedResources []*cqproto.FailedResourceFetch

+ ResourceCount uint64

+ ResourceName string

+ Status string

Jan 10, 2022

Changes in this version

type Client

+ func (c *Client) LoadPolicy(ctx context.Context, name, source string) (pol *policy.Policy, retErr error)

Jan 3, 2022

Changes in this version

+ const DevelopmentVersion

type ProviderFetchSummary

+ Status string

Dec 16, 2021

Changes in this version

+ const DefaultVersion

+ const UpdateCheckPeriod

+ func MaybeCheckForUpdate(ctx context.Context, fs afero.Afero, nowUnix, period int64) (*version.Version, error)

type Client

+ func (c *Client) CheckForProviderUpdates(ctx context.Context) ([]ProviderUpdateSummary, error)

type ProviderFetchSummary

+ Version string

+ type ProviderUpdateSummary struct

+ LatestVersion string

+ Name string

+ Version string

+ type UUID struct

+ func (dst UUID) Get() interface{}

+ func (u UUID) String() string

Dec 6, 2021

Changes in this version

+ var MinPostgresVersion = version.Must(version.NewVersion("11.0"))

+ func CreateDatabase(ctx context.Context, dsn string) (*pgxpool.Pool, error)

+ func ValidatePostgresVersion(ctx context.Context, pool *pgxpool.Pool, want *version.Version) error

type Client

+ HistoryCfg *history.Config

+ func (c *Client) LoadPolicies(ctx context.Context, req *PoliciesRunRequest) (policy.Policies, error)

type ProviderFetchSummary

+ func (p ProviderFetchSummary) Metrics() map[string]int64

+ type TableRemover interface

+ DropTable func(ctx context.Context, conn *pgxpool.Conn, t *schema.Table) error

Nov 22, 2021

Changes in this version

+ var ErrMigrationsNotSupported = errors.New("provider doesn't support migrations")

Nov 21, 2021

Changes in this version

+ func FilterPolicies(args []string, configPolicies []*config.Policy, policyName, subPath string) ([]*config.Policy, error)

type Client

+ PolicyManager policy.Manager

+ func (c *Client) RunPolicies(ctx context.Context, req *PoliciesRunRequest) ([]*policy.ExecutionResult, error)

+ type PoliciesRunRequest struct

+ FailOnViolation bool

+ OutputDir string

+ Policies []*config.Policy

+ PolicyName string

+ RunCallback policy.UpdateCallback

+ SkipVersioning bool

+ StopOnFailure bool

Nov 12, 2021

Changes in this version

type ModuleRunRequest

+ Config hcl.Body

type PolicyRunRequest

+ FailOnViolation bool

Nov 4, 2021

Changes in this version

type Client

+ ModuleManager module.Manager

+ func (c *Client) ExecuteModule(ctx context.Context, req ModuleRunRequest) (*module.ExecutionResult, error)

+ func (c *Client) GenModuleConfig(ctx context.Context, modName string) (*string, error)

+ type ModuleRunRequest struct

+ ModConfigPath string

+ Name string

+ Params interface{}

+ Providers []*cqproto.GetProviderSchemaResponse

type PolicyRunRequest

+ LocalPath string

Oct 21, 2021

Changes in this version

type ProviderFetchSummary

+ FetchResources map[string]cqproto.ResourceFetchSummary

+ TotalResourcesFetched uint64

+ func (p ProviderFetchSummary) Diagnostics() diag.Diagnostics

Oct 11, 2021

Changes in this version

type Client

+ func (c *Client) NormalizeResources(ctx context.Context, providers []*config.Provider) error

Sep 13, 2021

Changes in this version

type Client

+ func (c *Client) SetProviderVersion(ctx context.Context, providerName, version string) error

type ProviderFetchSummary

+ FetchErrors []error

+ func (s *ProviderFetchSummary) HasErrors() bool

Sep 9, 2021

Changes in this version

+ type FetchResponse struct

+ ProviderFetchSummary map[string]ProviderFetchSummary

type FetchUpdate

+ PartialFetchResults []*cqproto.PartialFetchFailedResource

+ type ProviderFetchSummary struct

+ PartialFetchErrors []*cqproto.PartialFetchFailedResource

+ ProviderName string

Aug 23, 2021

Changes in this version

type Client

+ func (c *Client) TestProvider(ctx context.Context, providerCfg *config.Provider) error

Aug 19, 2021

Changes in this version

+ var Version = "development"

type Client

+ func (c *Client) DowngradeProvider(ctx context.Context, providerName string) error

+ func (c *Client) DropProvider(ctx context.Context, providerName string) error

+ func (c *Client) UpgradeProvider(ctx context.Context, providerName string) error

Jul 27, 2021

Changes in this version

type Client

+ SkipBuildTables bool

+ SkipVersioning bool

+ TableCreator TableCreator

+ func (c *Client) BuildProviderTables(ctx context.Context, providerName string) error

type FetchRequest

+ DisableDataDelete bool

+ ExtraFields map[string]interface{}

type PolicyRunRequest

+ SkipVersioning bool

+ type TableCreator interface

+ CreateTable func(ctx context.Context, conn *pgxpool.Conn, t *schema.Table, p *schema.Table) error

Jun 24, 2021

Changes in this version

type Client

+ PolicyDirectory string

+ func (c Client) DownloadPolicy(ctx context.Context, args []string) error

+ func (c Client) RunPolicy(ctx context.Context, req PolicyRunRequest) error

+ type PolicyRunRequest struct

+ Args []string

+ OutputPath string

+ RunCallBack policy.ExecutionCallback

+ StopOnFailure bool

+ SubPath string

Jun 12, 2021

Changes in this version

type Client

+ DSN string

+ HubProgressUpdater ui.Progress

+ NoVerify bool

+ PluginDirectory string

+ Providers []*config.RequiredProvider

+ RegistryURL string

+ func (c *Client) DownloadProviders(ctx context.Context) error

May 16, 2021

Changes in this version

+ type Client struct

+ Hub registry.Registry

+ Logger hclog.Logger

+ Manager *plugin.Manager

+ func New(config *config.Config, options ...Option) (*Client, error)

+ func (c *Client) Fetch(ctx context.Context, request FetchRequest) error

+ func (c *Client) Initialize(ctx context.Context) error

+ func (c Client) Close()

+ func (c Client) ExecutePolicy(ctx context.Context, request ExecutePolicyRequest) (*PolicyExecutionResult, error)

+ func (c Client) GetProviderConfiguration(ctx context.Context, providerName string) (*cqproto.GetProviderConfigResponse, error)

+ func (c Client) GetProviderSchema(ctx context.Context, providerName string) (*cqproto.GetProviderSchemaResponse, error)

+ type ExecutePolicyRequest struct

+ OutputPath string

+ PolicyPath string

+ StopOnFailure bool

+ UpdateCallback PolicyExecutionCallback

+ type FetchDoneResult struct

+ DoneResources map[string]map[string]bool

+ ResourceCount string

+ type FetchRequest struct

+ Providers []*config.Provider

+ UpdateCallback FetchUpdateCallback

+ type FetchUpdate struct

+ Error string

+ FinishedResources map[string]bool

+ Provider string

+ ResourceCount uint64

+ Version string

+ func (f FetchUpdate) AllDone() bool

+ func (f FetchUpdate) DoneCount() int

+ type FetchUpdateCallback func(update FetchUpdate)

+ type Option func(options *Client)

+ type PolicyExecutionCallback func(name string, passed bool, resultCount int)

+ type PolicyExecutionResult struct

+ Passed bool

+ Results map[string]*PolicyResult

+ type PolicyResult struct

+ Columns []string

+ Data [][]interface{}

+ Name string

+ Passed bool

+ type UpgradeRequest struct

+ Provider string

+ Version string