Documentation ¶
Index ¶
- type APIKey
- type APIKeyResponse
- type APIKeysResponse
- type AccountMessage
- type ApiKeyCreateRequest
- type ApiKeyCreateRequestW
- type AuthRequest
- type AuthSuccessResponse
- type Client
- func (c *Client) CreateAPIKey(request *ApiKeyCreateRequest) (*APIKey, error)
- func (c *Client) CreateCluster(request ClusterCreateConfig) (*Cluster, error)
- func (c *Client) CreateConnector(account_id, cluster_id, name string, config ConnectorConfig) (*ConnectorInfo, error)
- func (c *Client) CreateEnvironment(name string, organizationID int) (*Environment, error)
- func (c *Client) CreateSchemaRegistry(accountID string, location string, serviceProvider string) (*SchemaRegistry, error)
- func (c *Client) CreateServiceAccount(request *ServiceAccountCreateRequest) (*ServiceAccount, error)
- func (c *Client) DeleteAPIKey(id, account_id string, logical_clusters []LogicalCluster) error
- func (c *Client) DeleteCluster(id, account_id string) error
- func (c *Client) DeleteConnector(account_id, cluster_id, name string) error
- func (c *Client) DeleteEnvironment(id string) error
- func (c *Client) DeleteServiceAccount(id int) error
- func (c *Client) GetCluster(id, account_id string) (*Cluster, error)
- func (c *Client) GetConnector(account_id, cluster_id, name string) (*ConnectorInfo, error)
- func (c *Client) GetEnvironment(id string) (*Environment, error)
- func (c *Client) GetSchemaRegistry(id string) (*SchemaRegistry, error)
- func (c *Client) ListAPIKeys(clusterID, accountID string) ([]APIKey, error)
- func (c *Client) ListClusters(accountID string) ([]Cluster, error)
- func (c *Client) ListConnectors(account_id, cluster_id string) ([]Connector, error)
- func (c *Client) ListEnvironments() ([]Environment, error)
- func (c *Client) ListServiceAccounts() ([]ServiceAccount, error)
- func (c *Client) Login() error
- func (c *Client) Me() (*UserInfoRequest, error)
- func (c *Client) NewRequest() *resty.Request
- func (c *Client) UpdateCluster(id, account_id, name string) error
- func (c *Client) UpdateConnectorConfig(account_id, cluster_id, name string, config ConnectorConfig) (*ConnectorInfo, error)
- func (c *Client) UpdateEnvironment(id, newName string, organizationID int) (*Environment, error)
- type Cluster
- type ClusterCreateConfig
- type ClusterCreateDeploymentConfig
- type ClusterCreateRequest
- type ClusterDeployment
- type ClusterDeploymentNetworkAccess
- type ClusterResponse
- type ClustersResponse
- type Connector
- type ConnectorConfig
- type ConnectorID
- type ConnectorInfo
- type ConnectorTask
- type CreateConnectorRequest
- type Environment
- type EnvironmentCreateRequest
- type EnvironmentRequest
- type EnvironmentResponse
- type EnvironmentsResponse
- type ErrorMessage
- type ErrorResponse
- type ListConnectorsResponse
- type LogicalCluster
- type SchemaRegistry
- type SchemaRegistryCreateRequest
- type SchemaRegistryCreateResponse
- type SchemaRegistryRequest
- type SchemaRegistryResponse
- type ServiceAccount
- type ServiceAccountCreateRequest
- type ServiceAccountCreateRequestW
- type ServiceAccountDeleteRequest
- type ServiceAccountDeleteRequestW
- type ServiceAccountResponse
- type ServiceAccountsResponse
- type UserInfoRequest
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type APIKey ¶
type APIKey struct { Key string `json:"key"` Secret string `json:"secret"` HashedSecret string `json:"hashed_secret"` HashedFunction string `json:"hashed_function"` SASLMechanism string `json:"sasl_mechanism"` UserID int `json:"user_id"` Deactived bool `json:"deactived"` ID int `json:"id"` Description string `json:"description"` LogicalClusters []LogicalCluster `json:"logical_clusters"` AccountID string `json:"account_id"` ServiceAccount bool `json:"service_account"` }
type APIKeyResponse ¶
type APIKeyResponse struct {
APIKey APIKey `json:"api_key"`
}
type APIKeysResponse ¶
type APIKeysResponse struct {
APIKeys []APIKey `json:"api_keys"`
}
type AccountMessage ¶
type ApiKeyCreateRequest ¶
type ApiKeyCreateRequest struct { AccountID string `json:"accountId"` UserID int `json:"user_id,omitempty"` Description string `json:"description,omitempty"` LogicalClusters []LogicalCluster `json:"logical_clusters"` }
type ApiKeyCreateRequestW ¶
type ApiKeyCreateRequestW struct {
APIKey *ApiKeyCreateRequest `json:"api_key"`
}
type AuthRequest ¶
type AuthSuccessResponse ¶
type AuthSuccessResponse struct {
Token string `json:"token"`
}
type Client ¶
func (*Client) CreateAPIKey ¶
func (c *Client) CreateAPIKey(request *ApiKeyCreateRequest) (*APIKey, error)
func (*Client) CreateCluster ¶
func (c *Client) CreateCluster(request ClusterCreateConfig) (*Cluster, error)
func (*Client) CreateConnector ¶
func (c *Client) CreateConnector(account_id, cluster_id, name string, config ConnectorConfig) (*ConnectorInfo, error)
func (*Client) CreateEnvironment ¶
func (c *Client) CreateEnvironment(name string, organizationID int) (*Environment, error)
func (*Client) CreateSchemaRegistry ¶
func (*Client) CreateServiceAccount ¶
func (c *Client) CreateServiceAccount(request *ServiceAccountCreateRequest) (*ServiceAccount, error)
func (*Client) DeleteAPIKey ¶
func (c *Client) DeleteAPIKey(id, account_id string, logical_clusters []LogicalCluster) error
func (*Client) DeleteCluster ¶
func (*Client) DeleteConnector ¶
func (*Client) DeleteEnvironment ¶
func (*Client) DeleteServiceAccount ¶
func (*Client) GetConnector ¶
func (c *Client) GetConnector(account_id, cluster_id, name string) (*ConnectorInfo, error)
func (*Client) GetEnvironment ¶
func (c *Client) GetEnvironment(id string) (*Environment, error)
func (*Client) GetSchemaRegistry ¶
func (c *Client) GetSchemaRegistry(id string) (*SchemaRegistry, error)
func (*Client) ListAPIKeys ¶
func (*Client) ListConnectors ¶
func (*Client) ListEnvironments ¶
func (c *Client) ListEnvironments() ([]Environment, error)
func (*Client) ListServiceAccounts ¶
func (c *Client) ListServiceAccounts() ([]ServiceAccount, error)
func (*Client) Me ¶
func (c *Client) Me() (*UserInfoRequest, error)
func (*Client) NewRequest ¶
func (*Client) UpdateCluster ¶
func (*Client) UpdateConnectorConfig ¶
func (c *Client) UpdateConnectorConfig(account_id, cluster_id, name string, config ConnectorConfig) (*ConnectorInfo, error)
func (*Client) UpdateEnvironment ¶
func (c *Client) UpdateEnvironment(id, newName string, organizationID int) (*Environment, error)
type Cluster ¶
type Cluster struct { ID string `json:"id"` Name string `json:"name"` AccountID string `json:"account_id"` NetworkIngress int `json:"network_ingress"` NetworkEgress int `json:"network_egress"` Storage int `json:"storage"` Durability string `json:"durability"` Status string `json:"status"` Endpoint string `json:"endpoint"` Region string `json:"region"` ServiceProvider string `json:"service_provider"` OrganizationID int `json:"organization_id"` Enterprise bool `json:"enterprise"` K8sClusterID string `json:"k8s_cluster_id"` PhysicalClusterID string `json:"physical_cluster_id"` PricePerHour string `json:"prince_per_hour"` AccruedThisCycle string `json:"accrued_this_cycle"` Type string `json:"type"` APIEndpoint string `json:"api_endpoint"` InternalProxy bool `json:"internal_proxy"` IsSLAEnabled bool `json:"is_sla_enabled"` IsSchedulable bool `json:"is_schedulable"` Dedicated bool `json:"dedicated"` NetworkIsolationDomainID string `json:"network_isolation_domain_id"` MaxNetworkIngress int `json:"max_network_ingress"` MaxNetworkEgress int `json:"max_network_egress"` Deployment ClusterDeployment `json:"deployment"` Cku int `json:"cku"` }
type ClusterCreateConfig ¶
type ClusterCreateConfig struct { Name string `json:"name"` AccountID string `json:"accountId"` Storage int `json:"storage"` NetworkIngress int `json:"network_ingress"` NetworkEgress int `json:"network_egress"` Region string `json:"region"` ServiceProvider string `json:"serviceProvider"` Durability string `json:"durability"` Deployment ClusterCreateDeploymentConfig `json:"deployment"` Cku int `json:"cku"` }
type ClusterCreateRequest ¶
type ClusterCreateRequest struct {
Config ClusterCreateConfig `json:"config"`
}
type ClusterDeployment ¶
type ClusterDeployment struct { ID string `json:"id"` Created time.Time `json:"created"` Modified time.Time `json:"modified"` Deactivated time.Time `json:"deactiviated"` AccountID string `json:"account_id"` NetworkAccess ClusterDeploymentNetworkAccess `json:"network_access"` Sku string `json:"sku"` }
type ClusterDeploymentNetworkAccess ¶
type ClusterDeploymentNetworkAccess struct { PublicInternet []interface{} `json:"public_internet"` VpcPeering []interface{} `json:"vpc_peering"` PrivateLink []interface{} `json:"private_link"` TransitGateway []interface{} `json:"transit_gateway"` }
type ClusterResponse ¶
type ClusterResponse struct {
Cluster Cluster `json:"cluster"`
}
type ClustersResponse ¶
type ClustersResponse struct {
Clusters []Cluster `json:"clusters"`
}
type Connector ¶
type Connector struct { ID ConnectorID `json:"id"` Info ConnectorInfo `json:"info"` }
type ConnectorConfig ¶
type ConnectorID ¶
type ConnectorInfo ¶
type ConnectorInfo struct { Name string `json:"name"` Type string `json:"type"` Config map[string]string `json:"config"` Tasks []ConnectorTask `json:"tasks"` }
type ConnectorTask ¶
type CreateConnectorRequest ¶
type CreateConnectorRequest struct { Name string `json:"name"` Config ConnectorConfig `json:"config"` }
type Environment ¶
type EnvironmentCreateRequest ¶
type EnvironmentCreateRequest struct {
Account EnvironmentRequest `json:"account"`
}
type EnvironmentRequest ¶
type EnvironmentResponse ¶
type EnvironmentResponse struct {
Account Environment `json:"account"`
}
type EnvironmentsResponse ¶
type EnvironmentsResponse struct {
Accounts []Environment `json:"accounts"`
}
type ErrorMessage ¶
type ErrorResponse ¶
type ErrorResponse struct {
Error ErrorMessage `json:"error"`
}
type ListConnectorsResponse ¶
type LogicalCluster ¶
type SchemaRegistry ¶
type SchemaRegistry struct { ID string `json:"id"` Name string `json:"name"` KafkaClusterID string `json:"kafka_cluster_id"` Endpoint string `json:"endpoint"` Created time.Time `json:"created"` Modified time.Time `json:"modified"` Status string `json:"status"` PhysicalClusterID string `json:"physical_cluster_id"` AccountID string `json:"account_id"` OrganizationID int `json:"organization_id"` MaxSchemas int `json:"max_schemas"` }
type SchemaRegistryCreateRequest ¶
type SchemaRegistryCreateRequest struct {
Config SchemaRegistryRequest `json:"config"`
}
type SchemaRegistryCreateResponse ¶
type SchemaRegistryCreateResponse struct { Error interface{} `json:"error"` Cluster SchemaRegistry `json:"cluster"` }
type SchemaRegistryRequest ¶
type SchemaRegistryResponse ¶
type SchemaRegistryResponse struct { Error interface{} `json:"error"` Clusters []SchemaRegistry `json:"clusters"` }
type ServiceAccount ¶
type ServiceAccountCreateRequestW ¶
type ServiceAccountCreateRequestW struct {
ServiceAccount *ServiceAccountCreateRequest `json:"user"`
}
type ServiceAccountDeleteRequest ¶
type ServiceAccountDeleteRequest struct {
ID int `json:"id"`
}
type ServiceAccountDeleteRequestW ¶
type ServiceAccountDeleteRequestW struct {
ServiceAccount ServiceAccountDeleteRequest `json:"user"`
}
type ServiceAccountResponse ¶
type ServiceAccountResponse struct {
ServiceAccount ServiceAccount `json:"user"`
}
type ServiceAccountsResponse ¶
type ServiceAccountsResponse struct {
ServiceAccounts []ServiceAccount `json:"users"`
}
type UserInfoRequest ¶
type UserInfoRequest struct { Account AccountMessage `json:"account"` Organization interface{} `json:"organization"` User interface{} `json:"user"` }
Click to show internal directories.
Click to hide internal directories.