cqproto

Aug 7, 2022

Changes in this version

+ const VUnmanaged

Jun 21, 2022

Changes in this version

+ const ConfigHCL

+ const ConfigYAML

+ type ConfigFormat int

type ConfigureProviderRequest

+ Format ConfigFormat

type GetProviderConfigRequest

+ Format ConfigFormat

type GetProviderConfigResponse

+ Format ConfigFormat

May 24, 2022

Changes in this version

+ const V5

Apr 26, 2022

Changes in this version

type ConfigureProviderResponse

+ Diagnostics diag.Diagnostics

Mar 17, 2022

Changes in this version

type FetchResourcesRequest

+ Timeout time.Duration

Mar 10, 2022

Changes in this version

type FetchResourcesRequest

+ Metadata map[string]interface{}

Feb 15, 2022

Changes in this version

type CQProvider

+ GetModuleInfo func(context.Context, *GetModuleRequest) (*GetModuleResponse, error)

type CQProviderServer

+ GetModuleInfo func(context.Context, *GetModuleRequest) (*GetModuleResponse, error)

type GRPCClient

+ func (g GRPCClient) GetModuleInfo(ctx context.Context, request *GetModuleRequest) (*GetModuleResponse, error)

type GRPCServer

+ func (g *GRPCServer) GetModuleInfo(ctx context.Context, request *internal.GetModuleInfo_Request) (*internal.GetModuleInfo_Response, error)

+ type GetModuleRequest struct

+ Module string

+ PreferredVersions []uint32

+ type GetModuleResponse struct

+ AvailableVersions []uint32

+ Data map[uint32]ModuleInfo

+ Diagnostics diag.Diagnostics

+ type ModuleFile struct

+ Contents []byte

+ Name string

+ type ModuleInfo struct

+ Extras map[string]string

+ Files []*ModuleFile

Feb 10, 2022

Changes in this version

type ProviderDiagnostic

+ ResourceId []string

type ResourceFetchStatus

+ func (s ResourceFetchStatus) String() string

Feb 8, 2022

Changes in this version

type FetchResourcesRequest

+ MaxGoroutines uint64

Jan 25, 2022

Changes in this version

+ const V4

+ const Vunmanaged

Dec 15, 2021

Changes in this version

type ProviderDiagnostic

+ func (p ProviderDiagnostic) Error() string

Nov 4, 2021

Changes in this version

type FetchResourcesRequest

+ ParallelFetchingLimit uint64

Oct 21, 2021

Changes in this version

+ type FailedResourceFetch struct

+ Error string

+ RootPrimaryKeyValues []string

+ RootTableName string

+ TableName string

type FetchResourcesResponse

+ ResourceName string

+ Summary ResourceFetchSummary

+ type ProviderDiagnostic struct

+ Details string

+ DiagnosticSeverity diag.Severity

+ DiagnosticType diag.DiagnosticType

+ ResourceName string

+ Summary string

+ func (p ProviderDiagnostic) Description() diag.Description

+ func (p ProviderDiagnostic) Severity() diag.Severity

+ func (p ProviderDiagnostic) Type() diag.DiagnosticType

+ type ResourceFetchStatus int

+ const ResourceFetchCanceled

+ const ResourceFetchComplete

+ const ResourceFetchFailed

+ const ResourceFetchPartial

+ type ResourceFetchSummary struct

+ Diagnostics diag.Diagnostics

+ ResourceCount uint64

+ Status ResourceFetchStatus

Sep 2, 2021

Changes in this version

type FetchResourcesRequest

+ PartialFetchingEnabled bool

type FetchResourcesResponse

+ PartialFetchFailedResources []*PartialFetchFailedResource

+ type PartialFetchFailedResource struct

+ Error string

+ RootPrimaryKeyValues []string

+ RootTableName string

+ TableName string

+ func PartialFetchToCQProto(in []schema.PartialFetchFailedResource) []*PartialFetchFailedResource

Aug 21, 2021

Changes in this version

type GetProviderSchemaResponse

+ Migrations map[string][]byte

Jul 26, 2021

Changes in this version

type ConfigureProviderRequest

+ DisableDelete bool

+ ExtraFields map[string]interface{}

May 15, 2021

Changes in this version

+ type CQPlugin struct

+ Impl CQProviderServer

+ func (p *CQPlugin) GRPCClient(_ context.Context, broker *plugin.GRPCBroker, c *grpc.ClientConn) (interface{}, error)

+ func (p *CQPlugin) GRPCServer(broker *plugin.GRPCBroker, s *grpc.Server) error

+ type CQProvider interface

+ ConfigureProvider func(context.Context, *ConfigureProviderRequest) (*ConfigureProviderResponse, error)

+ FetchResources func(context.Context, *FetchResourcesRequest) (FetchResourcesStream, error)

+ GetProviderConfig func(context.Context, *GetProviderConfigRequest) (*GetProviderConfigResponse, error)

+ GetProviderSchema func(context.Context, *GetProviderSchemaRequest) (*GetProviderSchemaResponse, error)

+ type CQProviderServer interface

+ ConfigureProvider func(context.Context, *ConfigureProviderRequest) (*ConfigureProviderResponse, error)

+ FetchResources func(context.Context, *FetchResourcesRequest, FetchResourcesSender) error

+ GetProviderConfig func(context.Context, *GetProviderConfigRequest) (*GetProviderConfigResponse, error)

+ GetProviderSchema func(context.Context, *GetProviderSchemaRequest) (*GetProviderSchemaResponse, error)

+ type ConfigureProviderRequest struct

+ CloudQueryVersion string

+ Config []byte

+ Connection ConnectionDetails

+ type ConfigureProviderResponse struct

+ Error string

+ type ConnectionDetails struct

+ DSN string

+ Type string

+ type FetchResourcesRequest struct

+ Resources []string

+ type FetchResourcesResponse struct

+ Error string

+ FinishedResources map[string]bool

+ ResourceCount uint64

+ type FetchResourcesSender interface

+ Send func(*FetchResourcesResponse) error

+ type FetchResourcesStream interface

+ Recv func() (*FetchResourcesResponse, error)

+ type GRPCClient struct

+ func (g GRPCClient) ConfigureProvider(ctx context.Context, request *ConfigureProviderRequest) (*ConfigureProviderResponse, error)

+ func (g GRPCClient) FetchResources(ctx context.Context, request *FetchResourcesRequest) (FetchResourcesStream, error)

+ func (g GRPCClient) GetProviderConfig(ctx context.Context, _ *GetProviderConfigRequest) (*GetProviderConfigResponse, error)

+ func (g GRPCClient) GetProviderSchema(ctx context.Context, _ *GetProviderSchemaRequest) (*GetProviderSchemaResponse, error)

+ type GRPCFetchResourcesServer struct

+ func (g GRPCFetchResourcesServer) Send(response *FetchResourcesResponse) error

+ type GRPCFetchResponseStream struct

+ func (g GRPCFetchResponseStream) Recv() (*FetchResourcesResponse, error)

+ type GRPCServer struct

+ Impl CQProviderServer

+ func (g *GRPCServer) ConfigureProvider(ctx context.Context, request *internal.ConfigureProvider_Request) (*internal.ConfigureProvider_Response, error)

+ func (g *GRPCServer) FetchResources(request *internal.FetchResources_Request, ...) error

+ func (g *GRPCServer) GetProviderConfig(ctx context.Context, _ *internal.GetProviderConfig_Request) (*internal.GetProviderConfig_Response, error)

+ func (g *GRPCServer) GetProviderSchema(ctx context.Context, _ *internal.GetProviderSchema_Request) (*internal.GetProviderSchema_Response, error)

+ type GetProviderConfigRequest struct

+ type GetProviderConfigResponse struct

+ Config []byte

+ type GetProviderSchemaRequest struct

+ type GetProviderSchemaResponse struct

+ Name string

+ ResourceTables map[string]*schema.Table

+ Version string