streamconnection

Documentation

Index

• Variables
• func DSAttributes(withArguments bool) map[string]schema.Attribute
• func DataSource() datasource.DataSource
• func NewStreamConnectionReq(ctx context.Context, plan *TFStreamConnectionModel) (*admin.StreamsConnection, diag.Diagnostics)
• func PluralDataSource() datasource.DataSource
• func Resource() resource.Resource
• type TFConnectionAuthenticationModel
• type TFConnectionSecurityModel
• 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 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,
}}

Functions

func DSAttributes

func DSAttributes(withArguments bool) map[string]schema.Attribute

DSAttributes returns the attribute definitions for a single stream connection. `withArguments` marks certain attributes as required (for singular data source) or as computed (for plural data source)

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

func Resource

func Resource() resource.Resource

Types

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 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"`
}

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)