provider

Mar 26, 2024

Changes in this version

type PulsarNamespacePolicies

+ OffloadThreshold *int64

Feb 29, 2024

Changes in this version

+ func HTTPResponseDiagErrWithBody(statusCode int, body []byte, err error, errorSummary string) diag.Diagnostics

+ func HTTPResponseDiagWarnWithBody(statusCode int, body []byte, err error, errorSummary string) diag.Diagnostics

type PulsarNamespacePolicies

+ SubscriptionExpirationTimeMinutes *int64

Feb 21, 2024

Changes in this version

+ type PulsarNamespaceInactiveTopicPolicies struct

+ DeleteMode *string

+ DeleteWhileInactive *bool

+ MaxInactiveDurationSeconds *int64

type PulsarNamespacePolicies

+ InactiveTopicPolicies *PulsarNamespaceInactiveTopicPolicies

Sep 19, 2023

Changes in this version

type StreamingTopicResourceModel

+ TopicFQN types.String

Aug 15, 2023

Changes in this version

+ const DefaultAstraAppsDomain

+ func CompareTerraformAttrToString(attr attr.Value, s string) bool

+ func HTTPResponseDiagErr(resp *http.Response, err error, errorSummary string) diag.Diagnostics

+ func HTTPResponseDiagWarn(resp *http.Response, err error, errorSummary string) diag.Diagnostics

+ func MergeTerraformObjects(old, new types.Object, attributeTypes map[string]attr.Type) (types.Object, diag.Diagnostics)

+ func NewSDKProviderV6(version string) func() tfprotov6.ProviderServer

+ func NewStreamingTopicResource() resource.Resource

+ func UpdateTerraformObjectWithAttr(ctx context.Context, obj types.Object, key string, value attr.Value) (types.Object, diag.Diagnostics)

+ type AutoTopicCreationOverridePlanModifier struct

+ func (m AutoTopicCreationOverridePlanModifier) Description(_ context.Context) string

+ func (m AutoTopicCreationOverridePlanModifier) MarkdownDescription(_ context.Context) string

+ func (m AutoTopicCreationOverridePlanModifier) PlanModifyObject(ctx context.Context, req planmodifier.ObjectRequest, ...)

+ type CDCStatus struct

+ CPU int

+ CdcStatus string

+ ClusterName string

+ CodStatus string

+ ConfigType string

+ ConnectorName string

+ ConnectorStatus string

+ CreatedAt time.Time

+ DataTopic string

+ DatabaseID string

+ DatabaseName string

+ DatabaseTable string

+ EventTopic string

+ Instances int

+ Keyspace string

+ Memory int

+ Namespace string

+ OrgID string

+ Tenant string

+ UpdatedAt time.Time

+ type CDCStatusResponse []CDCStatus

+ type PulsarNamespaceAutoTopicCreationOverride struct

+ AllowAutoTopicCreation *bool

+ DefaultNumPartitions *int64

+ TopicType *string

+ type PulsarNamespaceBacklogQuota struct

+ Limit *int64

+ LimitSize *int64

+ LimitTime *int64

+ Policy *string

+ type PulsarNamespacePolicies struct

+ AutoTopicCreationOverride *PulsarNamespaceAutoTopicCreationOverride

+ BacklogQuota map[string]*PulsarNamespaceBacklogQuota

+ IsAllowAutoUpdateSchema *bool

+ MessageTTLInSeconds *int32

+ RetentionPolicies *PulsarNamespaceRetentionPolicies

+ SchemaAutoUpdateCompatibilityStrategy *string

+ SchemaCompatibilityStrategy *string

+ SchemaValidationEnforced *bool

+ type PulsarNamespaceRetentionPolicies struct

+ RetentionSizeInMB *int64

+ RetentionTimeInMinutes *int32

+ type StreamingNamespaceResource struct

+ func (r *StreamingNamespaceResource) Configure(_ context.Context, req resource.ConfigureRequest, ...)

+ func (r *StreamingNamespaceResource) Create(ctx context.Context, req resource.CreateRequest, resp *resource.CreateResponse)

+ func (r *StreamingNamespaceResource) Delete(ctx context.Context, req resource.DeleteRequest, resp *resource.DeleteResponse)

+ func (r *StreamingNamespaceResource) ImportState(ctx context.Context, req resource.ImportStateRequest, ...)

+ func (r *StreamingNamespaceResource) Metadata(_ context.Context, req resource.MetadataRequest, ...)

+ func (r *StreamingNamespaceResource) Read(ctx context.Context, req resource.ReadRequest, resp *resource.ReadResponse)

+ func (r *StreamingNamespaceResource) Schema(_ context.Context, _ resource.SchemaRequest, resp *resource.SchemaResponse)

+ func (r *StreamingNamespaceResource) Update(ctx context.Context, req resource.UpdateRequest, resp *resource.UpdateResponse)

+ type StreamingNamespaceResourceModel struct

+ Cluster types.String

+ ID types.String

+ Namespace types.String

+ Policies types.Object

+ Tenant types.String

+ type StreamingTopicResource struct

+ func (r *StreamingTopicResource) Configure(_ context.Context, req resource.ConfigureRequest, ...)

+ func (r *StreamingTopicResource) Create(ctx context.Context, req resource.CreateRequest, resp *resource.CreateResponse)

+ func (r *StreamingTopicResource) Delete(ctx context.Context, req resource.DeleteRequest, resp *resource.DeleteResponse)

+ func (r *StreamingTopicResource) ImportState(ctx context.Context, req resource.ImportStateRequest, ...)

+ func (r *StreamingTopicResource) Metadata(_ context.Context, req resource.MetadataRequest, ...)

+ func (r *StreamingTopicResource) Read(ctx context.Context, req resource.ReadRequest, resp *resource.ReadResponse)

+ func (r *StreamingTopicResource) Schema(_ context.Context, _ resource.SchemaRequest, resp *resource.SchemaResponse)

+ func (r *StreamingTopicResource) Update(ctx context.Context, req resource.UpdateRequest, resp *resource.UpdateResponse)

+ type StreamingTopicResourceModel struct

+ CloudProvider types.String

+ Cluster types.String

+ DeletionProtection types.Bool

+ ID types.String

+ Namespace types.String

+ NumPartitions types.Int64

+ Partitioned types.Bool

+ Persistent types.Bool

+ Region types.String

+ Schema *StreamingTopicSchema

+ Tenant types.String

+ TenantName types.String

+ Topic types.String

+ type StreamingTopicSchema struct

+ Properties *map[string]string

+ Schema *string

+ Type *string

Jul 19, 2023

Changes in this version

+ func NewSDKProvider(version string) func() *schema.Provider

+ func NewStreamingNamespaceResource() resource.Resource

+ func NewStreamingPulsarTokenResource() resource.Resource

+ type StreamingPulsarTokenResource struct

+ func (r *StreamingPulsarTokenResource) Configure(_ context.Context, req resource.ConfigureRequest, ...)

+ func (r *StreamingPulsarTokenResource) Create(ctx context.Context, req resource.CreateRequest, resp *resource.CreateResponse)

+ func (r *StreamingPulsarTokenResource) Delete(ctx context.Context, req resource.DeleteRequest, resp *resource.DeleteResponse)

+ func (r *StreamingPulsarTokenResource) ImportState(ctx context.Context, req resource.ImportStateRequest, ...)

+ func (r *StreamingPulsarTokenResource) Metadata(_ context.Context, req resource.MetadataRequest, ...)

+ func (r *StreamingPulsarTokenResource) Read(ctx context.Context, req resource.ReadRequest, resp *resource.ReadResponse)

+ func (r *StreamingPulsarTokenResource) Schema(_ context.Context, _ resource.SchemaRequest, resp *resource.SchemaResponse)

+ func (r *StreamingPulsarTokenResource) Update(ctx context.Context, req resource.UpdateRequest, resp *resource.UpdateResponse)

+ type StreamingPulsarTokenResourceModel struct

+ Cluster types.String

+ ID types.String

+ Tenant types.String

+ TimeToLive types.String

+ Token types.String

+ type StreamingToken struct

+ Iat int

+ Iss string

+ Sub string

+ Tokenid string

Jul 7, 2023

Changes in this version

+ const DefaultAstraAPIURL

+ const DefaultStreamingAPIURL

Jun 30, 2022

Changes in this version

+ func GetPulsarCluster(cloudProvider string, rawRegion string) string

+ type CDCResult []struct

+ type OrgId struct

+ ID string

+ type ServerlessStreamingAvailableRegionsResult []struct

+ type SinkResponse struct

+ Archive string

+ AutoAck bool

+ ClassName string

+ CleanupSubscription interface{}

+ Configs struct{ ... }

+ CustomRuntimeOptions interface{}

+ DeadLetterTopic interface{}

+ Inputs interface{}

+ MaxMessageRetries interface{}

+ Name string

+ Namespace string

+ NegativeAckRedeliveryDelayMs interface{}

+ Parallelism int

+ ProcessingGuarantees string

+ Resources interface{}

+ RetainKeyOrdering bool

+ RetainOrdering bool

+ RuntimeFlags interface{}

+ Secrets interface{}

+ SourceSubscriptionName interface{}

+ SourceSubscriptionPosition string

+ Tenant string

+ TimeoutMs interface{}

+ TopicToSchemaProperties interface{}

+ TopicToSchemaType interface{}

+ TopicToSerdeClassName interface{}

+ TopicsPattern interface{}

+ type StreamingClusters []struct

+ type StreamingTenant struct

+ AstraOrgGUID string

+ BrokerServiceURL string

+ CloudProvider string

+ CloudProviderCode string

+ CloudRegion string

+ ClusterName string

+ Email string

+ ID string

+ JvmVersion string

+ Namespace string

+ Plan string

+ PlanCode string

+ PulsarToken string

+ PulsarVersion string

+ Status string

+ TenantName string

+ Topic string

+ WebServiceURL string

+ WebsocketQueryParamURL string

+ WebsocketURL string

+ type StreamingTokens []struct

Mar 11, 2022

Changes in this version

+ func New(version string) func() *schema.Provider