provider

Documentation

Index

• func GetPulsarCluster(cloudProvider string, rawRegion string) string
• func New(version string) func() *schema.Provider
• type CDCResult
• type OrgId
• type ServerlessStreamingAvailableRegionsResult
• type SinkResponse
• type StreamingClusters
• type StreamingTokens

Functions

func GetPulsarCluster

func GetPulsarCluster(cloudProvider string, rawRegion string) string

func New

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

Types

type CDCResult

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 OrgId

type OrgId struct {
	ID string `json:"id"`
}

type ServerlessStreamingAvailableRegionsResult

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

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

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 StreamingTokens

type StreamingTokens []struct {
	Iat     int    `json:"iat"`
	Iss     string `json:"iss"`
	Sub     string `json:"sub"`
	Tokenid string `json:"tokenid"`
}