source

package
v1.1.6 Latest Latest
Warning

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

 Go to latest Published: Aug 22, 2024 License: MPL-2.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewSourceDynamoDBResource added in v1.1.4 

func NewSourceDynamoDBResource() res.Resource

func NewSourcePostgreSQLResource 

func NewSourcePostgreSQLResource() res.Resource

Types

type SourceDynamoDBResource added in v1.1.4 

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

SourceDynamoDBResource defines the resource implementation.

func (*SourceDynamoDBResource) Configure added in v1.1.4 

func (r *SourceDynamoDBResource) Configure(ctx context.Context, req res.ConfigureRequest, resp *res.ConfigureResponse)

func (*SourceDynamoDBResource) Create added in v1.1.4 

func (r *SourceDynamoDBResource) Create(ctx context.Context, req res.CreateRequest, resp *res.CreateResponse)

func (*SourceDynamoDBResource) Delete added in v1.1.4 

func (r *SourceDynamoDBResource) Delete(ctx context.Context, req res.DeleteRequest, resp *res.DeleteResponse)

func (*SourceDynamoDBResource) ImportState added in v1.1.4 

func (r *SourceDynamoDBResource) ImportState(ctx context.Context, req res.ImportStateRequest, resp *res.ImportStateResponse)

func (*SourceDynamoDBResource) Metadata added in v1.1.4 

func (r *SourceDynamoDBResource) Metadata(ctx context.Context, req res.MetadataRequest, resp *res.MetadataResponse)

func (*SourceDynamoDBResource) Read added in v1.1.4 

func (r *SourceDynamoDBResource) Read(ctx context.Context, req res.ReadRequest, resp *res.ReadResponse)

func (*SourceDynamoDBResource) Schema added in v1.1.4 

func (r *SourceDynamoDBResource) Schema(ctx context.Context, req res.SchemaRequest, resp *res.SchemaResponse)

func (*SourceDynamoDBResource) Update added in v1.1.4 

func (r *SourceDynamoDBResource) Update(ctx context.Context, req res.UpdateRequest, resp *res.UpdateResponse)

type SourceDynamoDBResourceModel added in v1.1.4 

type SourceDynamoDBResourceModel struct {
	ID                            types.String `tfsdk:"id"`
	Name                          types.String `tfsdk:"name"`
	Connector                     types.String `tfsdk:"connector"`
	AWSRegion                     types.String `tfsdk:"aws_region"`
	AWSAccessKeyID                types.String `tfsdk:"aws_access_key_id"`
	AWSSecretKey                  types.String `tfsdk:"aws_secret_key"`
	S3ExportBucketName            types.String `tfsdk:"s3_export_bucket_name"`
	TableIncludeListUserDefined   types.String `tfsdk:"table_include_list_user_defined"`
	BatchSize                     types.Int64  `tfsdk:"batch_size"`
	DynamoDBServiceEndpoint       types.String `tfsdk:"dynamodb_service_endpoint"`
	PollTimeoutMS                 types.Int64  `tfsdk:"poll_timeout_ms"`
	IncrementalSnapshotChunkSize  types.Int64  `tfsdk:"incremental_snapshot_chunk_size"`
	IncrementalSnapshotMaxThreads types.Int64  `tfsdk:"incremental_snapshot_max_threads"`
	IncrementalSnapshotIntervalMS types.Int64  `tfsdk:"incremental_snapshot_interval_ms"`
	FullExportExpirationTimeMS    types.Int64  `tfsdk:"full_export_expiration_time_ms"`
	SignalKafkaPollTimeoutMS      types.Int64  `tfsdk:"signal_kafka_poll_timeout_ms"`
}

SourceDynamoDBResourceModel describes the resource data model.

type SourcePostgreSQLResource added in v1.0.2 

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

SourcePostgreSQLResource defines the resource implementation.

func (*SourcePostgreSQLResource) Configure added in v1.0.2 

func (r *SourcePostgreSQLResource) Configure(ctx context.Context, req res.ConfigureRequest, resp *res.ConfigureResponse)

func (*SourcePostgreSQLResource) Create added in v1.0.2 

func (r *SourcePostgreSQLResource) Create(ctx context.Context, req res.CreateRequest, resp *res.CreateResponse)

func (*SourcePostgreSQLResource) Delete added in v1.0.2 

func (r *SourcePostgreSQLResource) Delete(ctx context.Context, req res.DeleteRequest, resp *res.DeleteResponse)

func (*SourcePostgreSQLResource) ImportState added in v1.0.2 

func (r *SourcePostgreSQLResource) ImportState(ctx context.Context, req res.ImportStateRequest, resp *res.ImportStateResponse)

func (*SourcePostgreSQLResource) Metadata added in v1.0.2 

func (r *SourcePostgreSQLResource) Metadata(ctx context.Context, req res.MetadataRequest, resp *res.MetadataResponse)

func (*SourcePostgreSQLResource) Read added in v1.0.2 

func (r *SourcePostgreSQLResource) Read(ctx context.Context, req res.ReadRequest, resp *res.ReadResponse)

func (*SourcePostgreSQLResource) Schema added in v1.0.2 

func (r *SourcePostgreSQLResource) Schema(ctx context.Context, req res.SchemaRequest, resp *res.SchemaResponse)

func (*SourcePostgreSQLResource) Update added in v1.0.2 

func (r *SourcePostgreSQLResource) Update(ctx context.Context, req res.UpdateRequest, resp *res.UpdateResponse)

type SourcePostgreSQLResourceModel added in v1.0.2 

type SourcePostgreSQLResourceModel struct {
	ID                                      types.String `tfsdk:"id"`
	Name                                    types.String `tfsdk:"name"`
	Connector                               types.String `tfsdk:"connector"`
	DatabaseHostname                        types.String `tfsdk:"database_hostname"`
	DatabasePort                            types.Int64  `tfsdk:"database_port"`
	DatabaseUser                            types.String `tfsdk:"database_user"`
	DatabasePassword                        types.String `tfsdk:"database_password"`
	DatabaseDbname                          types.String `tfsdk:"database_dbname"`
	DatabaseSSLMode                         types.String `tfsdk:"database_sslmode"`
	SchemaIncludeList                       types.String `tfsdk:"schema_include_list"`
	TableIncludeList                        types.String `tfsdk:"table_include_list"`
	SignalDataCollectionSchemaOrDatabase    types.String `tfsdk:"signal_data_collection_schema_or_database"`
	ColumnIncludeList                       types.String `tfsdk:"column_include_list"`
	HeartbeatEnabled                        types.Bool   `tfsdk:"heartbeat_enabled"`
	HeartbeatDataCollectionSchemaOrDatabase types.String `tfsdk:"heartbeat_data_collection_schema_or_database"`
	IncludeSourceDBNameInTableName          types.Bool   `tfsdk:"include_source_db_name_in_table_name"`
	SlotName                                types.String `tfsdk:"slot_name"`
	PublicationName                         types.String `tfsdk:"publication_name"`
	BinaryHandlingMode                      types.String `tfsdk:"binary_handling_mode"`
	SSHEnabled                              types.Bool   `tfsdk:"ssh_enabled"`
	SSHHost                                 types.String `tfsdk:"ssh_host"`
	SSHPort                                 types.String `tfsdk:"ssh_port"`
	SSHUser                                 types.String `tfsdk:"ssh_user"`
}

SourcePostgreSQLResourceModel describes the resource data model.

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.