internal

package
v0.7.4 Latest Latest
Warning

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

 Go to latest Published: Feb 2, 2022 License: MPL-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ColumnType_name = map[int32]string{
		0:  "INVALID",
		1:  "BOOL",
		2:  "SMALLINT",
		3:  "INT",
		4:  "BIGINT",
		5:  "FLOAT",
		6:  "UUID",
		7:  "STRING",
		8:  "BYTE_ARRAY",
		9:  "STRING_ARRAY",
		10: "INT_ARRAY",
		11: "TIMESTAMP",
		12: "JSON",
		13: "UUID_ARRAY",
		14: "INET",
		15: "INET_ARRAY",
		16: "CIDR",
		17: "CIDR_ARRAY",
		18: "MAC_ADDR",
		19: "MAC_ADDR_ARRAY",
	}
	ColumnType_value = map[string]int32{
		"INVALID":        0,
		"BOOL":           1,
		"SMALLINT":       2,
		"INT":            3,
		"BIGINT":         4,
		"FLOAT":          5,
		"UUID":           6,
		"STRING":         7,
		"BYTE_ARRAY":     8,
		"STRING_ARRAY":   9,
		"INT_ARRAY":      10,
		"TIMESTAMP":      11,
		"JSON":           12,
		"UUID_ARRAY":     13,
		"INET":           14,
		"INET_ARRAY":     15,
		"CIDR":           16,
		"CIDR_ARRAY":     17,
		"MAC_ADDR":       18,
		"MAC_ADDR_ARRAY": 19,
	}
)

Enum value maps for ColumnType.

View Source 
var (
	ConnectionType_name = map[int32]string{
		0: "POSTGRES",
	}
	ConnectionType_value = map[string]int32{
		"POSTGRES": 0,
	}
)

Enum value maps for ConnectionType.

View Source 
var (
	ResourceFetchSummary_Status_name = map[int32]string{
		0: "COMPLETE",
		1: "FAILED",
		2: "PARTIAL",
		3: "CANCELED",
	}
	ResourceFetchSummary_Status_value = map[string]int32{
		"COMPLETE": 0,
		"FAILED":   1,
		"PARTIAL":  2,
		"CANCELED": 3,
	}
)

Enum value maps for ResourceFetchSummary_Status.

View Source 
var (
	Diagnostic_Type_name = map[int32]string{
		0: "UNKNOWN",
		1: "RESOLVING",
		2: "ACCESS",
		3: "THROTTLE",
		4: "DATABASE",
		5: "SCHEMA",
		6: "INTERNAL",
	}
	Diagnostic_Type_value = map[string]int32{
		"UNKNOWN":   0,
		"RESOLVING": 1,
		"ACCESS":    2,
		"THROTTLE":  3,
		"DATABASE":  4,
		"SCHEMA":    5,
		"INTERNAL":  6,
	}
)

Enum value maps for Diagnostic_Type.

View Source 
var (
	Diagnostic_Severity_name = map[int32]string{
		0: "INVALID",
		1: "ERROR",
		2: "WARNING",
		3: "PANIC",
	}
	Diagnostic_Severity_value = map[string]int32{
		"INVALID": 0,
		"ERROR":   1,
		"WARNING": 2,
		"PANIC":   3,
	}
)

Enum value maps for Diagnostic_Severity.

View Source 
var File_internal_plugin_proto protoreflect.FileDescriptor
View Source 
var Provider_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "proto.Provider",
	HandlerType: (*ProviderServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetProviderSchema",
			Handler:    _Provider_GetProviderSchema_Handler,
		},
		{
			MethodName: "GetProviderConfig",
			Handler:    _Provider_GetProviderConfig_Handler,
		},
		{
			MethodName: "ConfigureProvider",
			Handler:    _Provider_ConfigureProvider_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "FetchResources",
			Handler:       _Provider_FetchResources_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "internal/plugin.proto",
}

Provider_ServiceDesc is the grpc.ServiceDesc for Provider service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterProviderServer 

func RegisterProviderServer(s grpc.ServiceRegistrar, srv ProviderServer)

Types

type Column 

type Column struct {
	Name        string      `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Description string      `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	Type        ColumnType  `protobuf:"varint,3,opt,name=type,proto3,enum=proto.ColumnType" json:"type,omitempty"`
	Meta        *ColumnMeta `protobuf:"bytes,4,opt,name=meta,proto3" json:"meta,omitempty"`
	// contains filtered or unexported fields
}

func (*Column) Descriptor deprecated 

func (*Column) Descriptor() ([]byte, []int)

Deprecated: Use Column.ProtoReflect.Descriptor instead.

func (*Column) GetDescription 

func (x *Column) GetDescription() string

func (*Column) GetMeta added in v0.5.1 

func (x *Column) GetMeta() *ColumnMeta

func (*Column) GetName 

func (x *Column) GetName() string

func (*Column) GetType 

func (x *Column) GetType() ColumnType

func (*Column) ProtoMessage 

func (*Column) ProtoMessage()

func (*Column) ProtoReflect 

func (x *Column) ProtoReflect() protoreflect.Message

func (*Column) Reset 

func (x *Column) Reset()

func (*Column) String 

func (x *Column) String() string

type ColumnMeta added in v0.5.1 

type ColumnMeta struct {
	Resolver     *ResolverMeta `protobuf:"bytes,1,opt,name=resolver,proto3" json:"resolver,omitempty"`
	IgnoreExists bool          `protobuf:"varint,2,opt,name=IgnoreExists,proto3" json:"IgnoreExists,omitempty"`
	// contains filtered or unexported fields
}

func (*ColumnMeta) Descriptor deprecated added in v0.5.1 

func (*ColumnMeta) Descriptor() ([]byte, []int)

Deprecated: Use ColumnMeta.ProtoReflect.Descriptor instead.

func (*ColumnMeta) GetIgnoreExists added in v0.5.1 

func (x *ColumnMeta) GetIgnoreExists() bool

func (*ColumnMeta) GetResolver added in v0.5.1 

func (x *ColumnMeta) GetResolver() *ResolverMeta

func (*ColumnMeta) ProtoMessage added in v0.5.1 

func (*ColumnMeta) ProtoMessage()

func (*ColumnMeta) ProtoReflect added in v0.5.1 

func (x *ColumnMeta) ProtoReflect() protoreflect.Message

func (*ColumnMeta) Reset added in v0.5.1 

func (x *ColumnMeta) Reset()

func (*ColumnMeta) String added in v0.5.1 

func (x *ColumnMeta) String() string

type ColumnType 

type ColumnType int32
const (
	ColumnType_INVALID        ColumnType = 0
	ColumnType_BOOL           ColumnType = 1
	ColumnType_SMALLINT       ColumnType = 2
	ColumnType_INT            ColumnType = 3
	ColumnType_BIGINT         ColumnType = 4
	ColumnType_FLOAT          ColumnType = 5
	ColumnType_UUID           ColumnType = 6
	ColumnType_STRING         ColumnType = 7
	ColumnType_BYTE_ARRAY     ColumnType = 8
	ColumnType_STRING_ARRAY   ColumnType = 9
	ColumnType_INT_ARRAY      ColumnType = 10
	ColumnType_TIMESTAMP      ColumnType = 11
	ColumnType_JSON           ColumnType = 12
	ColumnType_UUID_ARRAY     ColumnType = 13
	ColumnType_INET           ColumnType = 14
	ColumnType_INET_ARRAY     ColumnType = 15
	ColumnType_CIDR           ColumnType = 16
	ColumnType_CIDR_ARRAY     ColumnType = 17
	ColumnType_MAC_ADDR       ColumnType = 18
	ColumnType_MAC_ADDR_ARRAY ColumnType = 19
)

func (ColumnType) Descriptor 

func (ColumnType) Descriptor() protoreflect.EnumDescriptor

func (ColumnType) Enum 

func (x ColumnType) Enum() *ColumnType

func (ColumnType) EnumDescriptor deprecated 

func (ColumnType) EnumDescriptor() ([]byte, []int)

Deprecated: Use ColumnType.Descriptor instead.

func (ColumnType) Number 

func (x ColumnType) Number() protoreflect.EnumNumber

func (ColumnType) String 

func (x ColumnType) String() string

func (ColumnType) Type 

func (ColumnType) Type() protoreflect.EnumType

type ConfigureProvider 

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

func (*ConfigureProvider) Descriptor deprecated 

func (*ConfigureProvider) Descriptor() ([]byte, []int)

Deprecated: Use ConfigureProvider.ProtoReflect.Descriptor instead.

func (*ConfigureProvider) ProtoMessage 

func (*ConfigureProvider) ProtoMessage()

func (*ConfigureProvider) ProtoReflect 

func (x *ConfigureProvider) ProtoReflect() protoreflect.Message

func (*ConfigureProvider) Reset 

func (x *ConfigureProvider) Reset()

func (*ConfigureProvider) String 

func (x *ConfigureProvider) String() string

type ConfigureProvider_Request 

type ConfigureProvider_Request struct {

	// Version of cloudquery executing this plugin
	CloudqueryVersion string `protobuf:"bytes,1,opt,name=cloudquery_version,json=cloudqueryVersion,proto3" json:"cloudquery_version,omitempty"`
	// Connection details for connecting to the database
	Connection *ConnectionDetails `protobuf:"bytes,2,opt,name=connection,proto3" json:"connection,omitempty"`
	// Holds information such as credentials, regions, accounts, etc'
	Config []byte `protobuf:"bytes,3,opt,name=config,proto3" json:"config,omitempty"`
	// Msgpack encoded: Allows to inject & override fields into resource tables, use this carefully to override fields
	ExtraFields []byte `protobuf:"bytes,5,opt,name=extraFields,proto3" json:"extraFields,omitempty"`
	// contains filtered or unexported fields
}

func (*ConfigureProvider_Request) Descriptor deprecated 

func (*ConfigureProvider_Request) Descriptor() ([]byte, []int)

Deprecated: Use ConfigureProvider_Request.ProtoReflect.Descriptor instead.

func (*ConfigureProvider_Request) GetCloudqueryVersion 

func (x *ConfigureProvider_Request) GetCloudqueryVersion() string

func (*ConfigureProvider_Request) GetConfig 

func (x *ConfigureProvider_Request) GetConfig() []byte

func (*ConfigureProvider_Request) GetConnection 

func (x *ConfigureProvider_Request) GetConnection() *ConnectionDetails

func (*ConfigureProvider_Request) GetExtraFields added in v0.3.0 

func (x *ConfigureProvider_Request) GetExtraFields() []byte

func (*ConfigureProvider_Request) ProtoMessage 

func (*ConfigureProvider_Request) ProtoMessage()

func (*ConfigureProvider_Request) ProtoReflect 

func (x *ConfigureProvider_Request) ProtoReflect() protoreflect.Message

func (*ConfigureProvider_Request) Reset 

func (x *ConfigureProvider_Request) Reset()

func (*ConfigureProvider_Request) String 

func (x *ConfigureProvider_Request) String() string

type ConfigureProvider_Response 

type ConfigureProvider_Response struct {
	Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*ConfigureProvider_Response) Descriptor deprecated 

func (*ConfigureProvider_Response) Descriptor() ([]byte, []int)

Deprecated: Use ConfigureProvider_Response.ProtoReflect.Descriptor instead.

func (*ConfigureProvider_Response) GetError 

func (x *ConfigureProvider_Response) GetError() string

func (*ConfigureProvider_Response) ProtoMessage 

func (*ConfigureProvider_Response) ProtoMessage()

func (*ConfigureProvider_Response) ProtoReflect 

func (x *ConfigureProvider_Response) ProtoReflect() protoreflect.Message

func (*ConfigureProvider_Response) Reset 

func (x *ConfigureProvider_Response) Reset()

func (*ConfigureProvider_Response) String 

func (x *ConfigureProvider_Response) String() string

type ConnectionDetails 

type ConnectionDetails struct {
	Type ConnectionType `protobuf:"varint,1,opt,name=type,proto3,enum=proto.ConnectionType" json:"type,omitempty"`
	Dsn  string         `protobuf:"bytes,2,opt,name=dsn,proto3" json:"dsn,omitempty"`
	// contains filtered or unexported fields
}

func (*ConnectionDetails) Descriptor deprecated 

func (*ConnectionDetails) Descriptor() ([]byte, []int)

Deprecated: Use ConnectionDetails.ProtoReflect.Descriptor instead.

func (*ConnectionDetails) GetDsn 

func (x *ConnectionDetails) GetDsn() string

func (*ConnectionDetails) GetType 

func (x *ConnectionDetails) GetType() ConnectionType

func (*ConnectionDetails) ProtoMessage 

func (*ConnectionDetails) ProtoMessage()

func (*ConnectionDetails) ProtoReflect 

func (x *ConnectionDetails) ProtoReflect() protoreflect.Message

func (*ConnectionDetails) Reset 

func (x *ConnectionDetails) Reset()

func (*ConnectionDetails) String 

func (x *ConnectionDetails) String() string

type ConnectionType 

type ConnectionType int32
const (
	ConnectionType_POSTGRES ConnectionType = 0
)

func (ConnectionType) Descriptor 

func (ConnectionType) Descriptor() protoreflect.EnumDescriptor

func (ConnectionType) Enum 

func (x ConnectionType) Enum() *ConnectionType

func (ConnectionType) EnumDescriptor deprecated 

func (ConnectionType) EnumDescriptor() ([]byte, []int)

Deprecated: Use ConnectionType.Descriptor instead.

func (ConnectionType) Number 

func (x ConnectionType) Number() protoreflect.EnumNumber

func (ConnectionType) String 

func (x ConnectionType) String() string

func (ConnectionType) Type 

func (ConnectionType) Type() protoreflect.EnumType

type Diagnostic added in v0.5.0 

type Diagnostic struct {
	Type     Diagnostic_Type     `protobuf:"varint,1,opt,name=type,proto3,enum=proto.Diagnostic_Type" json:"type,omitempty"`
	Severity Diagnostic_Severity `protobuf:"varint,2,opt,name=severity,proto3,enum=proto.Diagnostic_Severity" json:"severity,omitempty"`
	Summary  string              `protobuf:"bytes,3,opt,name=summary,proto3" json:"summary,omitempty"`
	Detail   string              `protobuf:"bytes,4,opt,name=detail,proto3" json:"detail,omitempty"`
	Resource string              `protobuf:"bytes,5,opt,name=resource,proto3" json:"resource,omitempty"`
	Redacted *Diagnostic         `protobuf:"bytes,6,opt,name=redacted,proto3" json:"redacted,omitempty"`
	// contains filtered or unexported fields
}

func (*Diagnostic) Descriptor deprecated added in v0.5.0 

func (*Diagnostic) Descriptor() ([]byte, []int)

Deprecated: Use Diagnostic.ProtoReflect.Descriptor instead.

func (*Diagnostic) GetDetail added in v0.5.0 

func (x *Diagnostic) GetDetail() string

func (*Diagnostic) GetRedacted added in v0.7.2 

func (x *Diagnostic) GetRedacted() *Diagnostic

func (*Diagnostic) GetResource added in v0.5.0 

func (x *Diagnostic) GetResource() string

func (*Diagnostic) GetSeverity added in v0.5.0 

func (x *Diagnostic) GetSeverity() Diagnostic_Severity

func (*Diagnostic) GetSummary added in v0.5.0 

func (x *Diagnostic) GetSummary() string

func (*Diagnostic) GetType added in v0.5.0 

func (x *Diagnostic) GetType() Diagnostic_Type

func (*Diagnostic) ProtoMessage added in v0.5.0 

func (*Diagnostic) ProtoMessage()

func (*Diagnostic) ProtoReflect added in v0.5.0 

func (x *Diagnostic) ProtoReflect() protoreflect.Message

func (*Diagnostic) Reset added in v0.5.0 

func (x *Diagnostic) Reset()

func (*Diagnostic) String added in v0.5.0 

func (x *Diagnostic) String() string

type Diagnostic_Severity added in v0.5.0 

type Diagnostic_Severity int32
const (
	Diagnostic_INVALID Diagnostic_Severity = 0
	Diagnostic_ERROR   Diagnostic_Severity = 1
	Diagnostic_WARNING Diagnostic_Severity = 2
	Diagnostic_PANIC   Diagnostic_Severity = 3
)

func (Diagnostic_Severity) Descriptor added in v0.5.0 

func (Diagnostic_Severity) Descriptor() protoreflect.EnumDescriptor

func (Diagnostic_Severity) Enum added in v0.5.0 

func (x Diagnostic_Severity) Enum() *Diagnostic_Severity

func (Diagnostic_Severity) EnumDescriptor deprecated added in v0.5.0 

func (Diagnostic_Severity) EnumDescriptor() ([]byte, []int)

Deprecated: Use Diagnostic_Severity.Descriptor instead.

func (Diagnostic_Severity) Number added in v0.5.0 

func (x Diagnostic_Severity) Number() protoreflect.EnumNumber

func (Diagnostic_Severity) String added in v0.5.0 

func (x Diagnostic_Severity) String() string

func (Diagnostic_Severity) Type added in v0.5.0 

func (Diagnostic_Severity) Type() protoreflect.EnumType

type Diagnostic_Type added in v0.5.0 

type Diagnostic_Type int32
const (
	Diagnostic_UNKNOWN   Diagnostic_Type = 0
	Diagnostic_RESOLVING Diagnostic_Type = 1
	Diagnostic_ACCESS    Diagnostic_Type = 2
	Diagnostic_THROTTLE  Diagnostic_Type = 3
	Diagnostic_DATABASE  Diagnostic_Type = 4
	Diagnostic_SCHEMA    Diagnostic_Type = 5
	Diagnostic_INTERNAL  Diagnostic_Type = 6
)

func (Diagnostic_Type) Descriptor added in v0.5.0 

func (Diagnostic_Type) Descriptor() protoreflect.EnumDescriptor

func (Diagnostic_Type) Enum added in v0.5.0 

func (x Diagnostic_Type) Enum() *Diagnostic_Type

func (Diagnostic_Type) EnumDescriptor deprecated added in v0.5.0 

func (Diagnostic_Type) EnumDescriptor() ([]byte, []int)

Deprecated: Use Diagnostic_Type.Descriptor instead.

func (Diagnostic_Type) Number added in v0.5.0 

func (x Diagnostic_Type) Number() protoreflect.EnumNumber

func (Diagnostic_Type) String added in v0.5.0 

func (x Diagnostic_Type) String() string

func (Diagnostic_Type) Type added in v0.5.0 

func (Diagnostic_Type) Type() protoreflect.EnumType

type DialectMigration added in v0.7.0 

type DialectMigration struct {
	Migrations map[string][]byte `` /* 161-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*DialectMigration) Descriptor deprecated added in v0.7.0 

func (*DialectMigration) Descriptor() ([]byte, []int)

Deprecated: Use DialectMigration.ProtoReflect.Descriptor instead.

func (*DialectMigration) GetMigrations added in v0.7.0 

func (x *DialectMigration) GetMigrations() map[string][]byte

func (*DialectMigration) ProtoMessage added in v0.7.0 

func (*DialectMigration) ProtoMessage()

func (*DialectMigration) ProtoReflect added in v0.7.0 

func (x *DialectMigration) ProtoReflect() protoreflect.Message

func (*DialectMigration) Reset added in v0.7.0 

func (x *DialectMigration) Reset()

func (*DialectMigration) String added in v0.7.0 

func (x *DialectMigration) String() string

type FetchResources 

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

func (*FetchResources) Descriptor deprecated 

func (*FetchResources) Descriptor() ([]byte, []int)

Deprecated: Use FetchResources.ProtoReflect.Descriptor instead.

func (*FetchResources) ProtoMessage 

func (*FetchResources) ProtoMessage()

func (*FetchResources) ProtoReflect 

func (x *FetchResources) ProtoReflect() protoreflect.Message

func (*FetchResources) Reset 

func (x *FetchResources) Reset()

func (*FetchResources) String 

func (x *FetchResources) String() string

type FetchResources_Request 

type FetchResources_Request struct {

	// list of resources provider is requested to fetch
	Resources []string `protobuf:"bytes,1,rep,name=resources,proto3" json:"resources,omitempty"`
	// trigger to enable partial fetching
	PartialFetchingEnabled bool `` /* 130-byte string literal not displayed */
	// if value is more than 0 it enables throttling for concurrent fetch
	ParallelFetchingLimit uint64 `` /* 127-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*FetchResources_Request) Descriptor deprecated 

func (*FetchResources_Request) Descriptor() ([]byte, []int)

Deprecated: Use FetchResources_Request.ProtoReflect.Descriptor instead.

func (*FetchResources_Request) GetParallelFetchingLimit added in v0.5.1 

func (x *FetchResources_Request) GetParallelFetchingLimit() uint64

func (*FetchResources_Request) GetPartialFetchingEnabled added in v0.4.0 

func (x *FetchResources_Request) GetPartialFetchingEnabled() bool

func (*FetchResources_Request) GetResources 

func (x *FetchResources_Request) GetResources() []string

func (*FetchResources_Request) ProtoMessage 

func (*FetchResources_Request) ProtoMessage()

func (*FetchResources_Request) ProtoReflect 

func (x *FetchResources_Request) ProtoReflect() protoreflect.Message

func (*FetchResources_Request) Reset 

func (x *FetchResources_Request) Reset()

func (*FetchResources_Request) String 

func (x *FetchResources_Request) String() string

type FetchResources_Response 

type FetchResources_Response struct {

	// map of resources that have finished fetching
	FinishedResources map[string]bool `` /* 201-byte string literal not displayed */
	// Amount of resources collected so far
	ResourceCount uint64 `protobuf:"varint,2,opt,name=resource_count,json=resourceCount,proto3" json:"resource_count,omitempty"`
	// Error value if any, if returned the stream will be canceled
	Error string `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	// list of resources where the fetching failed
	PartialFetchFailedResources []*PartialFetchFailedResource `` /* 146-byte string literal not displayed */
	// fetch summary of resource that finished
	Summary *ResourceFetchSummary `protobuf:"bytes,5,opt,name=summary,proto3" json:"summary,omitempty"`
	// name of resource that finished
	Resource string `protobuf:"bytes,6,opt,name=resource,proto3" json:"resource,omitempty"`
	// contains filtered or unexported fields
}

func (*FetchResources_Response) Descriptor deprecated 

func (*FetchResources_Response) Descriptor() ([]byte, []int)

Deprecated: Use FetchResources_Response.ProtoReflect.Descriptor instead.

func (*FetchResources_Response) GetError 

func (x *FetchResources_Response) GetError() string

func (*FetchResources_Response) GetFinishedResources 

func (x *FetchResources_Response) GetFinishedResources() map[string]bool

func (*FetchResources_Response) GetPartialFetchFailedResources added in v0.4.0 

func (x *FetchResources_Response) GetPartialFetchFailedResources() []*PartialFetchFailedResource

func (*FetchResources_Response) GetResource added in v0.5.0 

func (x *FetchResources_Response) GetResource() string

func (*FetchResources_Response) GetResourceCount 

func (x *FetchResources_Response) GetResourceCount() uint64

func (*FetchResources_Response) GetSummary added in v0.5.0 

func (x *FetchResources_Response) GetSummary() *ResourceFetchSummary

func (*FetchResources_Response) ProtoMessage 

func (*FetchResources_Response) ProtoMessage()

func (*FetchResources_Response) ProtoReflect 

func (x *FetchResources_Response) ProtoReflect() protoreflect.Message

func (*FetchResources_Response) Reset 

func (x *FetchResources_Response) Reset()

func (*FetchResources_Response) String 

func (x *FetchResources_Response) String() string

type GetProviderConfig 

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

func (*GetProviderConfig) Descriptor deprecated 

func (*GetProviderConfig) Descriptor() ([]byte, []int)

Deprecated: Use GetProviderConfig.ProtoReflect.Descriptor instead.

func (*GetProviderConfig) ProtoMessage 

func (*GetProviderConfig) ProtoMessage()

func (*GetProviderConfig) ProtoReflect 

func (x *GetProviderConfig) ProtoReflect() protoreflect.Message

func (*GetProviderConfig) Reset 

func (x *GetProviderConfig) Reset()

func (*GetProviderConfig) String 

func (x *GetProviderConfig) String() string

type GetProviderConfig_Request 

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

func (*GetProviderConfig_Request) Descriptor deprecated 

func (*GetProviderConfig_Request) Descriptor() ([]byte, []int)

Deprecated: Use GetProviderConfig_Request.ProtoReflect.Descriptor instead.

func (*GetProviderConfig_Request) ProtoMessage 

func (*GetProviderConfig_Request) ProtoMessage()

func (*GetProviderConfig_Request) ProtoReflect 

func (x *GetProviderConfig_Request) ProtoReflect() protoreflect.Message

func (*GetProviderConfig_Request) Reset 

func (x *GetProviderConfig_Request) Reset()

func (*GetProviderConfig_Request) String 

func (x *GetProviderConfig_Request) String() string

type GetProviderConfig_Response 

type GetProviderConfig_Response struct {
	Name    string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	Config  []byte `protobuf:"bytes,3,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

func (*GetProviderConfig_Response) Descriptor deprecated 

func (*GetProviderConfig_Response) Descriptor() ([]byte, []int)

Deprecated: Use GetProviderConfig_Response.ProtoReflect.Descriptor instead.

func (*GetProviderConfig_Response) GetConfig 

func (x *GetProviderConfig_Response) GetConfig() []byte

func (*GetProviderConfig_Response) GetName 

func (x *GetProviderConfig_Response) GetName() string

func (*GetProviderConfig_Response) GetVersion 

func (x *GetProviderConfig_Response) GetVersion() string

func (*GetProviderConfig_Response) ProtoMessage 

func (*GetProviderConfig_Response) ProtoMessage()

func (*GetProviderConfig_Response) ProtoReflect 

func (x *GetProviderConfig_Response) ProtoReflect() protoreflect.Message

func (*GetProviderConfig_Response) Reset 

func (x *GetProviderConfig_Response) Reset()

func (*GetProviderConfig_Response) String 

func (x *GetProviderConfig_Response) String() string

type GetProviderSchema 

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

func (*GetProviderSchema) Descriptor deprecated 

func (*GetProviderSchema) Descriptor() ([]byte, []int)

Deprecated: Use GetProviderSchema.ProtoReflect.Descriptor instead.

func (*GetProviderSchema) ProtoMessage 

func (*GetProviderSchema) ProtoMessage()

func (*GetProviderSchema) ProtoReflect 

func (x *GetProviderSchema) ProtoReflect() protoreflect.Message

func (*GetProviderSchema) Reset 

func (x *GetProviderSchema) Reset()

func (*GetProviderSchema) String 

func (x *GetProviderSchema) String() string

type GetProviderSchema_Request 

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

func (*GetProviderSchema_Request) Descriptor deprecated 

func (*GetProviderSchema_Request) Descriptor() ([]byte, []int)

Deprecated: Use GetProviderSchema_Request.ProtoReflect.Descriptor instead.

func (*GetProviderSchema_Request) ProtoMessage 

func (*GetProviderSchema_Request) ProtoMessage()

func (*GetProviderSchema_Request) ProtoReflect 

func (x *GetProviderSchema_Request) ProtoReflect() protoreflect.Message

func (*GetProviderSchema_Request) Reset 

func (x *GetProviderSchema_Request) Reset()

func (*GetProviderSchema_Request) String 

func (x *GetProviderSchema_Request) String() string

type GetProviderSchema_Response 

type GetProviderSchema_Response struct {
	Name           string                       `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Version        string                       `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	ResourceTables map[string]*Table            `` /* 191-byte string literal not displayed */
	Migrations     map[string]*DialectMigration `` /* 161-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*GetProviderSchema_Response) Descriptor deprecated 

func (*GetProviderSchema_Response) Descriptor() ([]byte, []int)

Deprecated: Use GetProviderSchema_Response.ProtoReflect.Descriptor instead.

func (*GetProviderSchema_Response) GetMigrations added in v0.3.3 

func (x *GetProviderSchema_Response) GetMigrations() map[string]*DialectMigration

func (*GetProviderSchema_Response) GetName 

func (x *GetProviderSchema_Response) GetName() string

func (*GetProviderSchema_Response) GetResourceTables 

func (x *GetProviderSchema_Response) GetResourceTables() map[string]*Table

func (*GetProviderSchema_Response) GetVersion 

func (x *GetProviderSchema_Response) GetVersion() string

func (*GetProviderSchema_Response) ProtoMessage 

func (*GetProviderSchema_Response) ProtoMessage()

func (*GetProviderSchema_Response) ProtoReflect 

func (x *GetProviderSchema_Response) ProtoReflect() protoreflect.Message

func (*GetProviderSchema_Response) Reset 

func (x *GetProviderSchema_Response) Reset()

func (*GetProviderSchema_Response) String 

func (x *GetProviderSchema_Response) String() string

type PartialFetchFailedResource added in v0.4.0 

type PartialFetchFailedResource struct {

	// table name of the failed resource fetch
	TableName string `protobuf:"bytes,1,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
	// root/parent table name
	RootTableName string `protobuf:"bytes,2,opt,name=root_table_name,json=rootTableName,proto3" json:"root_table_name,omitempty"`
	// root/parent primary key values
	RootPrimaryKeyValues []string `protobuf:"bytes,3,rep,name=root_primary_key_values,json=rootPrimaryKeyValues,proto3" json:"root_primary_key_values,omitempty"`
	// error message for this resource fetch failure
	Error string `protobuf:"bytes,4,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*PartialFetchFailedResource) Descriptor deprecated added in v0.4.0 

func (*PartialFetchFailedResource) Descriptor() ([]byte, []int)

Deprecated: Use PartialFetchFailedResource.ProtoReflect.Descriptor instead.

func (*PartialFetchFailedResource) GetError added in v0.4.0 

func (x *PartialFetchFailedResource) GetError() string

func (*PartialFetchFailedResource) GetRootPrimaryKeyValues added in v0.4.0 

func (x *PartialFetchFailedResource) GetRootPrimaryKeyValues() []string

func (*PartialFetchFailedResource) GetRootTableName added in v0.4.0 

func (x *PartialFetchFailedResource) GetRootTableName() string

func (*PartialFetchFailedResource) GetTableName added in v0.4.0 

func (x *PartialFetchFailedResource) GetTableName() string

func (*PartialFetchFailedResource) ProtoMessage added in v0.4.0 

func (*PartialFetchFailedResource) ProtoMessage()

func (*PartialFetchFailedResource) ProtoReflect added in v0.4.0 

func (x *PartialFetchFailedResource) ProtoReflect() protoreflect.Message

func (*PartialFetchFailedResource) Reset added in v0.4.0 

func (x *PartialFetchFailedResource) Reset()

func (*PartialFetchFailedResource) String added in v0.4.0 

func (x *PartialFetchFailedResource) String() string

type ProviderClient 

type ProviderClient interface {
	// Information about what a provider supports/expects
	GetProviderSchema(ctx context.Context, in *GetProviderSchema_Request, opts ...grpc.CallOption) (*GetProviderSchema_Response, error)
	// Gets a provider's configuration example
	GetProviderConfig(ctx context.Context, in *GetProviderConfig_Request, opts ...grpc.CallOption) (*GetProviderConfig_Response, error)
	// One-time initialization, called before other functions below
	ConfigureProvider(ctx context.Context, in *ConfigureProvider_Request, opts ...grpc.CallOption) (*ConfigureProvider_Response, error)
	// Fetch Provider Resources
	FetchResources(ctx context.Context, in *FetchResources_Request, opts ...grpc.CallOption) (Provider_FetchResourcesClient, error)
}

ProviderClient is the client API for Provider service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewProviderClient 

func NewProviderClient(cc grpc.ClientConnInterface) ProviderClient

type ProviderServer 

type ProviderServer interface {
	// Information about what a provider supports/expects
	GetProviderSchema(context.Context, *GetProviderSchema_Request) (*GetProviderSchema_Response, error)
	// Gets a provider's configuration example
	GetProviderConfig(context.Context, *GetProviderConfig_Request) (*GetProviderConfig_Response, error)
	// One-time initialization, called before other functions below
	ConfigureProvider(context.Context, *ConfigureProvider_Request) (*ConfigureProvider_Response, error)
	// Fetch Provider Resources
	FetchResources(*FetchResources_Request, Provider_FetchResourcesServer) error
	// contains filtered or unexported methods
}

ProviderServer is the server API for Provider service. All implementations must embed UnimplementedProviderServer for forward compatibility

type Provider_FetchResourcesClient 

type Provider_FetchResourcesClient interface {
	Recv() (*FetchResources_Response, error)
	grpc.ClientStream
}

type Provider_FetchResourcesServer 

type Provider_FetchResourcesServer interface {
	Send(*FetchResources_Response) error
	grpc.ServerStream
}

type ResolverMeta added in v0.5.1 

type ResolverMeta struct {
	Name    string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Builtin bool   `protobuf:"varint,2,opt,name=builtin,proto3" json:"builtin,omitempty"`
	// contains filtered or unexported fields
}

func (*ResolverMeta) Descriptor deprecated added in v0.5.1 

func (*ResolverMeta) Descriptor() ([]byte, []int)

Deprecated: Use ResolverMeta.ProtoReflect.Descriptor instead.

func (*ResolverMeta) GetBuiltin added in v0.5.1 

func (x *ResolverMeta) GetBuiltin() bool

func (*ResolverMeta) GetName added in v0.5.1 

func (x *ResolverMeta) GetName() string

func (*ResolverMeta) ProtoMessage added in v0.5.1 

func (*ResolverMeta) ProtoMessage()

func (*ResolverMeta) ProtoReflect added in v0.5.1 

func (x *ResolverMeta) ProtoReflect() protoreflect.Message

func (*ResolverMeta) Reset added in v0.5.1 

func (x *ResolverMeta) Reset()

func (*ResolverMeta) String added in v0.5.1 

func (x *ResolverMeta) String() string

type ResourceFetchSummary added in v0.5.0 

type ResourceFetchSummary struct {

	// Execution status of resource
	Status ResourceFetchSummary_Status `protobuf:"varint,1,opt,name=status,proto3,enum=proto.ResourceFetchSummary_Status" json:"status,omitempty"`
	// Total Amount of resources collected by this resource
	ResourceCount uint64 `protobuf:"varint,2,opt,name=resource_count,json=resourceCount,proto3" json:"resource_count,omitempty"`
	// list of diagnostic returned from a resource fetch
	Diagnostics []*Diagnostic `protobuf:"bytes,3,rep,name=diagnostics,proto3" json:"diagnostics,omitempty"`
	// contains filtered or unexported fields
}

ResourceFetchSummary includes a summarized report of a fetched resource, such as total amount of resources collected, status of the fetch and any diagnostics found while executing fetch on it.

func (*ResourceFetchSummary) Descriptor deprecated added in v0.5.0 

func (*ResourceFetchSummary) Descriptor() ([]byte, []int)

Deprecated: Use ResourceFetchSummary.ProtoReflect.Descriptor instead.

func (*ResourceFetchSummary) GetDiagnostics added in v0.5.0 

func (x *ResourceFetchSummary) GetDiagnostics() []*Diagnostic

func (*ResourceFetchSummary) GetResourceCount added in v0.5.0 

func (x *ResourceFetchSummary) GetResourceCount() uint64

func (*ResourceFetchSummary) GetStatus added in v0.5.0 

func (x *ResourceFetchSummary) GetStatus() ResourceFetchSummary_Status

func (*ResourceFetchSummary) ProtoMessage added in v0.5.0 

func (*ResourceFetchSummary) ProtoMessage()

func (*ResourceFetchSummary) ProtoReflect added in v0.5.0 

func (x *ResourceFetchSummary) ProtoReflect() protoreflect.Message

func (*ResourceFetchSummary) Reset added in v0.5.0 

func (x *ResourceFetchSummary) Reset()

func (*ResourceFetchSummary) String added in v0.5.0 

func (x *ResourceFetchSummary) String() string

type ResourceFetchSummary_Status added in v0.5.0 

type ResourceFetchSummary_Status int32

Execution status of the resource fetch execution 

const (
	// Execution was completed successfully without any errors/diagnostics
	ResourceFetchSummary_COMPLETE ResourceFetchSummary_Status = 0
	// Execution failed and wasn't able to fetch any resource
	ResourceFetchSummary_FAILED ResourceFetchSummary_Status = 1
	// Execution was partial, one or more resources failed to resolve/fetch
	ResourceFetchSummary_PARTIAL ResourceFetchSummary_Status = 2
	// Execution was canceled preemptively
	ResourceFetchSummary_CANCELED ResourceFetchSummary_Status = 3
)

func (ResourceFetchSummary_Status) Descriptor added in v0.5.0 

func (ResourceFetchSummary_Status) Descriptor() protoreflect.EnumDescriptor

func (ResourceFetchSummary_Status) Enum added in v0.5.0 

func (x ResourceFetchSummary_Status) Enum() *ResourceFetchSummary_Status

func (ResourceFetchSummary_Status) EnumDescriptor deprecated added in v0.5.0 

func (ResourceFetchSummary_Status) EnumDescriptor() ([]byte, []int)

Deprecated: Use ResourceFetchSummary_Status.Descriptor instead.

func (ResourceFetchSummary_Status) Number added in v0.5.0 

func (x ResourceFetchSummary_Status) Number() protoreflect.EnumNumber

func (ResourceFetchSummary_Status) String added in v0.5.0 

func (x ResourceFetchSummary_Status) String() string

func (ResourceFetchSummary_Status) Type added in v0.5.0 

func (ResourceFetchSummary_Status) Type() protoreflect.EnumType

type Table 

type Table struct {
	Name        string                `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Description string                `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	Columns     []*Column             `protobuf:"bytes,3,rep,name=columns,proto3" json:"columns,omitempty"`
	Relations   []*Table              `protobuf:"bytes,4,rep,name=relations,proto3" json:"relations,omitempty"`
	Options     *TableCreationOptions `protobuf:"bytes,5,opt,name=options,proto3,oneof" json:"options,omitempty"`
	// contains filtered or unexported fields
}

Table is the definition of how a table is defined in a provider

func (*Table) Descriptor deprecated 

func (*Table) Descriptor() ([]byte, []int)

Deprecated: Use Table.ProtoReflect.Descriptor instead.

func (*Table) GetColumns 

func (x *Table) GetColumns() []*Column

func (*Table) GetDescription 

func (x *Table) GetDescription() string

func (*Table) GetName 

func (x *Table) GetName() string

func (*Table) GetOptions added in v0.3.0 

func (x *Table) GetOptions() *TableCreationOptions

func (*Table) GetRelations 

func (x *Table) GetRelations() []*Table

func (*Table) ProtoMessage 

func (*Table) ProtoMessage()

func (*Table) ProtoReflect 

func (x *Table) ProtoReflect() protoreflect.Message

func (*Table) Reset 

func (x *Table) Reset()

func (*Table) String 

func (x *Table) String() string

type TableCreationOptions added in v0.3.0 

type TableCreationOptions struct {
	PrimaryKeys []string `protobuf:"bytes,1,rep,name=PrimaryKeys,proto3" json:"PrimaryKeys,omitempty"`
	// contains filtered or unexported fields
}

func (*TableCreationOptions) Descriptor deprecated added in v0.3.0 

func (*TableCreationOptions) Descriptor() ([]byte, []int)

Deprecated: Use TableCreationOptions.ProtoReflect.Descriptor instead.

func (*TableCreationOptions) GetPrimaryKeys added in v0.3.0 

func (x *TableCreationOptions) GetPrimaryKeys() []string

func (*TableCreationOptions) ProtoMessage added in v0.3.0 

func (*TableCreationOptions) ProtoMessage()

func (*TableCreationOptions) ProtoReflect added in v0.3.0 

func (x *TableCreationOptions) ProtoReflect() protoreflect.Message

func (*TableCreationOptions) Reset added in v0.3.0 

func (x *TableCreationOptions) Reset()

func (*TableCreationOptions) String added in v0.3.0 

func (x *TableCreationOptions) String() string

type UnimplementedProviderServer 

type UnimplementedProviderServer struct {
}

UnimplementedProviderServer must be embedded to have forward compatible implementations.

func (UnimplementedProviderServer) ConfigureProvider 

func (UnimplementedProviderServer) ConfigureProvider(context.Context, *ConfigureProvider_Request) (*ConfigureProvider_Response, error)

func (UnimplementedProviderServer) FetchResources 

func (UnimplementedProviderServer) FetchResources(*FetchResources_Request, Provider_FetchResourcesServer) error

func (UnimplementedProviderServer) GetProviderConfig 

func (UnimplementedProviderServer) GetProviderConfig(context.Context, *GetProviderConfig_Request) (*GetProviderConfig_Response, error)

func (UnimplementedProviderServer) GetProviderSchema 

func (UnimplementedProviderServer) GetProviderSchema(context.Context, *GetProviderSchema_Request) (*GetProviderSchema_Response, error)

type UnsafeProviderServer added in v0.4.0 

type UnsafeProviderServer interface {
	// contains filtered or unexported methods
}

UnsafeProviderServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ProviderServer will result in compilation errors.

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.