confluentcloud

package
v0.0.0-...-0f9329b Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 16, 2021 License: MIT Imports: 5 Imported by: 0

Documentation

Index

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 AccountMessage struct {
	ID             string `json:"id"`
	Name           string `json:"name"`
	OrganizationID int    `json:"organization_id"`
}

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 AuthRequest struct {
	Email    string `json:"email"`
	Password string `json:"password"`
}

type AuthSuccessResponse 

type AuthSuccessResponse struct {
	Token string `json:"token"`
}

type Client 

type Client struct {
	BaseURL   *url.URL
	UserAgent string
	// contains filtered or unexported fields
}

func NewClient 

func NewClient(email, password string) *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) CreateEnvironment 

func (c *Client) CreateEnvironment(name string, organizationID int) (*Environment, error)

func (*Client) CreateSchemaRegistry 

func (c *Client) CreateSchemaRegistry(accountID string, location string, serviceProvider string) (*SchemaRegistry, error)

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 (c *Client) DeleteCluster(id, account_id string) error

func (*Client) DeleteEnvironment 

func (c *Client) DeleteEnvironment(id string) error

func (*Client) DeleteServiceAccount 

func (c *Client) DeleteServiceAccount(id int) error

func (*Client) GetCluster 

func (c *Client) GetCluster(id, account_id string) (*Cluster, 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 (c *Client) ListAPIKeys(clusterID, accountID string) ([]APIKey, error)

func (*Client) ListClusters 

func (c *Client) ListClusters(accountID string) ([]Cluster, error)

func (*Client) ListServiceAccounts 

func (c *Client) ListServiceAccounts() ([]ServiceAccount, error)

func (*Client) Login 

func (c *Client) Login() error

func (*Client) Me 

func (c *Client) Me() (*UserInfoRequest, error)

func (*Client) NewRequest 

func (c *Client) NewRequest() *resty.Request

func (*Client) ReadServiceAccount 

func (c *Client) ReadServiceAccount(id int) (*ServiceAccount, error)

func (*Client) UpdateCluster 

func (c *Client) UpdateCluster(id, account_id, name string) 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 ClusterCreateDeploymentConfig 

type ClusterCreateDeploymentConfig struct {
	Sku       string `json:"sku"`
	AccountID string `json:"account_id"`
}

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 Environment 

type Environment struct {
	ID             string `json:"id"`
	Name           string `json:"name"`
	OrganizationID int    `json:"organization_id"`
	Deactivated    bool   `json:"deactivated"`
}

type EnvironmentCreateRequest 

type EnvironmentCreateRequest struct {
	Account EnvironmentRequest `json:"account"`
}

type EnvironmentRequest 

type EnvironmentRequest struct {
	Name           string `json:"name"`
	OrganizationID int    `json:"organization_id"`
}

type EnvironmentResponse 

type EnvironmentResponse struct {
	Account Environment `json:"account"`
}

type ErrorMessage 

type ErrorMessage struct {
	Code    int    `json:"code"`
	Message string `json:"message"`
}

type ErrorResponse 

type ErrorResponse struct {
	Error ErrorMessage `json:"error"`
}

type LogicalCluster 

type LogicalCluster struct {
	ID   string  `json:"id"`
	Type *string `json:"type,omitempty"`
}

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 SchemaRegistryRequest struct {
	AccountID       string `json:"account_id"`
	KafkaClusterID  string `json:"kafka_cluster_id"`
	Location        string `json:"location"`
	Name            string `json:"name"`
	ServiceProvider string `json:"service_provider"`
}

type SchemaRegistryResponse 

type SchemaRegistryResponse struct {
	Error    interface{}      `json:"error"`
	Clusters []SchemaRegistry `json:"clusters"`
}

type ServiceAccount 

type ServiceAccount struct {
	ID          int    `json:"id"`
	Name        string `json:"service_name"`
	Description string `json:"service_description"`
}

type ServiceAccountCreateRequest 

type ServiceAccountCreateRequest struct {
	Name        string `json:"service_name"`
	Description string `json:"service_description"`
}

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 ServiceAccountGetRequest 

type ServiceAccountGetRequest struct {
	ID int `json:"id"`
}

type ServiceAccountGetRequestW 

type ServiceAccountGetRequestW struct {
	ServiceAccount ServiceAccountGetRequest `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"`
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.