streamprivatelinkendpoint

Documentation

Index

• Constants
• func DataSource() datasource.DataSource
• func NewAtlasReq(ctx context.Context, plan *TFModel) (*admin.StreamsPrivateLinkConnection, diag.Diagnostics)
• func PluralDataSource() datasource.DataSource
• func Resource() resource.Resource
• func ResourceSchema(ctx context.Context) schema.Schema
• func WaitDeleteStateTransition(ctx context.Context, projectID, endpointID string, client admin.StreamsApi) (*admin.StreamsPrivateLinkConnection, error)
• func WaitDeleteStateTransitionWithMinTimeout(ctx context.Context, minTimeout time.Duration, projectID, connectionID string, ...) (*admin.StreamsPrivateLinkConnection, error)
• func WaitStateTransitionWithMinTimeout(ctx context.Context, minTimeout time.Duration, projectID, endpointID string, ...) (*admin.StreamsPrivateLinkConnection, error)
• type TFModel
  • func NewTFModel(ctx context.Context, projectID string, ...) (*TFModel, diag.Diagnostics)
• type TFModelDSP
  • func NewTFModelPluralDS(ctx context.Context, projectID string, ...) (*TFModelDSP, diag.Diagnostics)

Constants

const (
	FailedStatusErrorMessageSummary  = "Private endpoint is in a failed status"
	NonEmptyErrorMessageFieldSummary = "Something went wrong. Please review the `status` field of this resource"
)

const (
	VendorConfluent = "CONFLUENT"
)

Functions

func DataSource

func DataSource() datasource.DataSource

func NewAtlasReq

func NewAtlasReq(ctx context.Context, plan *TFModel) (*admin.StreamsPrivateLinkConnection, diag.Diagnostics)

func PluralDataSource

func PluralDataSource() datasource.DataSource

func Resource

func Resource() resource.Resource

func ResourceSchema

func ResourceSchema(ctx context.Context) schema.Schema

func WaitDeleteStateTransition

func WaitDeleteStateTransition(ctx context.Context, projectID, endpointID string, client admin.StreamsApi) (*admin.StreamsPrivateLinkConnection, error)

func WaitDeleteStateTransitionWithMinTimeout

func WaitDeleteStateTransitionWithMinTimeout(ctx context.Context, minTimeout time.Duration, projectID, connectionID string, client admin.StreamsApi) (*admin.StreamsPrivateLinkConnection, error)

func WaitStateTransitionWithMinTimeout

func WaitStateTransitionWithMinTimeout(ctx context.Context, minTimeout time.Duration, projectID, endpointID string, client admin.StreamsApi) (*admin.StreamsPrivateLinkConnection, error)

Types

type TFModel

type TFModel struct {
	Id                  types.String `tfsdk:"id"`
	DnsDomain           types.String `tfsdk:"dns_domain"`
	DnsSubDomain        types.List   `tfsdk:"dns_sub_domain"`
	ProjectId           types.String `tfsdk:"project_id"`
	InterfaceEndpointId types.String `tfsdk:"interface_endpoint_id"`
	Provider            types.String `tfsdk:"provider_name"`
	Region              types.String `tfsdk:"region"`
	ServiceEndpointId   types.String `tfsdk:"service_endpoint_id"`
	State               types.String `tfsdk:"state"`
	Vendor              types.String `tfsdk:"vendor"`
}

func NewTFModel

func NewTFModel(ctx context.Context, projectID string, apiResp *admin.StreamsPrivateLinkConnection) (*TFModel, diag.Diagnostics)

type TFModelDSP

type TFModelDSP struct {
	ProjectId types.String `tfsdk:"project_id"`
	Results   []TFModel    `tfsdk:"results"`
}

func NewTFModelPluralDS

func NewTFModelPluralDS(ctx context.Context, projectID string, sdkResults []admin.StreamsPrivateLinkConnection) (*TFModelDSP, diag.Diagnostics)