aiven

package module

Go to main page

Versions in this module

v1

v1.36.0

Sep 5, 2023

Changes in this version

type Client

+ OpenSearchSecurityPluginHandler *OpenSearchSecurityPluginHandler

+ type OpenSearchSecurityPluginConfigurationStatusResponse struct

+ SecurityPluginAdminEnabled bool

+ SecurityPluginAvailable bool

+ SecurityPluginEnabled bool

+ type OpenSearchSecurityPluginEnableRequest struct

+ AdminPassword string

+ type OpenSearchSecurityPluginHandler struct

+ func (h *OpenSearchSecurityPluginHandler) Enable(project string, service string, req OpenSearchSecurityPluginEnableRequest) (*OpenSearchSecurityPluginConfigurationStatusResponse, error)

+ func (h *OpenSearchSecurityPluginHandler) Get(project string, service string) (*OpenSearchSecurityPluginConfigurationStatusResponse, error)

+ func (h *OpenSearchSecurityPluginHandler) UpdatePassword(project string, service string, ...) (*OpenSearchSecurityPluginConfigurationStatusResponse, error)

+ type OpenSearchSecurityPluginUpdatePasswordRequest struct

+ AdminPassword string

+ NewPassword string

v1.35.0

Aug 4, 2023

v1.34.0

Jul 21, 2023

Changes in this version

type Client

+ OrganizationUserGroupMembers *OrganizationUserGroupMembersHandler

+ type OrganizationUserGroupMember struct

+ LastActivityTime string

+ UserID string

+ UserInfo OrganizationUserGroupMemberUserInfo

+ type OrganizationUserGroupMemberRequest struct

+ MemberIDs []string

+ Operation string

+ type OrganizationUserGroupMemberUserInfo struct

+ City string

+ Country string

+ CreateTime string

+ Department string

+ JobTitle string

+ RealName string

+ State string

+ UserEmail string

+ type OrganizationUserGroupMembersHandler struct

+ func (h *OrganizationUserGroupMembersHandler) List(orgID, userGroupID string) (*OrganizationUserGroupMembersListResponse, error)

+ func (h *OrganizationUserGroupMembersHandler) Modify(orgID, userGroupID string, req OrganizationUserGroupMemberRequest) error

+ type OrganizationUserGroupMembersListResponse struct

+ Members []OrganizationUserGroupMember

v1.33.0

Jul 20, 2023

Changes in this version

type BillingGroupHandler

+ func (h *BillingGroupHandler) GetInvoice(id, invoiceNumber string) (*BillingGroupInvoiceResponse, error)

+ func (h *BillingGroupHandler) ListInvoices(id string) (*BillingGroupListInvoicesResponse, error)

+ func (h *BillingGroupHandler) ListLines(id, invoiceNumber string) (*BillingGroupListInvoiceLinesResponse, error)

+ type BillingGroupInvoice struct

+ BillingGroupId string

+ BillingGroupName string

+ BillingGroupState string

+ Currency string

+ DownloadCookie string

+ GeneratedAt *string

+ InvoiceNumber string

+ PeriodBegin string

+ PeriodEnd string

+ State string

+ TotalIncVAT string

+ TotalVATZero string

+ type BillingGroupInvoiceLine struct

+ CloudName *string

+ CommitmentName *string

+ Description string

+ LinePreDiscountLocal *string

+ LineTotalLocal *string

+ LineTotalUSD string

+ LineType string

+ LocalCurrency *string

+ ProjectName *string

+ ServiceName *string

+ ServicePlan *string

+ ServiceType *string

+ Tags *string

+ TimestampBegin *string

+ TimestampEnd *string

+ type BillingGroupInvoiceResponse struct

+ Invoice BillingGroupInvoice

+ type BillingGroupListInvoiceLinesResponse struct

+ Lines []BillingGroupInvoiceLine

+ type BillingGroupListInvoicesResponse struct

+ Invoices []BillingGroupInvoice

v1.32.0

Jul 18, 2023

Changes in this version

+ type GCPPrivatelinkConnectionApproveRequest struct

+ UserIPAddress string

v1.31.0

Jul 18, 2023

Changes in this version

type Client

+ OrganizationUserGroups *OrganizationUserGroupHandler

+ type OrganizationUserGroupHandler struct

+ func (h *OrganizationUserGroupHandler) Create(orgID string, req OrganizationUserGroupRequest) (*OrganizationUserGroupResponse, error)

+ func (h *OrganizationUserGroupHandler) Delete(orgID, userGroupID string) error

+ func (h *OrganizationUserGroupHandler) Get(orgID, userGroupID string) (*OrganizationUserGroupResponse, error)

+ func (h *OrganizationUserGroupHandler) List(orgID string) (*OrganizationUserGroupListResponse, error)

+ func (h *OrganizationUserGroupHandler) Update(orgID, userGroupID string, req OrganizationUserGroupRequest) (*OrganizationUserGroupResponse, error)

+ type OrganizationUserGroupListResponse struct

+ UserGroups []OrganizationUserGroupResponse

+ type OrganizationUserGroupRequest struct

+ Description string

+ UserGroupName string

+ type OrganizationUserGroupResponse struct

+ CreateTime string

+ Description string

+ UpdateTime string

+ UserGroupID string

+ UserGroupName string

v1.30.0

Jul 18, 2023

v1.29.0

Jul 18, 2023

Changes in this version

+ type GCPPrivatelinkConnectionUpdateRequest struct

+ UserIPAddress string

v1.28.0

Jul 18, 2023

v1.27.0

Jul 17, 2023

Changes in this version

type Client

+ GCPPrivatelink *GCPPrivatelinkHandler

v1.26.0

Jul 14, 2023

Changes in this version

type Client

+ GCPPrivateLink *GCPPrivatelinkHandler

+ type GCPPrivatelinkConnectionResponse struct

+ PSCConnectionID string

+ PrivatelinkConnectionID string

+ State string

+ UserIPAddress string

+ type GCPPrivatelinkConnectionsResponse struct

+ Connections []GCPPrivatelinkConnectionResponse

+ type GCPPrivatelinkHandler struct

+ func (h *GCPPrivatelinkHandler) ConnectionApprove(project, serviceName, privatelinkConnectionId string) error

+ func (h *GCPPrivatelinkHandler) ConnectionGet(project, serviceName string, connID *string) (*GCPPrivatelinkConnectionResponse, error)

+ func (h *GCPPrivatelinkHandler) ConnectionsList(project, serviceName string) (*GCPPrivatelinkConnectionsResponse, error)

+ func (h *GCPPrivatelinkHandler) Create(project, serviceName string) (*GCPPrivatelinkResponse, error)

+ func (h *GCPPrivatelinkHandler) Delete(project, serviceName string) error

+ func (h *GCPPrivatelinkHandler) Get(project, serviceName string) (*GCPPrivatelinkResponse, error)

+ func (h *GCPPrivatelinkHandler) Refresh(project, serviceName string) error

+ func (h *GCPPrivatelinkHandler) Update(project, serviceName string) (*GCPPrivatelinkResponse, error)

+ type GCPPrivatelinkResponse struct

+ GoogleServiceAttachment string

+ State string

v1.25.0

Jul 6, 2023

v1.24.0

Jul 6, 2023

v1.23.0

Jul 4, 2023

Changes in this version

type OrganizationUserInvitationsHandler

+ func (h *OrganizationUserInvitationsHandler) Delete(id, userEmail string) error

v1.22.0

Jul 4, 2023

v1.21.0

Jun 29, 2023

Changes in this version

type Client

+ Organization *OrganizationHandler

+ OrganizationUser *OrganizationUserHandler

+ OrganizationUserInvitations *OrganizationUserInvitationsHandler

+ type OrganizationHandler struct

+ func (h *OrganizationHandler) Get(id string) (*OrganizationInfo, error)

+ type OrganizationMemberInfo struct

+ JoinTime string

+ UserID string

+ UserInfo []OrganizationUserInfo

+ type OrganizationUserHandler struct

+ func (h *OrganizationUserHandler) Delete(id, userID string) error

+ func (h *OrganizationUserHandler) Get(id, userID string) (*OrganizationMemberInfo, error)

+ func (h *OrganizationUserHandler) List(id string) (*OrganizationUserList, error)

+ type OrganizationUserInfo struct

+ Country string

+ Department string

+ JobTitle string

+ RealName string

+ State string

+ UserEmail string

+ type OrganizationUserInvitationAddRequest struct

+ UserEmail string

+ type OrganizationUserInvitationInfo struct

+ CreateTime string

+ ExpiryTime string

+ InvitedBy *string

+ UserEmail string

+ type OrganizationUserInvitationsHandler struct

+ func (h *OrganizationUserInvitationsHandler) Invite(id string, req OrganizationUserInvitationAddRequest) error

+ func (h *OrganizationUserInvitationsHandler) List(id string) (*OrganizationUserInvitationsList, error)

+ type OrganizationUserInvitationsList struct

+ Invitations []OrganizationUserInvitationInfo

+ type OrganizationUserList struct

+ Users []OrganizationMemberInfo

v1.20.0

Jun 28, 2023

Changes in this version

+ type ClickhouseCurrentQueriesResponse struct

+ Queries []ClickhouseCurrentQuery

+ type ClickhouseCurrentQuery struct

+ ClientName string

+ Database string

+ Elapsed float64

+ Query string

+ User string

type ClickhouseQueryHandler

+ func (h *ClickhouseQueryHandler) CurrentQueries(project, service string) (*ClickhouseCurrentQueriesResponse, error)

v1.19.0

Jun 27, 2023

v1.18.0

Jun 27, 2023

Changes in this version

+ type CancelFlinkApplicationDeploymentResponse struct

+ type CancelJobFlinkApplicationQueryResponse struct

+ Canceled bool

+ Details string

type Client

+ FlinkApplicationDeployments *FlinkApplicationDeploymentHandler

+ FlinkApplicationQueries *FlinkApplicationQueryHandler

+ type CreateFlinkApplicationDeploymentRequest struct

+ Parallelism int

+ RestartEnabled bool

+ StartingSavepoint string

+ VersionID string

+ type CreateFlinkApplicationDeploymentResponse struct

+ type CreateFlinkApplicationQueryRequest struct

+ JobTTL int

+ MaxRows int

+ Sinks []struct{ ... }

+ Sources []struct{ ... }

+ Statement string

+ type CreateFlinkApplicationQueryResponse struct

+ QueryID string

+ type DeleteFlinkApplicationDeploymentResponse struct

+ type FlinkApplicationDeployment struct

+ CreatedAt string

+ CreatedBy string

+ ID string

+ JobID string

+ LastSavepoint string

+ Parallelism int

+ RestartEnabled bool

+ StartingSavepoint string

+ Status string

+ VersionID string

+ type FlinkApplicationDeploymentHandler struct

+ func (h *FlinkApplicationDeploymentHandler) Cancel(project, service, applicationId, queryId string) (*CancelFlinkApplicationDeploymentResponse, error)

+ func (h *FlinkApplicationDeploymentHandler) Create(project, service, applicationId string, ...) (*CreateFlinkApplicationDeploymentResponse, error)

+ func (h *FlinkApplicationDeploymentHandler) Delete(project, service, applicationId, queryId string) (*DeleteFlinkApplicationDeploymentResponse, error)

+ func (h *FlinkApplicationDeploymentHandler) Get(project, service, applicationId, queryId string) (*GetFlinkApplicationDeploymentResponse, error)

+ func (h *FlinkApplicationDeploymentHandler) List(project, service, applicationId string) (*ListFlinkApplicationDeploymentResponse, error)

+ func (h *FlinkApplicationDeploymentHandler) Stop(project, service, applicationId, queryId string) (*StopFlinkApplicationDeploymentResponse, error)

+ type FlinkApplicationQueryHandler struct

+ func (h *FlinkApplicationQueryHandler) CancelJob(project, service, applicationId, queryId string) (*CancelJobFlinkApplicationQueryResponse, error)

+ func (h *FlinkApplicationQueryHandler) Create(project, service, applicationId string, req CreateFlinkApplicationQueryRequest) (*CreateFlinkApplicationQueryResponse, error)

+ func (h *FlinkApplicationQueryHandler) Delete(project, service, applicationId, queryId string) error

+ func (h *FlinkApplicationQueryHandler) Get(project, service, applicationId, queryId string) (*GetFlinkApplicationQueryResponse, error)

+ func (h *FlinkApplicationQueryHandler) List(project, service, applicationId string) (*ListFlinkApplicationQueryResponse, error)

+ type FlinkApplicationVersion struct

+ Sinks []FlinkApplicationVersionCreateInput

+ Sources []FlinkApplicationVersionCreateInput

+ Statement string

+ type FlinkApplicationVersionCreateInput struct

+ CreateTable string

+ IntegrationID string

type FlinkJobHandler

+ func (h *FlinkJobHandler) List(project, service string) (*ListFlinkJobResponse, error)

+ type GetFlinkApplicationDeploymentResponse struct

+ type GetFlinkApplicationQueryResponse struct

+ type ListFlinkApplicationDeploymentResponse struct

+ Deployments []FlinkApplicationDeployment

+ type ListFlinkApplicationQueryResponse struct

+ Queries []flinkApplicationQueryBase

+ type ListFlinkJobResponse struct

+ Jobs []struct{ ... }

+ type StopFlinkApplicationDeploymentResponse struct

v1.17.0

Jun 20, 2023

Changes in this version

type Client

+ Organizations *OrganizationsHandler

+ type OrganizationInfo struct

+ AccountID string

+ CreateTime string

+ ID string

+ Name string

+ UpdateTime string

+ type OrganizationsHandler struct

+ func (h *OrganizationsHandler) Get(id string) (*OrganizationInfo, error)

v1.16.0

Jun 20, 2023

Changes in this version

type Account

+ OrganizationId string

v1.15.0

May 16, 2023

Changes in this version

type Account

+ ParentAccountId string

v1.14.0

May 10, 2023

v1.13.0

May 2, 2023

Changes in this version

type Client

+ func (c *Client) WithContext(ctx context.Context) *Client

v1.12.0

Apr 19, 2023

v1.11.0

Apr 19, 2023

Changes in this version

type CreateServiceIntegrationRequest

+ DestinationProject *string

+ SourceProject *string

v1.10.0

Apr 19, 2023

v1.9.0

Apr 19, 2023

v1.8.0

Apr 19, 2023

Changes in this version

+ func PointerToString(s *string) string

type AccessControl

+ M3Group *string

+ func (ac AccessControl) MarshalJSON() ([]byte, error)

type Account

+ IsAccountOwner bool

+ PrimaryBillingGroupId string

+ type AccountAuthenticationListResponse struct

+ AuthenticationMethods []AccountAuthenticationMethod

type AccountAuthenticationMethod

+ AccountID string

+ AuthenticationMethodEnabled bool

+ AuthenticationMethodID string

+ AuthenticationMethodName string

+ AuthenticationMethodType string

+ AutoJoinTeamID string

+ SAMLAcsURL string

+ SAMLDigestAlgorithm string

+ SAMLEntityID string

+ SAMLFieldMapping *SAMLFieldMapping

+ SAMLIdpLoginAllowed bool

+ SAMLIdpURL string

+ SAMLMetadataURL string

+ SAMLSignatureAlgorithm string

+ SAMLVariant string

+ type AccountAuthenticationMethodCreate struct

+ AuthenticationMethodName string

+ AuthenticationMethodType string

+ AutoJoinTeamID string

+ SAMLCertificate string

+ SAMLDigestAlgorithm string

+ SAMLEntityID string

+ SAMLFieldMapping *SAMLFieldMapping

+ SAMLIdpLoginAllowed bool

+ SAMLIdpURL string

+ SAMLSignatureAlgorithm string

+ SAMLVariant string

+ type AccountAuthenticationMethodUpdate struct

+ AuthenticationMethodEnabled bool

+ AuthenticationMethodName string

+ AutoJoinTeamID string

+ SAMLCertificate string

+ SAMLDigestAlgorithm string

+ SAMLEntity string

+ SAMLFieldMapping *SAMLFieldMapping

+ SAMLIdpLoginAllowed bool

+ SAMLIdpURL string

+ SAMLSignatureAlgorithm string

+ SAMLVariant string

+ type AssociateStaticIPRequest struct

+ ServiceName string

+ type AzurePrivatelinkConnectionResponse struct

+ PrivateEndpointID string

+ PrivatelinkConnectionID string

+ State string

+ UserIPAddress string

+ type AzurePrivatelinkConnectionUpdateRequest struct

+ UserIPAddress string

+ type AzurePrivatelinkConnectionsResponse struct

+ Connections []AzurePrivatelinkConnectionResponse

type AzurePrivatelinkHandler

+ func (h *AzurePrivatelinkHandler) ConnectionApprove(project, serviceName, privatelinkConnectionId string) error

+ func (h *AzurePrivatelinkHandler) ConnectionGet(project, serviceName string, privatelinkConnectionID *string) (*AzurePrivatelinkConnectionResponse, error)

+ func (h *AzurePrivatelinkHandler) ConnectionUpdate(project, serviceName, privatelinkConnectionId string, ...) error

+ func (h *AzurePrivatelinkHandler) ConnectionsList(project, serviceName string) (*AzurePrivatelinkConnectionsResponse, error)

+ func (h *AzurePrivatelinkHandler) Refresh(project, serviceName string) error

type Backup

+ AdditionalRegions []*BackupAdditionalRegion

+ BackupName string

+ StorageLocation string

+ type BackupAdditionalRegion struct

+ Cloud string

+ Region string

+ type BackupConfig struct

+ FrequentIntervalMinutes int

+ FrequentOldestAgeMinutes int

+ InfrequentIntervalMinutes int

+ InfrequentOldestAgeMinutes int

+ Interval int

+ MaxCount int

+ RecoveryMode string

type BillingGroupRequest

+ CopyFromBillingGroup *string

+ type ClickhouseDatabase struct

+ Engine string

+ Name string

+ Required bool

+ type ClickhouseDatabaseHandler struct

+ func (h *ClickhouseDatabaseHandler) Create(project, service, database string) error

+ func (h *ClickhouseDatabaseHandler) Delete(project, service, database string) error

+ func (h *ClickhouseDatabaseHandler) Get(project, service, database string) (*ClickhouseDatabase, error)

+ func (h *ClickhouseDatabaseHandler) List(project, service string) (*ListClickhouseDatabaseResponse, error)

+ type ClickhouseDatabaseRequest struct

+ Database string

+ type ClickhouseQueryColumnMeta struct

+ Name string

+ Type string

+ type ClickhouseQueryHandler struct

+ func (h *ClickhouseQueryHandler) Query(project, service, database, query string) (*ClickhouseQueryResponse, error)

+ type ClickhouseQueryRequest struct

+ Database string

+ Query string

+ type ClickhouseQueryResponse struct

+ Data []interface{}

+ Meta []ClickhouseQueryColumnMeta

+ type ClickhouseUser struct

+ Name string

+ Password string

+ Privileges []ClickhouseUserPrivilege

+ Required bool

+ Roles []ClickhouseUserRole

+ UUID string

+ type ClickhouseUserHandler struct

+ func (h *ClickhouseUserHandler) Create(project, service, name string) (*ClickhouseUserResponse, error)

+ func (h *ClickhouseUserHandler) Delete(project, service, uuid string) error

+ func (h *ClickhouseUserHandler) Get(project, service, uuid string) (*ClickhouseUser, error)

+ func (h *ClickhouseUserHandler) List(project, service string) (*ListClickhouseUserResponse, error)

+ func (h *ClickhouseUserHandler) ResetPassword(project, service, uuid, password string) (string, error)

+ type ClickhouseUserPrivilege struct

+ AccessType string

+ Column string

+ Database string

+ GrantOption bool

+ IsPartialRevoke bool

+ Table string

+ type ClickhouseUserRequest struct

+ Name string

+ type ClickhouseUserResponse struct

+ User ClickhouseUser

+ type ClickhouseUserRole struct

+ IsDefault bool

+ Name string

+ UUID string

+ WithAdminOption bool

type Client

+ ClickHouseQuery *ClickhouseQueryHandler

+ ClickhouseDatabase *ClickhouseDatabaseHandler

+ ClickhouseUser *ClickhouseUserHandler

+ FlinkApplicationVersions *FlinkApplicationVersionHandler

+ FlinkApplications *FlinkApplicationHandler

+ KafkaSchemaRegistryACLs *KafkaSchemaRegistryACLHandler

+ ServiceTags *ServiceTagsHandler

+ ServiceTypes *ServiceTypesHandler

+ StaticIPs *StaticIPsHandler

+ func SetupEnvClient(userAgent string) (*Client, error)

type ConnectionInfo

+ MySQLParams []MySQLParams

+ MySQLReplicaURI string

+ MySQLStandbyURIs []string

+ MySQLURIs []string

+ type CreateFlinkApplicationRequest struct

+ ApplicationVersion interface{}

+ Name string

type CreateFlinkTableRequest

+ KafkaConnectorType string

+ KafkaKeyFields []string

+ KafkaKeyFormat string

+ KafkaStartupMode string

+ KafkaValueFieldsInclude string

+ KafkaValueFormat string

+ OpenSearchIndex string

+ UpsertKafka *FlinkTableUpsertKafka

+ type CreateKafkaSchemaRegistryACLRequest struct

+ Permission string

+ Resource string

+ Username string

type CreateProjectRequest

+ Tags map[string]string

type CreateServiceRequest

+ DiskSpaceMB int

+ StaticIPs []string

type CreateServiceUserRequest

+ Authentication *string

+ type CreateStaticIPRequest struct

+ CloudName string

+ type CreateStaticIPResponse struct

+ type DeleteStaticIPRequest struct

+ StaticIPAddressID string

+ type DetailedFlinkApplicationResponse struct

+ ApplicationVersions []interface{}

+ CurrentDeployment interface{}

+ type DetailedFlinkApplicationVersionResponse struct

+ CreatedAt string

+ CreatedBy string

+ ID string

+ Version int

+ type FlinkApplicationHandler struct

+ func (h *FlinkApplicationHandler) Create(project string, service string, req CreateFlinkApplicationRequest) (*DetailedFlinkApplicationResponse, error)

+ func (h *FlinkApplicationHandler) Delete(project string, service string, applicationID string) (*DetailedFlinkApplicationResponse, error)

+ func (h *FlinkApplicationHandler) Get(project string, service string, applicationID string) (*DetailedFlinkApplicationResponse, error)

+ func (h *FlinkApplicationHandler) List(project string, service string) (*FlinkApplicationListResponse, error)

+ func (h *FlinkApplicationHandler) Update(project string, service string, applicationID string, ...) (*DetailedFlinkApplicationResponse, error)

+ type FlinkApplicationListResponse struct

+ Applications []GenericFlinkApplicationResponse

+ type FlinkApplicationVersionHandler struct

+ func (h *FlinkApplicationVersionHandler) Create(project string, service string, applicationID string, ...) (*DetailedFlinkApplicationVersionResponse, error)

+ func (h *FlinkApplicationVersionHandler) Delete(project string, service string, applicationID string, ...) (*DetailedFlinkApplicationVersionResponse, error)

+ func (h *FlinkApplicationVersionHandler) Get(project string, service string, applicationID string, ...) (*DetailedFlinkApplicationVersionResponse, error)

+ func (h *FlinkApplicationVersionHandler) Validate(project string, service string, applicationID string, ...) (*ValidateFlinkApplicationVersionResponse, error)

+ type FlinkApplicationVersionRelation struct

+ CreateTable string

+ IntegrationID string

type FlinkJobHandler

+ func (h *FlinkJobHandler) Validate(project, service string, req ValidateFlinkJobRequest) (*ValidateFlinkJobResponse, error)

type FlinkTableHandler

+ func (h *FlinkTableHandler) Validate(project, service string, req ValidateFlinkTableRequest) (*ValidateFlinkTableResponse, error)

+ type FlinkTableUpsertKafka struct

+ KeyFields []string

+ KeyFormat string

+ ScanStartupMode string

+ Topic string

+ ValueFieldsInclude string

+ ValueFormat string

+ type GenericFlinkApplicationResponse struct

+ CreatedAt string

+ CreatedBy string

+ ID string

+ Name string

+ UpdatedAt string

+ UpdatedBy string

+ type GenericFlinkApplicationVersionRequest struct

+ Sinks []FlinkApplicationVersionRelation

+ Sources []FlinkApplicationVersionRelation

+ Statement string

+ type GenericFlinkApplicationVersionResponse struct

+ type GetServicePlanPricingResponse struct

+ BasePriceUSD string

+ ExtraDiskPricePerGBUSD string

+ type GetServicePlanResponse struct

+ DiskSpaceCapMB int

+ DiskSpaceMB int

+ DiskSpaceStepMB int

+ type IntegrationEndpointType struct

+ EndpointType string

+ ServiceTypes []string

+ Title string

+ UserConfigSchema UserConfigSchema

+ type IntegrationType struct

+ DestDescription string

+ DestServiceTypes []string

+ IntegrationType string

+ SourceDescription string

+ SourceServiceTypes []string

+ UserConfigSchema UserConfigSchema

+ type KafkaSchemaRegistryACL struct

+ ID string

+ Permission string

+ Resource string

+ Username string

+ type KafkaSchemaRegistryACLHandler struct

+ func (h *KafkaSchemaRegistryACLHandler) Create(project, service string, req CreateKafkaSchemaRegistryACLRequest) (*KafkaSchemaRegistryACL, error)

+ func (h *KafkaSchemaRegistryACLHandler) Delete(project, serviceName, aclID string) error

+ func (h *KafkaSchemaRegistryACLHandler) Get(project, serviceName, aclID string) (*KafkaSchemaRegistryACL, error)

+ func (h *KafkaSchemaRegistryACLHandler) List(project, serviceName string) ([]*KafkaSchemaRegistryACL, error)

+ type KafkaSchemaRegistryACLResponse struct

+ ACL []*KafkaSchemaRegistryACL

type KafkaSchemaSubject

+ SchemaType string

type KafkaSchemaSubjectVersion

+ SchemaType string

+ type ListClickhouseDatabaseResponse struct

+ Databases []ClickhouseDatabase

+ type ListClickhouseUserResponse struct

+ Users []ClickhouseUser

+ type ListStaticIPResponse struct

+ StaticIPs []StaticIP

+ type MaintenanceUpdate struct

+ Deadline *string

+ Description string

+ StartAfter string

+ StartAt *string

type MaintenanceWindow

+ Updates []*MaintenanceUpdate

+ type MySQLParams struct

+ DatabaseName string

+ Host string

+ Password string

+ Port string

+ SSLMode string

+ User string

type Project

+ Tags map[string]string

+ type ProjectIntegrationEndpointTypesResponse struct

+ EndpointTypes []IntegrationEndpointType

+ type ProjectIntegrationTypesResponse struct

+ IntegrationTypes []IntegrationType

+ type ProjectServiceTypesResponse struct

+ ServiceTypes map[string]ServiceType

type ProjectsHandler

+ func (h *ProjectsHandler) IntegrationEndpointTypes(project string) ([]IntegrationEndpointType, error)

+ func (h *ProjectsHandler) IntegrationTypes(project string) ([]IntegrationType, error)

+ func (h *ProjectsHandler) ServiceTypes(project string) (map[string]ServiceType, error)

type ReplicationFlow

+ OffsetSyncsTopicLocation string

+ type SAMLFieldMapping struct

+ Email string

+ FirstName string

+ Identity string

+ LastName string

+ RealName string

type Service

+ DiskSpaceMB int

+ Features ServiceFeatures

+ SchemaRegistryACL []*KafkaSchemaRegistryACL

+ type ServiceFeatures struct

+ EnhancedLogging bool

+ ImprovedTopicManagement bool

+ IndexPatterns bool

+ KafkaConfigBackupsEnabled bool

+ KafkaConnect bool

+ KafkaConnectServiceIntegration bool

+ KafkaMirrormaker bool

+ KafkaRest bool

+ KafkaStrictAccessCertChecks bool

+ KafkaTopicInfo bool

+ Karapace bool

+ KarapaceJSONSchema bool

+ KarapaceRest bool

+ Letsencrypt bool

+ PGAllowReplication bool

+ SchemaRegistry bool

+ ServiceIntegrations bool

+ TopicManagement bool

+ type ServicePlan struct

+ BackupConfig *BackupConfig

+ MaxMemoryPercent int

+ NodeCount int

+ Regions interface{}

+ ServicePlan string

+ ServiceType string

+ type ServiceTagsHandler struct

+ func (h *ServiceTagsHandler) Get(project, service string) (*ServiceTagsResponse, error)

+ func (h *ServiceTagsHandler) Set(project, service string, req ServiceTagsRequest) (*ServiceTagsResponse, error)

+ type ServiceTagsRequest struct

+ Tags map[string]string

+ type ServiceTagsResponse struct

+ Tags map[string]string

+ type ServiceType struct

+ DefaultVersion string

+ Description string

+ LatestAvailableVersion string

+ ServicePlans []ServicePlan

+ UserConfigSchema UserConfigSchema

+ type ServiceTypesHandler struct

+ func (h *ServiceTypesHandler) GetPlan(project, serviceType, servicePlan string) (*GetServicePlanResponse, error)

+ func (h *ServiceTypesHandler) GetPlanPricing(project, serviceType, servicePlan, cloudName string) (*GetServicePlanPricingResponse, error)

+ type StaticIP struct

+ CloudName string

+ IPAddress string

+ ServiceName string

+ State string

+ StaticIPAddressID string

+ type StaticIPsHandler struct

+ func (h *StaticIPsHandler) Associate(project, staticIPID string, req AssociateStaticIPRequest) error

+ func (h *StaticIPsHandler) Create(project string, req CreateStaticIPRequest) (*CreateStaticIPResponse, error)

+ func (h *StaticIPsHandler) Delete(project string, req DeleteStaticIPRequest) error

+ func (h *StaticIPsHandler) Dissociate(project, staticIPID string) error

+ func (h *StaticIPsHandler) Get(project, staticIPID string) (*StaticIP, error)

+ func (h *StaticIPsHandler) List(project string) (*ListStaticIPResponse, error)

+ type UpdateFlinkApplicationRequest struct

+ Name string

type UpdateProjectRequest

+ AddAccountOwnersAdminAccess *bool

+ Tags map[string]string

type UpdateServiceRequest

+ DiskSpaceMB int

+ Karapace *bool

+ type UserConfigSchema struct

+ AdditionalProperties interface{}

+ CreateOnly bool

+ Default interface{}

+ Description string

+ Enum []interface{}

+ Example interface{}

+ Items *UserConfigSchema

+ MaxItems *int

+ MaxLength *int

+ Maximum *float64

+ MinLength *int

+ Minimum *float64

+ OneOf []UserConfigSchema

+ Pattern string

+ Properties map[string]UserConfigSchema

+ Required []string

+ Title string

+ Type interface{}

+ UserError string

+ type ValidateFlinkApplicationVersionResponse struct

+ type ValidateFlinkApplicationVersionStatementError struct

+ Message string

+ Position flinkPosition

+ type ValidateFlinkJobRequest struct

+ Statement string

+ TableIDs []string

+ type ValidateFlinkJobResponse struct

+ JobValidateError struct{ ... }

+ type ValidateFlinkTableRequest CreateFlinkTableRequest

+ type ValidateFlinkTableResponse struct

+ TableValidateError struct{ ... }

v1.7.0

Nov 4, 2021

Changes in this version

+ type AzurePrivatelinkHandler struct

+ func (h *AzurePrivatelinkHandler) Create(project, serviceName string, r AzurePrivatelinkRequest) (*AzurePrivatelinkResponse, error)

+ func (h *AzurePrivatelinkHandler) Delete(project, serviceName string) error

+ func (h *AzurePrivatelinkHandler) Get(project, serviceName string) (*AzurePrivatelinkResponse, error)

+ func (h *AzurePrivatelinkHandler) Update(project, serviceName string, r AzurePrivatelinkRequest) (*AzurePrivatelinkResponse, error)

+ type AzurePrivatelinkRequest struct

+ UserSubscriptionIDs []string

+ type AzurePrivatelinkResponse struct

+ AzureServiceAlias string

+ AzureServiceID string

+ Message string

+ State string

+ UserSubscriptionIDs []string

type Client

+ AzurePrivatelink *AzurePrivatelinkHandler

+ FlinkJobs *FlinkJobHandler

+ FlinkTables *FlinkTableHandler

type ConnectionInfo

+ FlinkHostPorts []string

+ type CreateFlinkJobRequest struct

+ JobName string

+ Statement string

+ TablesIds []string

+ type CreateFlinkJobResponse struct

+ JobId string

+ JobName string

+ type CreateFlinkTableRequest struct

+ IntegrationId string

+ JDBCTable string

+ KafkaTopic string

+ LikeOptions string

+ Name string

+ PartitionedBy string

+ SchemaSQL string

+ type CreateFlinkTableResponse struct

type CreateProjectRequest

+ AddAccountOwnersAdminAccess bool

+ type DeleteFlinkTableRequest struct

+ TableId string

+ type FlinkJobHandler struct

+ func (h *FlinkJobHandler) Create(project, service string, req CreateFlinkJobRequest) (*CreateFlinkJobResponse, error)

+ func (h *FlinkJobHandler) Get(project, service string, req GetFlinkJobRequest) (*GetFlinkJobResponse, error)

+ func (h *FlinkJobHandler) Patch(project, service string, req PatchFlinkJobRequest) error

+ type FlinkTableHandler struct

+ func (h *FlinkTableHandler) Create(project, service string, req CreateFlinkTableRequest) (*CreateFlinkTableResponse, error)

+ func (h *FlinkTableHandler) Delete(project, service string, req DeleteFlinkTableRequest) error

+ func (h *FlinkTableHandler) Get(project, service string, req GetFlinkTableRequest) (*GetFlinkTableResponse, error)

+ func (h *FlinkTableHandler) List(project, service string) (*ListFlinkTableResponse, error)

+ type GetFlinkJobRequest struct

+ JobId string

+ type GetFlinkJobResponse struct

+ Duration int

+ EndTime int

+ IsStoppable bool

+ JID string

+ MaxParallelism int

+ Name string

+ Now int

+ Plan struct{ ... }

+ StartTime int

+ State string

+ StatusCounts struct{ ... }

+ Timestamps struct{ ... }

+ Vertices []interface{}

+ type GetFlinkTableRequest struct

+ TableId string

+ type GetFlinkTableResponse struct

+ type ListFlinkTableResponse struct

+ Tables []flinkTable

+ type PatchFlinkJobRequest struct

+ JobId string

v1.6.2

Sep 24, 2021

Changes in this version

type ReplicationFlow

+ EmitHeartbeatsEnabled bool

+ ReplicationPolicyClass string

+ SyncGroupOffsetsEnabled bool

+ SyncGroupOffsetsIntervalSeconds int

v1.6.1

Sep 20, 2021

Changes in this version

+ const UpdateOperationResetCredentials

+ const UpdateOperationSetAccessControl

type AccessControl

+ PostgresAllowReplication *bool

type ConnectionInfo

+ OpensearchDashboardsURI string

+ OpensearchPassword string

+ OpensearchURIs []string

+ OpensearchUsername string

type ModifyServiceUserRequest

+ AccessControl *AccessControl

v1.6.0

Aug 30, 2021

Changes in this version

+ type KafkaConnectorStatus struct

+ State string

+ Tasks []KafkaConnectorTaskStatus

+ type KafkaConnectorStatusResponse struct

+ Status KafkaConnectorStatus

+ type KafkaConnectorTaskStatus struct

+ Id int

+ State string

+ Trace string

type KafkaConnectorsHandler

+ func (h *KafkaConnectorsHandler) GetByName(project, service, name string) (*KafkaConnector, error)

+ func (h *KafkaConnectorsHandler) Status(project, service, name string) (*KafkaConnectorStatusResponse, error)

v1.5.13

Aug 6, 2021

Changes in this version

+ func ToStringPointer(s string) *string

+ type AWSPrivatelinkHandler struct

+ func (h *AWSPrivatelinkHandler) Create(project, serviceName string, principals []string) (*AWSPrivatelinkResponse, error)

+ func (h *AWSPrivatelinkHandler) Delete(project, serviceName string) error

+ func (h *AWSPrivatelinkHandler) Get(project, serviceName string) (*AWSPrivatelinkResponse, error)

+ func (h *AWSPrivatelinkHandler) Update(project, serviceName string, principals []string) (*AWSPrivatelinkResponse, error)

+ type AWSPrivatelinkRequest struct

+ Principals []string

+ type AWSPrivatelinkResponse struct

+ AWSServiceID string

+ AWSServiceName string

+ Principals []string

+ State string

type AccessControl

+ RedisACLChannels []string

+ type BillingGroup struct

+ Id string

+ type BillingGroupHandler struct

+ func (h *BillingGroupHandler) AssignProjects(id string, projects []string) error

+ func (h *BillingGroupHandler) Create(req BillingGroupRequest) (*BillingGroup, error)

+ func (h *BillingGroupHandler) Delete(id string) error

+ func (h *BillingGroupHandler) Get(id string) (*BillingGroup, error)

+ func (h *BillingGroupHandler) GetProjects(id string) ([]string, error)

+ func (h *BillingGroupHandler) ListAll() ([]BillingGroup, error)

+ func (h *BillingGroupHandler) Update(id string, req BillingGroupRequest) (*BillingGroup, error)

+ type BillingGroupListResponse struct

+ BillingGroupList []BillingGroup

+ type BillingGroupProject struct

+ AvailableCredits string

+ EstimatedBalance string

+ ProjectName string

+ type BillingGroupProjectsResponse struct

+ Projects []BillingGroupProject

+ type BillingGroupRequest struct

+ AccountId *string

+ AddressLines []string

+ BillingCurrency *string

+ BillingEmails []*ContactEmail

+ BillingExtraText *string

+ BillingGroupName string

+ CardId *string

+ City *string

+ Company *string

+ CountryCode *string

+ State *string

+ VatId *string

+ ZipCode *string

+ type BillingGroupResponse struct

+ BillingGroup *BillingGroup

type Client

+ AWSPrivatelink *AWSPrivatelinkHandler

+ BillingGroup *BillingGroupHandler

+ ServiceTask *ServiceTaskHandler

type CreateKafkaTopicRequest

+ Tags []KafkaTopicTag

type CreateProjectRequest

+ BillingGroupId string

+ UseSourceProjectBillingGroup bool

type KafkaTopic

+ Tags []KafkaTopicTag

type KafkaTopicConfigResponse

+ Tags []KafkaTopicTag

+ type KafkaTopicTag struct

+ Key string

+ Value string

type KafkaTopicsHandler

+ func (h *KafkaTopicsHandler) V2List(project, service string, topics []string) ([]*KafkaTopic, error)

+ type KafkaV2TopicsResponse struct

+ Topics []*KafkaTopic

+ type NodeState struct

+ Name string

+ ProgressUpdates []ProgressUpdate

+ Role string

+ State string

+ type ProgressUpdate struct

+ Completed bool

+ Current int

+ Max int

+ Min int

+ Phase string

+ Unit string

type Project

+ BillingGroupId string

+ BillingGroupName string

+ type ProjectEvent struct

+ Actor string

+ EventDesc string

+ EventType string

+ ServiceName string

+ Time string

+ type ProjectEventLogEntriesResponse struct

+ Events []*ProjectEvent

type ProjectUser

+ TeamId string

+ TeamName string

type ProjectsHandler

+ func (h *ProjectsHandler) GetEventLog(project string) ([]*ProjectEvent, error)

type Service

+ NodeStates []*NodeState

+ type ServiceTask struct

+ CreateTime string

+ Id string

+ Result string

+ SourcePgVersion string

+ Success *bool

+ TargetPgVersion string

+ TaskType string

+ type ServiceTaskHandler struct

+ func (h ServiceTaskHandler) Create(project, service string, r ServiceTaskRequest) (*ServiceTaskResponse, error)

+ func (h ServiceTaskHandler) Get(project, service, id string) (*ServiceTaskResponse, error)

+ type ServiceTaskRequest struct

+ TargetVersion string

+ TaskType string

+ type ServiceTaskResponse struct

+ Task ServiceTask

type UpdateKafkaTopicRequest

+ Tags []KafkaTopicTag

type UpdateProjectRequest

+ Name string

v1.5.12

Jan 30, 2021

v1.5.11

Dec 2, 2020

Changes in this version

+ func IsAlreadyExists(err error) bool

+ type AccessControl struct

+ RedisACLCategories []string

+ RedisACLCommands []string

+ RedisACLKeys []string

type CreateProjectRequest

+ VatID *string

type CreateServiceUserRequest

+ AccessControl AccessControl

type ServiceUser

+ AccessCertNotValidAfterTime string

+ AccessControl AccessControl

type UpdateProjectRequest

+ VatID *string

v1.5.10

Oct 16, 2020

Changes in this version

type CreateKafkaTopicRequest

+ Config KafkaTopicConfig

type KafkaTopic

+ Config KafkaTopicConfigResponse

+ type KafkaTopicConfig struct

+ CleanupPolicy string

+ CompressionType string

+ DeleteRetentionMs *int64

+ FileDeleteDelayMs *int64

+ FlushMessages *int64

+ FlushMs *int64

+ IndexIntervalBytes *int64

+ MaxCompactionLagMs *int64

+ MaxMessageBytes *int64

+ MessageDownconversionEnable *bool

+ MessageFormatVersion string

+ MessageTimestampDifferenceMaxMs *int64

+ MessageTimestampType string

+ MinCleanableDirtyRatio *float64

+ MinCompactionLagMs *int64

+ MinInsyncReplicas *int64

+ Preallocate *bool

+ RetentionBytes *int64

+ RetentionMs *int64

+ SegmentBytes *int64

+ SegmentIndexBytes *int64

+ SegmentJitterMs *int64

+ SegmentMs *int64

+ UncleanLeaderElectionEnable *bool

+ type KafkaTopicConfigResponse struct

+ CleanupPolicy KafkaTopicConfigResponseString

+ CompressionType KafkaTopicConfigResponseString

+ DeleteRetentionMs KafkaTopicConfigResponseInt

+ FileDeleteDelayMs KafkaTopicConfigResponseInt

+ FlushMessages KafkaTopicConfigResponseInt

+ FlushMs KafkaTopicConfigResponseInt

+ IndexIntervalBytes KafkaTopicConfigResponseInt

+ MaxCompactionLagMs KafkaTopicConfigResponseInt

+ MaxMessageBytes KafkaTopicConfigResponseInt

+ MessageDownconversionEnable KafkaTopicConfigResponseBool

+ MessageFormatVersion KafkaTopicConfigResponseString

+ MessageTimestampDifferenceMaxMs KafkaTopicConfigResponseInt

+ MessageTimestampType KafkaTopicConfigResponseString

+ MinCleanableDirtyRatio KafkaTopicConfigResponseFloat

+ MinCompactionLagMs KafkaTopicConfigResponseInt

+ MinInsyncReplicas KafkaTopicConfigResponseInt

+ Preallocate KafkaTopicConfigResponseBool

+ RetentionBytes KafkaTopicConfigResponseInt

+ RetentionMs KafkaTopicConfigResponseInt

+ SegmentBytes KafkaTopicConfigResponseInt

+ SegmentIndexBytes KafkaTopicConfigResponseInt

+ SegmentJitterMs KafkaTopicConfigResponseInt

+ SegmentMs KafkaTopicConfigResponseInt

+ UncleanLeaderElectionEnable KafkaTopicConfigResponseBool

+ type KafkaTopicConfigResponseBool struct

+ Source string

+ Synonyms []struct{ ... }

+ Value bool

+ type KafkaTopicConfigResponseFloat struct

+ Source string

+ Synonyms []struct{ ... }

+ Value float64

+ type KafkaTopicConfigResponseInt struct

+ Source string

+ Synonyms []struct{ ... }

+ Value int64

+ type KafkaTopicConfigResponseString struct

+ Source string

+ Synonyms []struct{ ... }

+ Value string

type UpdateKafkaTopicRequest

+ Config KafkaTopicConfig

v1.5.9

Sep 29, 2020

Changes in this version

+ type ModifyServiceUserRequest struct

+ Authentication *string

+ NewPassword string

+ Operation *string

type ServiceUsersHandler

+ func (h *ServiceUsersHandler) Update(project, service, username string, update ModifyServiceUserRequest) (*ServiceUser, error)

type VPCPeeringConnectionsHandler

+ func (h *VPCPeeringConnectionsHandler) DeleteVPCPeeringWithResourceGroup(project, vpcID, peerCloudAccount, peerVPC, peerResourceGroup string, ...) error

+ func (h *VPCPeeringConnectionsHandler) GetVPCPeeringWithResourceGroup(project string, vpcID string, peerCloudAccount string, peerVPC string, ...) (*VPCPeeringConnection, error)

v1.5.8

Sep 3, 2020

Changes in this version

+ func ContactEmailFromStringSlice(emails []string) *[]*ContactEmail

+ func IsNotFound(err error) bool

type CreateProjectRequest

+ BillingCurrency string

type KafkaSubjectSchemasHandler

+ func (h *KafkaSubjectSchemasHandler) GetConfiguration(project, service, subjectName string) (*KafkaSchemaConfigResponse, error)

+ func (h *KafkaSubjectSchemasHandler) UpdateConfiguration(project, service, subjectName, compatibility string) (*KafkaSchemaConfigUpdateResponse, error)

type Project

+ BillingCurrency string

+ CopyFromProject string

+ func (p Project) GetBillingEmailsAsStringSlice() []string

+ func (p Project) GetTechnicalEmailsAsStringSlice() []string

type UpdateProjectRequest

+ BillingCurrency string

v1.5.7

Aug 21, 2020

Changes in this version

type Client

+ TransitGatewayVPCAttachment *TransitGatewayVPCAttachmentHandler

type KafkaSubjectSchemasHandler

+ func (h *KafkaSubjectSchemasHandler) Update(project, service, subjectName, compatibility string) (*KafkaSchemaConfigUpdateResponse, error)

type Service

+ Powered bool

type ServiceComponents

+ KafkaAuthenticationMethod string

+ Ssl string

v1.5.6

Jul 21, 2020

Changes in this version

type CreateVPCPeeringConnectionRequest

+ PeerAzureAppId string

+ PeerAzureTenantId string

+ PeerResourceGroup string

+ UserPeerNetworkCIDRs []string

+ type TransitGatewayVPCAttachment struct

+ CIDR string

+ PeerCloudAccount string

+ PeerResourceGroup string

+ PeerVPC string

+ type TransitGatewayVPCAttachmentHandler struct

+ func (h *TransitGatewayVPCAttachmentHandler) Update(project, projectVPCId string, req TransitGatewayVPCAttachmentRequest) (*VPC, error)

+ type TransitGatewayVPCAttachmentRequest struct

+ Add []TransitGatewayVPCAttachment

+ Delete []string

type VPCPeeringConnection

+ PeerAzureAppId string

+ PeerAzureTenantId string

+ PeerResourceGroup string

+ UserPeerNetworkCIDRs []string

+ VPCPeeringConnectionType string

v1.5.5

May 12, 2020

v1.5.4

May 12, 2020

Changes in this version

type Client

+ KafkaMirrorMakerReplicationFlow *MirrorMakerReplicationFlowHandler

+ type MirrorMakerReplicationFlowHandler struct

+ func (h *MirrorMakerReplicationFlowHandler) Create(project, service string, req MirrorMakerReplicationFlowRequest) error

+ func (h *MirrorMakerReplicationFlowHandler) Delete(project, service, sourceCluster, targetCluster string) error

+ func (h *MirrorMakerReplicationFlowHandler) Get(project, service, sourceCluster, targetCluster string) (*MirrorMakerReplicationFlowResponse, error)

+ func (h *MirrorMakerReplicationFlowHandler) List(project, service string) (*MirrorMakerReplicationFlowsResponse, error)

+ func (h *MirrorMakerReplicationFlowHandler) Update(project, service string, req MirrorMakerReplicationFlowRequest) (*MirrorMakerReplicationFlowsResponse, error)

+ type MirrorMakerReplicationFlowRequest struct

+ type MirrorMakerReplicationFlowResponse struct

+ ReplicationFlow ReplicationFlow

+ type MirrorMakerReplicationFlowsResponse struct

+ ReplicationFlows []ReplicationFlow

+ type ReplicationFlow struct

+ Enabled bool

+ SourceCluster string

+ TargetCluster string

+ Topics []string

+ TopicsBlacklist []string

v1.5.3

Feb 20, 2020

Changes in this version

type AccountAuthenticationMethod

+ SAMLAcsUrl string

+ SAMLMetadataUrl string

v1.5.2

Feb 12, 2020

Changes in this version

type AccountTeamInvitesHandler

+ func (h AccountTeamInvitesHandler) Delete(accountId, teamId, userEmail string) error

v1.5.1

Feb 7, 2020

v1.5.0

Feb 4, 2020

Changes in this version

+ type Account struct

+ BillingEnabled bool

+ CreateTime *time.Time

+ Id string

+ Name string

+ OwnerTeamId string

+ TenantId string

+ UpdateTime *time.Time

+ type AccountAuthenticationMethod struct

+ AccountId string

+ AutoJoinTeamId string

+ CreateTime *time.Time

+ DeleteTime *time.Time

+ Enabled bool

+ Id string

+ Name string

+ SAMLCertificate string

+ SAMLCertificateIssuer string

+ SAMLCertificateNotValidAfter *time.Time

+ SAMLCertificateNotValidBefore *time.Time

+ SAMLCertificateSubject string

+ SAMLEntity string

+ SAMLIdpUrl string

+ State string

+ Type string

+ UpdateTime *time.Time

+ type AccountAuthenticationResponse struct

+ AuthenticationMethod AccountAuthenticationMethod

+ type AccountAuthenticationsHandler struct

+ func (h AccountAuthenticationsHandler) Create(accountId string, a AccountAuthenticationMethod) (*AccountAuthenticationResponse, error)

+ func (h AccountAuthenticationsHandler) Delete(accountId, authId string) error

+ func (h AccountAuthenticationsHandler) Get(accountId, authId string) (*AccountAuthenticationResponse, error)

+ func (h AccountAuthenticationsHandler) List(accountId string) (*AccountAuthenticationsResponse, error)

+ func (h AccountAuthenticationsHandler) Update(accountId string, a AccountAuthenticationMethod) (*AccountAuthenticationResponse, error)

+ type AccountAuthenticationsResponse struct

+ AuthenticationMethods []AccountAuthenticationMethod

+ type AccountResponse struct

+ Account Account

+ type AccountTeam struct

+ AccountId string

+ CreateTime *time.Time

+ Id string

+ Name string

+ UpdateTime *time.Time

+ type AccountTeamInvite struct

+ AccountId string

+ AccountName string

+ CreateTime *time.Time

+ InvitedByUserEmail string

+ TeamId string

+ TeamName string

+ UserEmail string

+ type AccountTeamInvitesHandler struct

+ func (h AccountTeamInvitesHandler) List(accountId, teamId string) (*AccountTeamInvitesResponse, error)

+ type AccountTeamInvitesResponse struct

+ Invites []AccountTeamInvite

+ type AccountTeamMember struct

+ CreateTime *time.Time

+ RealName string

+ TeamId string

+ TeamName string

+ UpdateTime *time.Time

+ UserEmail string

+ UserId string

+ type AccountTeamMemberResponse struct

+ Member AccountTeamMember

+ type AccountTeamMembersHandler struct

+ func (h AccountTeamMembersHandler) Delete(accountId, teamId, userId string) error

+ func (h AccountTeamMembersHandler) Invite(accountId, teamId, email string) error

+ func (h AccountTeamMembersHandler) List(accountId, teamId string) (*AccountTeamMembersResponse, error)

+ type AccountTeamMembersResponse struct

+ Members []AccountTeamMember

+ type AccountTeamProject struct

+ ProjectName string

+ TeamType string

+ type AccountTeamProjectsHandler struct

+ func (h AccountTeamProjectsHandler) Create(accountId, teamId string, p AccountTeamProject) error

+ func (h AccountTeamProjectsHandler) Delete(accountId, teamId, projectName string) error

+ func (h AccountTeamProjectsHandler) List(accountId, teamId string) (*AccountTeamProjectsResponse, error)

+ func (h AccountTeamProjectsHandler) Update(accountId, teamId string, p AccountTeamProject) error

+ type AccountTeamProjectsResponse struct

+ Projects []AccountTeamProject

+ type AccountTeamResponse struct

+ Team AccountTeam

+ type AccountTeamsHandler struct

+ func (h AccountTeamsHandler) Create(accountId string, team AccountTeam) (*AccountTeamResponse, error)

+ func (h AccountTeamsHandler) Delete(accountId, teamId string) error

+ func (h AccountTeamsHandler) Get(accountId, teamId string) (*AccountTeamResponse, error)

+ func (h AccountTeamsHandler) List(accountId string) (*AccountTeamsResponse, error)

+ func (h AccountTeamsHandler) Update(accountId, teamId string, team AccountTeam) (*AccountTeamResponse, error)

+ type AccountTeamsResponse struct

+ Teams []AccountTeam

+ type AccountsHandler struct

+ func (h AccountsHandler) Create(account Account) (*AccountResponse, error)

+ func (h AccountsHandler) Delete(id string) error

+ func (h AccountsHandler) Get(id string) (*AccountResponse, error)

+ func (h AccountsHandler) List() (*AccountsResponse, error)

+ func (h AccountsHandler) Update(id string, account Account) (*AccountResponse, error)

+ type AccountsResponse struct

+ Accounts []Account

type Client

+ AccountAuthentications *AccountAuthenticationsHandler

+ AccountTeamInvites *AccountTeamInvitesHandler

+ AccountTeamMembers *AccountTeamMembersHandler

+ AccountTeamProjects *AccountTeamProjectsHandler

+ AccountTeams *AccountTeamsHandler

+ Accounts *AccountsHandler

type CreateProjectRequest

+ AccountId string

type Project

+ AccountId string

type UpdateProjectRequest

+ AccountId string

v1.4.2

Jan 10, 2020

Changes in this version

type KafkaSchemaConfigResponse

+ CompatibilityLevel string

+ type KafkaSchemaConfigUpdateResponse struct

type KafkaSchemaSubjectVersion

+ Id int

+ Schema string

+ Subject string

+ Version int

type KafkaSchemaSubjectVersionResponse

+ Version KafkaSchemaSubjectVersion

+ type KafkaSchemaSubjectVersions struct

+ Versions []int

+ type KafkaSchemaSubjectVersionsResponse struct

v1.4.1

Jan 9, 2020

v1.4.0

Jan 7, 2020

Changes in this version

type APIResponse

+ func (r APIResponse) GetError() error

type Client

+ KafkaConnectors *KafkaConnectorsHandler

+ KafkaGlobalSchemaConfig *KafkaGlobalSchemaConfigHandler

+ KafkaSubjectSchemas *KafkaSubjectSchemasHandler

+ type KafkaConnector struct

+ Config KafkaConnectorConfig

+ Name string

+ Plugin KafkaConnectorPlugin

+ Tasks []KafkaConnectorTask

+ type KafkaConnectorConfig map[string]string

+ type KafkaConnectorPlugin struct

+ Author string

+ Class string

+ DocumentationURL string

+ Title string

+ Type string

+ Version string

+ type KafkaConnectorResponse struct

+ Connector KafkaConnector

+ type KafkaConnectorTask struct

+ Connector string

+ Task string

+ type KafkaConnectorsHandler struct

+ func (h *KafkaConnectorsHandler) Create(project, service string, c KafkaConnectorConfig) error

+ func (h *KafkaConnectorsHandler) Delete(project, service, name string) error

+ func (h *KafkaConnectorsHandler) Get(project, service, name string) (*KafkaConnectorResponse, error)

+ func (h *KafkaConnectorsHandler) List(project, service string) (*KafkaConnectorsResponse, error)

+ func (h *KafkaConnectorsHandler) Update(project, service, name string, c KafkaConnectorConfig) (*KafkaConnectorResponse, error)

+ type KafkaConnectorsResponse struct

+ Connectors []KafkaConnector

+ type KafkaGlobalSchemaConfigHandler struct

+ func (h *KafkaGlobalSchemaConfigHandler) Get(project, service string) (*KafkaSchemaConfigResponse, error)

+ func (h *KafkaGlobalSchemaConfigHandler) Update(project, service string, c KafkaSchemaConfig) (*KafkaSchemaConfigResponse, error)

+ type KafkaSchemaConfig struct

+ CompatibilityLevel string

+ type KafkaSchemaConfigResponse struct

+ type KafkaSchemaSubject struct

+ Schema string

+ type KafkaSchemaSubjectResponse struct

+ Id int

+ type KafkaSchemaSubjectVersion struct

+ Versions []int

+ type KafkaSchemaSubjectVersionResponse struct

+ type KafkaSchemaSubjects struct

+ Subjects []string

+ type KafkaSchemaSubjectsResponse struct

+ type KafkaSchemaValidateResponse struct

+ IsCompatible bool

+ type KafkaSubjectSchemasHandler struct

+ func (h *KafkaSubjectSchemasHandler) Add(project, service, name string, subject KafkaSchemaSubject) (*KafkaSchemaSubjectResponse, error)

+ func (h *KafkaSubjectSchemasHandler) Delete(project, service, name string, versions ...int) error

+ func (h *KafkaSubjectSchemasHandler) Get(project, service, name string, version int) (*KafkaSchemaSubjectResponse, error)

+ func (h *KafkaSubjectSchemasHandler) GetVersions(project, service, name string) (*KafkaSchemaSubjectVersionResponse, error)

+ func (h *KafkaSubjectSchemasHandler) List(project, service string) (*KafkaSchemaSubjectsResponse, error)

+ func (h *KafkaSubjectSchemasHandler) Validate(project, service, name string, version int, subject KafkaSchemaSubject) (bool, error)

+ type Response interface

+ GetError func() error

type Service

+ Components []*ServiceComponents

+ type ServiceComponents struct

+ Component string

+ Host string

+ Port int

+ Route string

+ Usage string

v1.3.0

Dec 23, 2019

Changes in this version

type Client

+ ElasticsearchACLs *ElasticSearchACLsHandler

+ type ElasticSearchACL struct

+ Rules []ElasticsearchACLRule

+ Username string

+ type ElasticSearchACLConfig struct

+ ACLs []ElasticSearchACL

+ Enabled bool

+ ExtendedAcl bool

+ func (conf *ElasticSearchACLConfig) Add(acl ElasticSearchACL) *ElasticSearchACLConfig

+ func (conf *ElasticSearchACLConfig) Delete(acl ElasticSearchACL) *ElasticSearchACLConfig

+ type ElasticSearchACLResponse struct

+ ElasticSearchACLConfig ElasticSearchACLConfig

+ type ElasticSearchACLsHandler struct

+ func (h *ElasticSearchACLsHandler) Get(project, service string) (*ElasticSearchACLResponse, error)

+ func (h *ElasticSearchACLsHandler) Update(project, service string, req ElasticsearchACLRequest) (*ElasticSearchACLResponse, error)

+ type ElasticsearchACLRequest struct

+ ElasticSearchACLConfig ElasticSearchACLConfig

+ type ElasticsearchACLRule struct

+ Index string

+ Permission string

type Service

+ Integrations []*ServiceIntegration

v1.2.0

Jun 18, 2019

Changes in this version

+ func GetUserAgentOrDefault(userAgent string) string

+ func Version() string

type Client

+ UserAgent string

v1.1.0

Jun 7, 2019

Changes in this version

type CreateServiceRequest

+ MaintenanceWindow *MaintenanceWindow

+ ServiceIntegrations []NewServiceIntegration

+ TerminationProtection bool

type CreateVPCPeeringConnectionRequest

+ PeerRegion *string

+ type MaintenanceWindow struct

+ DayOfWeek string

+ TimeOfDay string

+ type NewServiceIntegration struct

+ DestinationEndpointID *string

+ DestinationService *string

+ IntegrationType string

+ SourceEndpointID *string

+ SourceService *string

+ UserConfig map[string]interface{}

type Service

+ MaintenanceWindow MaintenanceWindow

+ TerminationProtection bool

type ServiceIntegrationEndpoint

+ EndpointConfig map[string]interface{}

type UpdateServiceRequest

+ MaintenanceWindow *MaintenanceWindow

+ TerminationProtection bool

type VPCPeeringConnection

+ PeerRegion *string

type VPCPeeringConnectionsHandler

+ func (h *VPCPeeringConnectionsHandler) DeleteVPCPeering(project, vpcID, peerCloudAccount, peerVPC string, peerRegion *string) error

+ func (h *VPCPeeringConnectionsHandler) GetVPCPeering(project string, vpcID string, peerCloudAccount string, peerVPC string, ...) (*VPCPeeringConnection, error)

v1.0.0

Sep 26, 2018

Changes in this version

type Backup

+ BackupTime string

+ DataSize int

+ type CAHandler struct

+ func (h *CAHandler) Get(project string) (string, error)

type CardsHandler

+ func (h *CardsHandler) Get(cardID string) (*Card, error)

type Client

+ CA *CAHandler

+ CardsHandler *CardsHandler

+ ConnectionPools *ConnectionPoolsHandler

+ KafkaACLs *KafkaACLHandler

+ ProjectUsers *ProjectUsersHandler

+ ServiceIntegrationEndpoints *ServiceIntegrationEndpointsHandler

+ ServiceIntegrations *ServiceIntegrationsHandler

+ VPCPeeringConnections *VPCPeeringConnectionsHandler

+ VPCs *VPCsHandler

+ type ConnectionInfo struct

+ CassandraHosts []string

+ ElasticsearchPassword string

+ ElasticsearchURIs []string

+ ElasticsearchUsername string

+ GrafanaURIs []string

+ InfluxDBDatabaseName string

+ InfluxDBPassword string

+ InfluxDBURIs []string

+ InfluxDBUsername string

+ KafkaAccessCert string

+ KafkaAccessKey string

+ KafkaConnectURI string

+ KafkaHosts []string

+ KafkaRestURI string

+ KibanaURI string

+ PostgresParams []PostgresParams

+ PostgresReplicaURI string

+ PostgresStandbyURIs []string

+ PostgresURIs []string

+ RedisPassword string

+ RedisSlaveURIs []string

+ RedisURIs []string

+ SchemaRegistryURI string

type ConnectionPool

+ ConnectionURI string

+ Database string

+ PoolMode string

+ PoolName string

+ PoolSize int

+ Username string

+ type ConnectionPoolsHandler struct

+ func (h *ConnectionPoolsHandler) Create(project string, serviceName string, req CreateConnectionPoolRequest) (*ConnectionPool, error)

+ func (h *ConnectionPoolsHandler) Delete(project, serviceName, poolName string) error

+ func (h *ConnectionPoolsHandler) Get(project, serviceName, poolName string) (*ConnectionPool, error)

+ func (h *ConnectionPoolsHandler) List(project, serviceName string) ([]*ConnectionPool, error)

+ func (h *ConnectionPoolsHandler) Update(project string, serviceName string, poolName string, ...) (*ConnectionPool, error)

+ type ContactEmail struct

+ Email string

+ type CreateConnectionPoolRequest struct

+ Database string

+ PoolMode string

+ PoolName string

+ PoolSize int

+ Username string

+ type CreateKafkaACLRequest struct

+ Permission string

+ Topic string

+ Username string

+ type CreateProjectInvitationRequest struct

+ MemberType string

+ UserEmail string

type CreateProjectRequest

+ BillingAddress *string

+ BillingEmails *[]*ContactEmail

+ BillingExtraText *string

+ CopyFromProject string

+ CountryCode *string

+ TechnicalEmails *[]*ContactEmail

+ type CreateServiceIntegrationEndpointRequest struct

+ EndpointName string

+ EndpointType string

+ UserConfig map[string]interface{}

+ type CreateServiceIntegrationRequest struct

+ DestinationEndpointID *string

+ DestinationService *string

+ IntegrationType string

+ SourceEndpointID *string

+ SourceService *string

+ UserConfig map[string]interface{}

type CreateServiceRequest

+ ProjectVPCID *string

+ UserConfig map[string]interface{}

+ type CreateVPCPeeringConnectionRequest struct

+ PeerCloudAccount string

+ PeerVPC string

+ type CreateVPCRequest struct

+ CloudName string

+ NetworkCIDR string

+ PeeringConnections []*VPCPeeringConnection

type Database

+ DatabaseName string

+ type DatabaseListResponse struct

+ Databases []*Database

type DatabasesHandler

+ func (h *DatabasesHandler) Get(projectName, serviceName, databaseName string) (*Database, error)

+ func (h *DatabasesHandler) List(project, service string) ([]*Database, error)

+ type KafkaACL struct

+ ID string

+ Permission string

+ Topic string

+ Username string

+ type KafkaACLHandler struct

+ func (h *KafkaACLHandler) Create(project, service string, req CreateKafkaACLRequest) (*KafkaACL, error)

+ func (h *KafkaACLHandler) Delete(project, serviceName, aclID string) error

+ func (h *KafkaACLHandler) Get(project, serviceName, aclID string) (*KafkaACL, error)

+ func (h *KafkaACLHandler) List(project, serviceName string) ([]*KafkaACL, error)

+ type KafkaACLResponse struct

+ ACL []*KafkaACL

+ type PostgresParams struct

+ DatabaseName string

+ Host string

+ Password string

+ Port string

+ SSLMode string

+ User string

type Project

+ BillingEmails []*ContactEmail

+ BillingExtraText string

+ TechnicalEmails []*ContactEmail

+ type ProjectCAResponse struct

+ CACertificate string

+ type ProjectInvitation struct

+ InviteTime string

+ InvitingUserEmail string

+ MemberType string

+ UserEmail string

+ type ProjectInvitationsAndUsersListResponse struct

+ ProjectInvitations []*ProjectInvitation

+ ProjectUsers []*ProjectUser

+ type ProjectUser struct

+ AuthMethods []string

+ BillingContact bool

+ CreateTime string

+ Email string

+ MemberType string

+ RealName string

+ type ProjectUsersHandler struct

+ func (h *ProjectUsersHandler) DeleteInvitation(project, email string) error

+ func (h *ProjectUsersHandler) DeleteUser(project, email string) error

+ func (h *ProjectUsersHandler) DeleteUserOrInvitation(project, email string) error

+ func (h *ProjectUsersHandler) Get(project, email string) (*ProjectUser, *ProjectInvitation, error)

+ func (h *ProjectUsersHandler) Invite(project string, req CreateProjectInvitationRequest) error

+ func (h *ProjectUsersHandler) List(project string) ([]*ProjectUser, []*ProjectInvitation, error)

+ func (h *ProjectUsersHandler) UpdateInvitation(project string, email string, req UpdateProjectUserOrInvitationRequest) error

+ func (h *ProjectUsersHandler) UpdateUser(project string, email string, req UpdateProjectUserOrInvitationRequest) error

+ func (h *ProjectUsersHandler) UpdateUserOrInvitation(project string, email string, req UpdateProjectUserOrInvitationRequest) error

type Service

+ ACL []*KafkaACL

+ Backups []*Backup

+ ConnectionInfo ConnectionInfo

+ ConnectionPools []*ConnectionPool

+ ProjectVPCID *string

+ URIParams map[string]string

+ UserConfig map[string]interface{}

+ type ServiceIntegration struct

+ Active bool

+ Description string

+ DestinationEndpointID *string

+ DestinationEndpointName *string

+ DestinationProject *string

+ DestinationService *string

+ DestinationServiceType *string

+ Enabled bool

+ IntegrationStatus map[string]interface{}

+ IntegrationType string

+ ServiceIntegrationID string

+ SourceEndpointID *string

+ SourceEndpointName *string

+ SourceProject *string

+ SourceService *string

+ SourceServiceType *string

+ UserConfig map[string]interface{}

+ type ServiceIntegrationEndpoint struct

+ EndpointID string

+ EndpointName string

+ EndpointType string

+ UserConfig map[string]interface{}

+ type ServiceIntegrationEndpointListResponse struct

+ ServiceIntegrationEndpoints []*ServiceIntegrationEndpoint

+ type ServiceIntegrationEndpointResponse struct

+ ServiceIntegrationEndpoint *ServiceIntegrationEndpoint

+ type ServiceIntegrationEndpointsHandler struct

+ func (h *ServiceIntegrationEndpointsHandler) Create(project string, req CreateServiceIntegrationEndpointRequest) (*ServiceIntegrationEndpoint, error)

+ func (h *ServiceIntegrationEndpointsHandler) Delete(project, endpointID string) error

+ func (h *ServiceIntegrationEndpointsHandler) Get(project, endpointID string) (*ServiceIntegrationEndpoint, error)

+ func (h *ServiceIntegrationEndpointsHandler) List(project string) ([]*ServiceIntegrationEndpoint, error)

+ func (h *ServiceIntegrationEndpointsHandler) Update(project string, endpointID string, req UpdateServiceIntegrationEndpointRequest) (*ServiceIntegrationEndpoint, error)

+ type ServiceIntegrationListResponse struct

+ ServiceIntegrations []*ServiceIntegration

+ type ServiceIntegrationResponse struct

+ ServiceIntegration *ServiceIntegration

+ type ServiceIntegrationsHandler struct

+ func (h *ServiceIntegrationsHandler) Create(project string, req CreateServiceIntegrationRequest) (*ServiceIntegration, error)

+ func (h *ServiceIntegrationsHandler) Delete(project, integrationID string) error

+ func (h *ServiceIntegrationsHandler) Get(project, integrationID string) (*ServiceIntegration, error)

+ func (h *ServiceIntegrationsHandler) List(project, service string) ([]*ServiceIntegration, error)

+ func (h *ServiceIntegrationsHandler) Update(project string, integrationID string, req UpdateServiceIntegrationRequest) (*ServiceIntegration, error)

type ServiceUsersHandler

+ func (h *ServiceUsersHandler) Get(project, serviceName, username string) (*ServiceUser, error)

+ func (h *ServiceUsersHandler) List(project, serviceName string) ([]*ServiceUser, error)

+ type UpdateConnectionPoolRequest struct

+ Database string

+ PoolMode string

+ PoolSize int

+ Username string

type UpdateKafkaTopicRequest

+ Replication *int

type UpdateProjectRequest

+ BillingEmails *[]*ContactEmail

+ BillingExtraText *string

+ CountryCode *string

+ TechnicalEmails *[]*ContactEmail

+ type UpdateProjectUserOrInvitationRequest struct

+ MemberType string

+ type UpdateServiceIntegrationEndpointRequest struct

+ UserConfig map[string]interface{}

+ type UpdateServiceIntegrationRequest struct

+ UserConfig map[string]interface{}

type UpdateServiceRequest

+ ProjectVPCID *string

+ UserConfig map[string]interface{}

+ type VPC struct

+ CloudName string

+ CreateTime *string

+ NetworkCIDR string

+ PeeringConnections []*VPCPeeringConnection

+ ProjectVPCID string

+ State string

+ UpdateTime string

+ type VPCListResponse struct

+ VPCs []*VPC

+ type VPCPeeringConnection struct

+ CreateTime *string

+ PeerCloudAccount string

+ PeerVPC string

+ State string

+ StateInfo interface{}

+ UpdateTime string

+ type VPCPeeringConnectionsHandler struct

+ func (h *VPCPeeringConnectionsHandler) Create(project string, vpcID string, req CreateVPCPeeringConnectionRequest) (*VPCPeeringConnection, error)

+ func (h *VPCPeeringConnectionsHandler) Delete(project, vpcID, peerCloudAccount, peerVPC string) error

+ func (h *VPCPeeringConnectionsHandler) Get(project string, vpcID string, peerCloudAccount string, peerVPC string) (*VPCPeeringConnection, error)

+ func (h *VPCPeeringConnectionsHandler) List(project, vpcID string) ([]*VPCPeeringConnection, error)

+ type VPCsHandler struct

+ func (h *VPCsHandler) Create(project string, req CreateVPCRequest) (*VPC, error)

+ func (h *VPCsHandler) Delete(project, vpcID string) error

+ func (h *VPCsHandler) Get(project, vpcID string) (*VPC, error)

+ func (h *VPCsHandler) List(project string) ([]*VPC, error)

v0

v0.0.2

Jun 12, 2018

Changes in this version

+ const APIURL

type Card

+ CardID string

type Client

+ APIKey string

+ KafkaTopics *KafkaTopicsHandler

+ func NewMFAUserClient(email, otp, password string) (*Client, error)

+ type ConsumerGroup struct

+ GroupName string

+ Offset int

+ type CreateKafkaTopicRequest struct

+ CleanupPolicy *string

+ MinimumInSyncReplicas *int

+ Partitions *int

+ Replication *int

+ RetentionBytes *int

+ RetentionHours *int

+ TopicName string

type CreateProjectRequest

+ CardID string

+ type KafkaListTopic struct

+ CleanupPolicy string

+ MinimumInSyncReplicas int

+ Partitions int

+ Replication int

+ RetentionBytes int

+ RetentionHours int

+ State string

+ TopicName string

+ type KafkaTopic struct

+ CleanupPolicy string

+ MinimumInSyncReplicas int

+ Partitions []*Partition

+ Replication int

+ RetentionBytes int

+ RetentionHours int

+ State string

+ TopicName string

+ type KafkaTopicResponse struct

+ Topic *KafkaTopic

+ type KafkaTopicsHandler struct

+ func (h *KafkaTopicsHandler) Create(project, service string, req CreateKafkaTopicRequest) error

+ func (h *KafkaTopicsHandler) Delete(project, service, topic string) error

+ func (h *KafkaTopicsHandler) Get(project, service, topic string) (*KafkaTopic, error)

+ func (h *KafkaTopicsHandler) List(project, service string) ([]*KafkaListTopic, error)

+ func (h *KafkaTopicsHandler) Update(project, service, topic string, req UpdateKafkaTopicRequest) error

+ type KafkaTopicsResponse struct

+ Topics []*KafkaListTopic

+ type Partition struct

+ ConsumerGroups []*ConsumerGroup

+ EarliestOffset int

+ ISR int

+ LatestOffset int

+ Partition int

+ Size int

type Project

+ VatID string

type Service

+ URI string

type ServiceUser

+ AccessCert string

+ AccessKey string

type Token

+ func MFAUserToken(email, otp, password string, client *http.Client) (*Token, error)

+ type UpdateKafkaTopicRequest struct

+ MinimumInSyncReplicas *int

+ Partitions *int

+ RetentionBytes *int

+ RetentionHours *int

type UpdateProjectRequest

+ CardID string

v0.0.1

Mar 17, 2017

Changes in this version

+ const APIUrl

+ var ErrInvalidHost = errors.New("Host doesn't isn't in the correct format: `hostname:port`")

+ var ErrNoResponseData = errors.New("No response data available")

+ type APIResponse struct

+ Errors []Error

+ Message string

+ type Backup struct

+ type BillingHandler struct

+ Cards *CardsHandler

+ type Card struct

+ Brand string

+ CardId string

+ Country string

+ CountryCode string

+ ExpMonth int

+ ExpYear int

+ Last4 string

+ Name string

+ ProjectNames []string

+ type CardListResponse struct

+ Cards []*Card

+ type CardsHandler struct

+ func (h *CardsHandler) List() ([]*Card, error)

+ type Client struct

+ ApiKey string

+ Billing *BillingHandler

+ Client *http.Client

+ Databases *DatabasesHandler

+ Projects *ProjectsHandler

+ ServiceUsers *ServiceUsersHandler

+ Services *ServicesHandler

+ func NewTokenClient(key string) (*Client, error)

+ func NewUserClient(email, password string) (*Client, error)

+ func (c *Client) Init()

+ type ConnectionPool struct

+ type CreateDatabaseRequest struct

+ Database string

+ LcCollate string

+ LcType string

+ type CreateProjectRequest struct

+ CardId string

+ Cloud string

+ Project string

+ type CreateServiceRequest struct

+ Cloud string

+ GroupName string

+ Plan string

+ ServiceName string

+ ServiceType string

+ type CreateServiceUserRequest struct

+ Username string

+ type Database struct

+ Database string

+ LcCollate string

+ LcType string

+ type DatabasesHandler struct

+ func (h *DatabasesHandler) Create(project, service string, req CreateDatabaseRequest) (*Database, error)

+ func (h *DatabasesHandler) Delete(project, service, database string) error

+ type Error struct

+ Message string

+ MoreInfo string

+ Status int

+ func (e Error) Error() string

+ type Project struct

+ AvailableCredits string

+ BillingAddress string

+ Card Card

+ Country string

+ CountryCode string

+ DefaultCloud string

+ EstimatedBalance string

+ Name string

+ PaymentMethod string

+ VatId string

+ type ProjectListResponse struct

+ Projects []*Project

+ type ProjectResponse struct

+ Project *Project

+ type ProjectsHandler struct

+ func (h *ProjectsHandler) Create(req CreateProjectRequest) (*Project, error)

+ func (h *ProjectsHandler) Delete(project string) error

+ func (h *ProjectsHandler) Get(project string) (*Project, error)

+ func (h *ProjectsHandler) List() ([]*Project, error)

+ func (h *ProjectsHandler) Update(project string, req UpdateProjectRequest) (*Project, error)

+ type Service struct

+ CloudName string

+ CreateTime string

+ GroupList []string

+ Metadata interface{}

+ Name string

+ NodeCount int

+ Plan string

+ State string

+ Type string

+ UpdateTime string

+ Uri string

+ Users []*ServiceUser

+ func (s *Service) Hostname() (string, error)

+ func (s *Service) Port() (string, error)

+ type ServiceListResponse struct

+ Services []*Service

+ type ServiceResponse struct

+ Service *Service

+ type ServiceUser struct

+ Password string

+ Type string

+ Username string

+ type ServiceUserResponse struct

+ User *ServiceUser

+ type ServiceUsersHandler struct

+ func (h *ServiceUsersHandler) Create(project, service string, req CreateServiceUserRequest) (*ServiceUser, error)

+ func (h *ServiceUsersHandler) Delete(project, service, user string) error

+ type ServicesHandler struct

+ func (h *ServicesHandler) Create(project string, req CreateServiceRequest) (*Service, error)

+ func (h *ServicesHandler) Delete(project, service string) error

+ func (h *ServicesHandler) Get(project, service string) (*Service, error)

+ func (h *ServicesHandler) List(project string) ([]*Service, error)

+ func (h *ServicesHandler) Update(project, service string, req UpdateServiceRequest) (*Service, error)

+ type Token struct

+ State string

+ Token string

+ func UserToken(email, password string, client *http.Client) (*Token, error)

+ type UpdateProjectRequest struct

+ BillingAddress string

+ CardId string

+ Cloud string

+ type UpdateServiceRequest struct

+ Cloud string

+ GroupName string

+ Plan string

+ Powered bool

+ type User struct

+ Password string

+ Type string

+ Username string

Other modules containing this package

github.com/aiven/aiven-go-client/v2

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL