streamconnection

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)

Variables

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

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

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

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

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

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

Functions

func DataSource

func DataSource() datasource.DataSource

func DeleteStreamConnection

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

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

func ResourceSchema(ctx context.Context) schema.Schema

Types

type TFAWSModel

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

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

type TFNetworkingAccessModel

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

type TFNetworkingModel

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)