Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetPulsarCluster ¶ added in v2.1.0
Types ¶
type CDCResult ¶ added in v2.1.0
type CDCResult []struct { OrgID string `json:"orgId"` ClusterName string `json:"clusterName"` Tenant string `json:"tenant"` Namespace string `json:"namespace"` ConnectorName string `json:"connectorName"` ConfigType string `json:"configType"` DatabaseID string `json:"databaseId"` DatabaseName string `json:"databaseName"` Keyspace string `json:"keyspace"` DatabaseTable string `json:"databaseTable"` ConnectorStatus string `json:"connectorStatus"` CdcStatus string `json:"cdcStatus"` CodStatus string `json:"codStatus"` CreatedAt time.Time `json:"createdAt"` UpdatedAt time.Time `json:"updatedAt"` EventTopic string `json:"eventTopic"` DataTopic string `json:"dataTopic"` Instances int `json:"instances"` CPU int `json:"cpu"` Memory int `json:"memory"` }
type ServerlessStreamingAvailableRegionsResult ¶ added in v2.1.0
type ServerlessStreamingAvailableRegionsResult []struct { Tier string `json:"tier"` Description string `json:"description"` CloudProvider string `json:"cloudProvider"` Region string `json:"region"` RegionDisplay string `json:"regionDisplay"` RegionContinent string `json:"regionContinent"` Cost struct { CostPerMinCents int `json:"costPerMinCents"` CostPerHourCents int `json:"costPerHourCents"` CostPerDayCents int `json:"costPerDayCents"` CostPerMonthCents int `json:"costPerMonthCents"` CostPerMinMRCents int `json:"costPerMinMRCents"` CostPerHourMRCents int `json:"costPerHourMRCents"` CostPerDayMRCents int `json:"costPerDayMRCents"` CostPerMonthMRCents int `json:"costPerMonthMRCents"` CostPerMinParkedCents int `json:"costPerMinParkedCents"` CostPerHourParkedCents int `json:"costPerHourParkedCents"` CostPerDayParkedCents int `json:"costPerDayParkedCents"` CostPerMonthParkedCents int `json:"costPerMonthParkedCents"` CostPerNetworkGbCents int `json:"costPerNetworkGbCents"` CostPerWrittenGbCents int `json:"costPerWrittenGbCents"` CostPerReadGbCents int `json:"costPerReadGbCents"` } `json:"cost"` DatabaseCountUsed int `json:"databaseCountUsed"` DatabaseCountLimit int `json:"databaseCountLimit"` CapacityUnitsUsed int `json:"capacityUnitsUsed"` CapacityUnitsLimit int `json:"capacityUnitsLimit"` DefaultStoragePerCapacityUnitGb int `json:"defaultStoragePerCapacityUnitGb"` }
type SinkResponse ¶ added in v2.1.0
type SinkResponse struct { Tenant string `json:"tenant"` Namespace string `json:"namespace"` Name string `json:"name"` ClassName string `json:"className"` SourceSubscriptionName interface{} `json:"sourceSubscriptionName"` SourceSubscriptionPosition string `json:"sourceSubscriptionPosition"` Inputs interface{} `json:"inputs"` TopicToSerdeClassName interface{} `json:"topicToSerdeClassName"` TopicsPattern interface{} `json:"topicsPattern"` TopicToSchemaType interface{} `json:"topicToSchemaType"` TopicToSchemaProperties interface{} `json:"topicToSchemaProperties"` MaxMessageRetries interface{} `json:"maxMessageRetries"` DeadLetterTopic interface{} `json:"deadLetterTopic"` Configs struct { Password string `json:"password"` JdbcURL string `json:"jdbcUrl"` UserName string `json:"userName"` TableName string `json:"tableName"` } `json:"configs"` Secrets interface{} `json:"secrets"` Parallelism int `json:"parallelism"` ProcessingGuarantees string `json:"processingGuarantees"` RetainOrdering bool `json:"retainOrdering"` RetainKeyOrdering bool `json:"retainKeyOrdering"` Resources interface{} `json:"resources"` AutoAck bool `json:"autoAck"` TimeoutMs interface{} `json:"timeoutMs"` NegativeAckRedeliveryDelayMs interface{} `json:"negativeAckRedeliveryDelayMs"` Archive string `json:"archive"` CleanupSubscription interface{} `json:"cleanupSubscription"` RuntimeFlags interface{} `json:"runtimeFlags"` CustomRuntimeOptions interface{} `json:"customRuntimeOptions"` }
type StreamingClusters ¶ added in v2.1.0
type StreamingClusters []struct { ID string `json:"id"` TenantName string `json:"tenantName"` ClusterName string `json:"clusterName"` WebServiceURL string `json:"webServiceUrl"` BrokerServiceURL string `json:"brokerServiceUrl"` WebsocketURL string `json:"websocketUrl"` WebsocketQueryParamURL string `json:"websocketQueryParamUrl"` PulsarToken string `json:"pulsarToken"` Plan string `json:"plan"` PlanCode string `json:"planCode"` AstraOrgGUID string `json:"astraOrgGUID"` CloudProvider string `json:"cloudProvider"` CloudProviderCode string `json:"cloudProviderCode"` CloudRegion string `json:"cloudRegion"` Status string `json:"status"` JvmVersion string `json:"jvmVersion"` PulsarVersion string `json:"pulsarVersion"` Email string `json:"Email"` }
type StreamingTenant ¶ added in v2.1.0
type StreamingTenant struct { Namespace string `json:"namespace"` Topic string `json:"topic"` ID string `json:"id"` TenantName string `json:"tenantName"` ClusterName string `json:"clusterName"` WebServiceURL string `json:"webServiceUrl"` BrokerServiceURL string `json:"brokerServiceUrl"` WebsocketURL string `json:"websocketUrl"` WebsocketQueryParamURL string `json:"websocketQueryParamUrl"` PulsarToken string `json:"pulsarToken"` Plan string `json:"plan"` PlanCode string `json:"planCode"` AstraOrgGUID string `json:"astraOrgGUID"` CloudProvider string `json:"cloudProvider"` CloudProviderCode string `json:"cloudProviderCode"` CloudRegion string `json:"cloudRegion"` Status string `json:"status"` JvmVersion string `json:"jvmVersion"` PulsarVersion string `json:"pulsarVersion"` Email string `json:"Email"` }
Source Files ¶
- data_source_access_list.go
- data_source_available_regions.go
- data_source_database.go
- data_source_databases.go
- data_source_keyspace.go
- data_source_keyspaces.go
- data_source_private_link_endpoints.go
- data_source_private_links.go
- data_source_role.go
- data_source_roles.go
- data_source_secure_connect_bundle_url.go
- data_source_token.go
- data_source_users.go
- provider.go
- resource_access_list.go
- resource_cdc.go
- resource_database.go
- resource_keyspace.go
- resource_private_link.go
- resource_private_link_endpoint.go
- resource_role.go
- resource_streaming_sink.go
- resource_streaming_tenant.go
- resource_streaming_topic.go
- resource_table.go
- resource_token.go
- util.go
- validators.go
Click to show internal directories.
Click to hide internal directories.