Documentation ¶
Index ¶
- Variables
- func DataSource() datasource.DataSource
- func NewStreamConnectionReq(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 TFConnectionAuthenticationModel
- type TFConnectionSecurityModel
- type TFDbRoleToExecuteModel
- type TFStreamConnectionModel
- type TFStreamConnectionsDSModel
Constants ¶
This section is empty.
Variables ¶
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, }}
Functions ¶
func DataSource ¶
func DataSource() datasource.DataSource
func NewStreamConnectionReq ¶
func NewStreamConnectionReq(ctx context.Context, plan *TFStreamConnectionModel) (*admin.StreamsConnection, diag.Diagnostics)
func PluralDataSource ¶
func PluralDataSource() datasource.DataSource
Types ¶
type TFDbRoleToExecuteModel ¶ added in v1.15.2
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"` }
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)
Click to show internal directories.
Click to hide internal directories.