streamconnection

package

v1.30.0 Latest Latest Go to latest Published: Mar 20, 2025 License: MPL-2.0 Imports: 24 Imported by: 0

Documentation ¶

Index ¶

Variables
func DataSource() datasource.DataSource
func DeleteStreamConnection(ctx context.Context, api admin.StreamsApi, ...) error
func NewStreamConnectionReq(ctx context.Context, plan *TFStreamConnectionModel) (*admin.StreamsConnection, diag.Diagnostics)
func NewStreamConnectionUpdateReq(ctx context.Context, plan *TFStreamConnectionModel) (*admin.StreamsConnection, diag.Diagnostics)
func PluralDataSource() datasource.DataSource
func Resource() resource.Resource
func ResourceSchema(ctx context.Context) schema.Schema
type TFAWSModel
type TFConnectionAuthenticationModel
type TFConnectionSecurityModel
type TFDbRoleToExecuteModel
type TFNetworkingAccessModel
type TFNetworkingModel
type TFStreamConnectionModel
- func NewTFStreamConnection(ctx context.Context, projID, instanceName string, currAuthConfig *types.Object, ...) (*TFStreamConnectionModel, diag.Diagnostics)
type TFStreamConnectionsDSModel
- func NewTFStreamConnections(ctx context.Context, streamConnectionsConfig *TFStreamConnectionsDSModel, ...) (*TFStreamConnectionsDSModel, diag.Diagnostics)

Constants ¶

This section is empty.

Variables ¶

View Source

var AWSObjectType = types.ObjectType{AttrTypes: map[string]attr.Type{
	"role_arn": types.StringType,
}}

View Source

var ConnectionAuthenticationObjectType = types.ObjectType{AttrTypes: map[string]attr.Type{
	"mechanism": types.StringType,
	"password":  types.StringType,
	"username":  types.StringType,
}}

View Source

var ConnectionSecurityObjectType = types.ObjectType{AttrTypes: map[string]attr.Type{
	"broker_public_certificate": types.StringType,
	"protocol":                  types.StringType,
}}

View Source

var DBRoleToExecuteObjectType = types.ObjectType{AttrTypes: map[string]attr.Type{
	"role": types.StringType,
	"type": types.StringType,
}}

View Source

var NetworkingAccessObjectType = types.ObjectType{AttrTypes: map[string]attr.Type{
	"type":          types.StringType,
	"connection_id": types.StringType,
}}

View Source

var NetworkingObjectType = types.ObjectType{AttrTypes: map[string]attr.Type{
	"access": NetworkingAccessObjectType,
}}

Functions ¶

func DataSource ¶

func DataSource() datasource.DataSource

func DeleteStreamConnection ¶ added in v1.25.0

func DeleteStreamConnection(ctx context.Context, api admin.StreamsApi, projectID, instanceName, connectionName string, timeout time.Duration) error

func NewStreamConnectionReq ¶

func NewStreamConnectionReq(ctx context.Context, plan *TFStreamConnectionModel) (*admin.StreamsConnection, diag.Diagnostics)

func NewStreamConnectionUpdateReq ¶ added in v1.30.0

func NewStreamConnectionUpdateReq(ctx context.Context, plan *TFStreamConnectionModel) (*admin.StreamsConnection, diag.Diagnostics)

func PluralDataSource ¶

func PluralDataSource() datasource.DataSource

func Resource ¶

func Resource() resource.Resource

func ResourceSchema ¶ added in v1.22.0

func ResourceSchema(ctx context.Context) schema.Schema

Types ¶

type TFAWSModel ¶ added in v1.29.0

type TFAWSModel struct {
	RoleArn types.String `tfsdk:"role_arn"`
}

type TFConnectionAuthenticationModel ¶

type TFConnectionAuthenticationModel struct {
	Mechanism types.String `tfsdk:"mechanism"`
	Password  types.String `tfsdk:"password"`
	Username  types.String `tfsdk:"username"`
}

type TFConnectionSecurityModel ¶

type TFConnectionSecurityModel struct {
	BrokerPublicCertificate types.String `tfsdk:"broker_public_certificate"`
	Protocol                types.String `tfsdk:"protocol"`
}

type TFDbRoleToExecuteModel ¶ added in v1.15.2

type TFDbRoleToExecuteModel struct {
	Role types.String `tfsdk:"role"`
	Type types.String `tfsdk:"type"`
}

type TFNetworkingAccessModel ¶ added in v1.25.0

type TFNetworkingAccessModel struct {
	Type         types.String `tfsdk:"type"`
	ConnectionID types.String `tfsdk:"connection_id"`
}

type TFNetworkingModel ¶ added in v1.25.0

type TFNetworkingModel struct {
	Access types.Object `tfsdk:"access"`
}

type TFStreamConnectionModel ¶

type TFStreamConnectionModel struct {
	ID               types.String `tfsdk:"id"`
	ProjectID        types.String `tfsdk:"project_id"`
	InstanceName     types.String `tfsdk:"instance_name"`
	ConnectionName   types.String `tfsdk:"connection_name"`
	Type             types.String `tfsdk:"type"`
	ClusterName      types.String `tfsdk:"cluster_name"`
	Authentication   types.Object `tfsdk:"authentication"`
	BootstrapServers types.String `tfsdk:"bootstrap_servers"`
	Config           types.Map    `tfsdk:"config"`
	Security         types.Object `tfsdk:"security"`
	DBRoleToExecute  types.Object `tfsdk:"db_role_to_execute"`
	Networking       types.Object `tfsdk:"networking"`
	AWS              types.Object `tfsdk:"aws"`
	// https connection
	Headers types.Map    `tfsdk:"headers"`
	URL     types.String `tfsdk:"url"`
}

func NewTFStreamConnection ¶

func NewTFStreamConnection(ctx context.Context, projID, instanceName string, currAuthConfig *types.Object, apiResp *admin.StreamsConnection) (*TFStreamConnectionModel, diag.Diagnostics)

type TFStreamConnectionsDSModel ¶

type TFStreamConnectionsDSModel struct {
	ID           types.String              `tfsdk:"id"`
	ProjectID    types.String              `tfsdk:"project_id"`
	InstanceName types.String              `tfsdk:"instance_name"`
	Results      []TFStreamConnectionModel `tfsdk:"results"`
	PageNum      types.Int64               `tfsdk:"page_num"`
	ItemsPerPage types.Int64               `tfsdk:"items_per_page"`
	TotalCount   types.Int64               `tfsdk:"total_count"`
}

func NewTFStreamConnections ¶

func NewTFStreamConnections(ctx context.Context,
	streamConnectionsConfig *TFStreamConnectionsDSModel,
	paginatedResult *admin.PaginatedApiStreamsConnection) (*TFStreamConnectionsDSModel, diag.Diagnostics)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL