aiven

package module

Go to main page

Versions in this module

v2

v2.21.0

May 13, 2024

v2.20.0

May 8, 2024

Changes in this version

+ type OrganizationCreateRequest struct

+ Name string

+ PrimaryBillingGroupID *string

+ Tier OrganizationTier

type OrganizationHandler

+ func (h *OrganizationHandler) Create(ctx context.Context, req OrganizationCreateRequest) (*OrganizationInfo, error)

+ func (h *OrganizationHandler) Update(ctx context.Context, id string, req OrganizationUpdateRequest) (*OrganizationInfo, error)

type OrganizationInfo

+ DefaultGovernanceUserGroupID *string

+ Tier OrganizationTier

+ type OrganizationTier string

+ const OrganizationTierBusiness

+ const OrganizationTierPersonal

+ type OrganizationUpdateRequest struct

+ DefaultGovernanceUserGroupID *string

+ KafkaGovernanceEnabled *bool

+ Name *string

+ Tier *OrganizationTier

v2.19.0

May 7, 2024

v2.18.0

Apr 25, 2024

Changes in this version

type ConnectionInfo

+ QueryFrontendURI string

+ QueryURI string

+ ReceiverIngestingRemoteWriteURI string

+ ReceiverRemoteWriteURI string

+ StoreURI string

v2.17.0

Apr 22, 2024

v2.16.0

Apr 10, 2024

v2.15.0

Mar 28, 2024

v2.14.0

Mar 15, 2024

v2.13.0

Mar 14, 2024

v2.12.0

Jan 22, 2024

Changes in this version

type ProjectEvent

+ ID string

v2.11.0

Jan 11, 2024

v2.10.0

Jan 10, 2024

v2.9.0

Jan 6, 2024

Changes in this version

+ type ApplicationUserCreateRequest struct

+ Name string

+ type ApplicationUserCreateResponse struct

+ type ApplicationUserInfo struct

+ Name string

+ UserEmail string

+ UserID string

+ type ApplicationUserListResponse struct

+ Users []ApplicationUserInfo

+ type ApplicationUserTokenCreateRequest struct

+ Description string

+ ExtendWhenUsed bool

+ MaxAgeSeconds int

+ Scopes []string

+ type ApplicationUserTokenCreateResponse struct

+ FullToken string

+ TokenPrefix string

+ type ApplicationUserTokenInfo struct

+ CreateTime *time.Time

+ CreatedManually bool

+ CurrentlyActive bool

+ Description string

+ ExpiryTime *time.Time

+ ExtendWhenUsed bool

+ LastIP string

+ LastUsedTime *time.Time

+ LastUserAgent string

+ LastUserAgentHumanReadable string

+ MaxAgeSeconds int

+ Scopes []string

+ TokenPrefix string

+ type ApplicationUserTokenList struct

+ Tokens []ApplicationUserTokenInfo

+ type ApplicationUserTokenListResponse struct

type Client

+ OrganizationApplicationUserHandler *OrganizationApplicationUserHandler

+ type OrganizationApplicationUserHandler struct

+ func (h *OrganizationApplicationUserHandler) Create(ctx context.Context, orgID string, req ApplicationUserCreateRequest) (*ApplicationUserCreateResponse, error)

+ func (h *OrganizationApplicationUserHandler) CreateToken(ctx context.Context, orgID string, userID string, ...) (*ApplicationUserTokenCreateResponse, error)

+ func (h *OrganizationApplicationUserHandler) Delete(ctx context.Context, orgID string, userID string) error

+ func (h *OrganizationApplicationUserHandler) DeleteToken(ctx context.Context, orgID string, userID string, tokenPrefix string) error

+ func (h *OrganizationApplicationUserHandler) List(ctx context.Context, orgID string) (*ApplicationUserListResponse, error)

+ func (h *OrganizationApplicationUserHandler) ListTokens(ctx context.Context, orgID string, userID string) (*ApplicationUserTokenListResponse, error)

type OrganizationUserHandler

+ func (h *OrganizationUserHandler) Update(ctx context.Context, id string, userID string, ...) (*OrganizationMemberInfo, error)

+ type OrganizationUserUpdateRequest struct

+ City *string

+ Country *string

+ Department *string

+ IsSuperAdmin *bool

+ JobTitle *string

+ RealName *string

v2.8.0

Jan 5, 2024

v2.7.0

Jan 2, 2024

Changes in this version

type KafkaTopicConfig

+ LocalRetentionBytes *int64

+ LocalRetentionMs *int64

+ RemoteStorageEnable *bool

type KafkaTopicConfigResponse

+ LocalRetentionBytes KafkaTopicConfigResponseInt

+ LocalRetentionMs KafkaTopicConfigResponseInt

+ RemoteStorageEnable KafkaTopicConfigResponseBool

v2.6.0

Dec 28, 2023

Changes in this version

type Client

+ ProjectOrganization *ProjectOrgHandler

type Project

+ OrganizationId string

+ type ProjectOrgHandler struct

+ func (h *ProjectOrgHandler) Add(ctx context.Context, project, userGroupID, role string) error

+ func (h *ProjectOrgHandler) Delete(ctx context.Context, project, userGroupID string) error

+ func (h *ProjectOrgHandler) List(ctx context.Context, project string) ([]*ProjectUserGroup, error)

+ func (h *ProjectOrgHandler) OrganizationProjects(ctx context.Context, organizationID string) ([]*Project, error)

+ type ProjectUserGroup struct

+ CreateTime string

+ OrganizationGroupID string

+ Role string

+ UpdateTime string

+ type ProjectUserGroupListResponse struct

+ AccessList []*ProjectUserGroup

+ type ProjectUserGroupRequest struct

+ Role string

v2.5.0

Dec 21, 2023

Changes in this version

type CreateServiceRequest

+ TechnicalEmails *[]ContactEmail

type Service

+ TechnicalEmails []ContactEmail

type UpdateServiceRequest

+ TechnicalEmails *[]ContactEmail

v2.4.0

Nov 15, 2023

v2.3.0

Nov 15, 2023

Changes in this version

type ReplicationFlow

+ EmitBackwardHeartbeatsEnabled bool

v2.2.0

Oct 18, 2023

Changes in this version

type Client

+ OpenSearchACLs *OpenSearchACLsHandler

+ type OpenSearchACL struct

+ Rules []OpenSearchACLRule

+ Username string

+ type OpenSearchACLConfig struct

+ ACLs []OpenSearchACL

+ Enabled bool

+ ExtendedAcl bool

+ func (conf *OpenSearchACLConfig) Add(acl OpenSearchACL) *OpenSearchACLConfig

+ func (conf *OpenSearchACLConfig) Delete(ctx context.Context, acl OpenSearchACL) *OpenSearchACLConfig

+ type OpenSearchACLRequest struct

+ OpenSearchACLConfig OpenSearchACLConfig

+ type OpenSearchACLResponse struct

+ OpenSearchACLConfig OpenSearchACLConfig

+ type OpenSearchACLRule struct

+ Index string

+ Permission string

+ type OpenSearchACLsHandler struct

+ func (h *OpenSearchACLsHandler) Get(ctx context.Context, project, service string) (*OpenSearchACLResponse, error)

+ func (h *OpenSearchACLsHandler) Update(ctx context.Context, project, service string, req OpenSearchACLRequest) (*OpenSearchACLResponse, error)

v2.1.0

Sep 28, 2023

v2.0.0

Sep 14, 2023

Changes in this version

+ const OrganizationGroupMemberAdd

+ const OrganizationGroupMemberRemove

+ const UpdateOperationResetCredentials

+ const UpdateOperationSetAccessControl

+ var ErrInvalidHost = errors.New("host wasn't specified in the correct format: `hostname:port`")

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

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

+ func GetUserAgentOrDefault(userAgent string) string

+ func IsAlreadyExists(err error) bool

+ func IsNotFound(err error) bool

+ func PointerToString(s *string) string

+ func ToStringPointer(s string) *string

+ func Version() string

+ type APIResponse struct

+ Errors []Error

+ Message string

+ func (r APIResponse) GetError() error

+ type AWSPrivatelinkHandler struct

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

+ func (h *AWSPrivatelinkHandler) Delete(ctx context.Context, project, serviceName string) error

+ func (h *AWSPrivatelinkHandler) Get(ctx context.Context, project, serviceName string) (*AWSPrivatelinkResponse, error)

+ func (h *AWSPrivatelinkHandler) Update(ctx context.Context, 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 struct

+ M3Group *string

+ PostgresAllowReplication *bool

+ RedisACLCategories []string

+ RedisACLChannels []string

+ RedisACLCommands []string

+ RedisACLKeys []string

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

+ type Account struct

+ BillingEnabled bool

+ CreateTime *time.Time

+ Id string

+ IsAccountOwner bool

+ Name string

+ OrganizationId string

+ OwnerTeamId string

+ ParentAccountId string

+ PrimaryBillingGroupId string

+ TenantId string

+ UpdateTime *time.Time

+ type AccountAuthenticationListResponse struct

+ AuthenticationMethods []AccountAuthenticationMethod

+ type AccountAuthenticationMethod struct

+ AccountID string

+ AuthenticationMethodEnabled bool

+ AuthenticationMethodID string

+ AuthenticationMethodName string

+ AuthenticationMethodType string

+ AutoJoinTeamID string

+ CreateTime *time.Time

+ DeleteTime *time.Time

+ SAMLAcsURL string

+ SAMLCertificate string

+ SAMLCertificateIssuer string

+ SAMLCertificateNotValidAfter string

+ SAMLCertificateNotValidBefore string

+ SAMLCertificateSubject string

+ SAMLDigestAlgorithm string

+ SAMLEntityID string

+ SAMLFieldMapping *SAMLFieldMapping

+ SAMLIdpLoginAllowed bool

+ SAMLIdpURL string

+ SAMLMetadataURL string

+ SAMLSignatureAlgorithm string

+ SAMLVariant string

+ State string

+ UpdateTime *time.Time

+ 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 AccountAuthenticationResponse struct

+ AuthenticationMethod AccountAuthenticationMethod

+ type AccountAuthenticationsHandler struct

+ func (h AccountAuthenticationsHandler) Create(ctx context.Context, accountId string, a AccountAuthenticationMethodCreate) (*AccountAuthenticationResponse, error)

+ func (h AccountAuthenticationsHandler) Delete(ctx context.Context, accountId, authId string) error

+ func (h AccountAuthenticationsHandler) Get(ctx context.Context, accountId, authId string) (*AccountAuthenticationResponse, error)

+ func (h AccountAuthenticationsHandler) List(ctx context.Context, accountId string) (*AccountAuthenticationListResponse, error)

+ func (h AccountAuthenticationsHandler) Update(ctx context.Context, accountId, accountAuthMethID string, ...) (*AccountAuthenticationResponse, error)

+ 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) Delete(ctx context.Context, accountId, teamId, userEmail string) error

+ func (h AccountTeamInvitesHandler) List(ctx context.Context, 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(ctx context.Context, accountId, teamId, userId string) error

+ func (h AccountTeamMembersHandler) Invite(ctx context.Context, accountId, teamId, email string) error

+ func (h AccountTeamMembersHandler) List(ctx context.Context, accountId, teamId string) (*AccountTeamMembersResponse, error)

+ type AccountTeamMembersResponse struct

+ Members []AccountTeamMember

+ type AccountTeamProject struct

+ ProjectName string

+ TeamType string

+ type AccountTeamProjectsHandler struct

+ func (h AccountTeamProjectsHandler) Create(ctx context.Context, accountId, teamId string, p AccountTeamProject) error

+ func (h AccountTeamProjectsHandler) Delete(ctx context.Context, accountId, teamId, projectName string) error

+ func (h AccountTeamProjectsHandler) List(ctx context.Context, accountId, teamId string) (*AccountTeamProjectsResponse, error)

+ func (h AccountTeamProjectsHandler) Update(ctx context.Context, accountId, teamId string, p AccountTeamProject) error

+ type AccountTeamProjectsResponse struct

+ Projects []AccountTeamProject

+ type AccountTeamResponse struct

+ Team AccountTeam

+ type AccountTeamsHandler struct

+ func (h AccountTeamsHandler) Create(ctx context.Context, accountId string, team AccountTeam) (*AccountTeamResponse, error)

+ func (h AccountTeamsHandler) Delete(ctx context.Context, accountId, teamId string) error

+ func (h AccountTeamsHandler) Get(ctx context.Context, accountId, teamId string) (*AccountTeamResponse, error)

+ func (h AccountTeamsHandler) List(ctx context.Context, accountId string) (*AccountTeamsResponse, error)

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

+ type AccountTeamsResponse struct

+ Teams []AccountTeam

+ type AccountsHandler struct

+ func (h AccountsHandler) Create(ctx context.Context, account Account) (*AccountResponse, error)

+ func (h AccountsHandler) Delete(ctx context.Context, id string) error

+ func (h AccountsHandler) Get(ctx context.Context, id string) (*AccountResponse, error)

+ func (h AccountsHandler) List(ctx context.Context) (*AccountsResponse, error)

+ func (h AccountsHandler) Update(ctx context.Context, id string, account Account) (*AccountResponse, error)

+ type AccountsResponse struct

+ Accounts []Account

+ 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 struct

+ func (h *AzurePrivatelinkHandler) ConnectionApprove(ctx context.Context, project, serviceName, privatelinkConnectionId string) error

+ func (h *AzurePrivatelinkHandler) ConnectionGet(ctx context.Context, project, serviceName string, connID *string) (*AzurePrivatelinkConnectionResponse, error)

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

+ func (h *AzurePrivatelinkHandler) ConnectionsList(ctx context.Context, project, serviceName string) (*AzurePrivatelinkConnectionsResponse, error)

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

+ func (h *AzurePrivatelinkHandler) Delete(ctx context.Context, project, serviceName string) error

+ func (h *AzurePrivatelinkHandler) Get(ctx context.Context, project, serviceName string) (*AzurePrivatelinkResponse, error)

+ func (h *AzurePrivatelinkHandler) Refresh(ctx context.Context, project, serviceName string) error

+ func (h *AzurePrivatelinkHandler) Update(ctx context.Context, 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 Backup struct

+ AdditionalRegions []*BackupAdditionalRegion

+ BackupName string

+ BackupTime *time.Time

+ DataSize int

+ 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 BillingGroup struct

+ Id string

+ type BillingGroupHandler struct

+ func (h *BillingGroupHandler) AssignProjects(ctx context.Context, id string, projects []string) error

+ func (h *BillingGroupHandler) Create(ctx context.Context, req BillingGroupRequest) (*BillingGroup, error)

+ func (h *BillingGroupHandler) Delete(ctx context.Context, id string) error

+ func (h *BillingGroupHandler) Get(ctx context.Context, id string) (*BillingGroup, error)

+ func (h *BillingGroupHandler) GetInvoice(ctx context.Context, id, invoiceNumber string) (*BillingGroupInvoiceResponse, error)

+ func (h *BillingGroupHandler) GetProjects(ctx context.Context, id string) ([]string, error)

+ func (h *BillingGroupHandler) ListAll(ctx context.Context) ([]BillingGroup, error)

+ func (h *BillingGroupHandler) ListInvoices(ctx context.Context, id string) (*BillingGroupListInvoicesResponse, error)

+ func (h *BillingGroupHandler) ListLines(ctx context.Context, id, invoiceNumber string) (*BillingGroupListInvoiceLinesResponse, error)

+ func (h *BillingGroupHandler) Update(ctx context.Context, id string, req BillingGroupRequest) (*BillingGroup, 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

+ 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

+ CopyFromBillingGroup *string

+ CountryCode *string

+ State *string

+ VatId *string

+ ZipCode *string

+ type BillingGroupResponse struct

+ BillingGroup *BillingGroup

+ type CAHandler struct

+ func (h *CAHandler) Get(ctx context.Context, project string) (string, error)

+ type CancelFlinkApplicationDeploymentResponse struct

+ type CancelJobFlinkApplicationQueryResponse struct

+ Canceled bool

+ Details string

+ 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) Get(ctx context.Context, cardID string) (*Card, error)

+ func (h *CardsHandler) List(ctx context.Context) ([]*Card, error)

+ type ClickhouseCurrentQueriesResponse struct

+ Queries []ClickhouseCurrentQuery

+ type ClickhouseCurrentQuery struct

+ ClientName string

+ Database string

+ Elapsed float64

+ Query string

+ User string

+ type ClickhouseDatabase struct

+ Engine string

+ Name string

+ Required bool

+ type ClickhouseDatabaseHandler struct

+ func (h *ClickhouseDatabaseHandler) Create(ctx context.Context, project, service, database string) error

+ func (h *ClickhouseDatabaseHandler) Delete(ctx context.Context, project, service, database string) error

+ func (h *ClickhouseDatabaseHandler) Get(ctx context.Context, project, service, database string) (*ClickhouseDatabase, error)

+ func (h *ClickhouseDatabaseHandler) List(ctx context.Context, project, service string) (*ListClickhouseDatabaseResponse, error)

+ type ClickhouseDatabaseRequest struct

+ Database string

+ type ClickhouseQueryColumnMeta struct

+ Name string

+ Type string

+ type ClickhouseQueryHandler struct

+ func (h *ClickhouseQueryHandler) CurrentQueries(ctx context.Context, project, service string) (*ClickhouseCurrentQueriesResponse, error)

+ func (h *ClickhouseQueryHandler) Query(ctx context.Context, 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(ctx context.Context, project, service, name string) (*ClickhouseUserResponse, error)

+ func (h *ClickhouseUserHandler) Delete(ctx context.Context, project, service, uuid string) error

+ func (h *ClickhouseUserHandler) Get(ctx context.Context, project, service, uuid string) (*ClickhouseUser, error)

+ func (h *ClickhouseUserHandler) List(ctx context.Context, project, service string) (*ListClickhouseUserResponse, error)

+ func (h *ClickhouseUserHandler) ResetPassword(ctx context.Context, 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 struct

+ APIKey string

+ AWSPrivatelink *AWSPrivatelinkHandler

+ AccountAuthentications *AccountAuthenticationsHandler

+ AccountTeamInvites *AccountTeamInvitesHandler

+ AccountTeamMembers *AccountTeamMembersHandler

+ AccountTeamProjects *AccountTeamProjectsHandler

+ AccountTeams *AccountTeamsHandler

+ Accounts *AccountsHandler

+ AzurePrivatelink *AzurePrivatelinkHandler

+ BillingGroup *BillingGroupHandler

+ CA *CAHandler

+ CardsHandler *CardsHandler

+ ClickHouseQuery *ClickhouseQueryHandler

+ ClickhouseDatabase *ClickhouseDatabaseHandler

+ ClickhouseUser *ClickhouseUserHandler

+ Client *http.Client

+ ConnectionPools *ConnectionPoolsHandler

+ Databases *DatabasesHandler

+ ElasticsearchACLs *ElasticSearchACLsHandler

+ FlinkApplicationDeployments *FlinkApplicationDeploymentHandler

+ FlinkApplicationQueries *FlinkApplicationQueryHandler

+ FlinkApplicationVersions *FlinkApplicationVersionHandler

+ FlinkApplications *FlinkApplicationHandler

+ FlinkJobs *FlinkJobHandler

+ GCPPrivatelink *GCPPrivatelinkHandler

+ KafkaACLs *KafkaACLHandler

+ KafkaConnectors *KafkaConnectorsHandler

+ KafkaGlobalSchemaConfig *KafkaGlobalSchemaConfigHandler

+ KafkaMirrorMakerReplicationFlow *MirrorMakerReplicationFlowHandler

+ KafkaSchemaRegistryACLs *KafkaSchemaRegistryACLHandler

+ KafkaSubjectSchemas *KafkaSubjectSchemasHandler

+ KafkaTopics *KafkaTopicsHandler

+ OpenSearchSecurityPluginHandler *OpenSearchSecurityPluginHandler

+ Organization *OrganizationHandler

+ OrganizationUser *OrganizationUserHandler

+ OrganizationUserGroupMembers *OrganizationUserGroupMembersHandler

+ OrganizationUserGroups *OrganizationUserGroupHandler

+ OrganizationUserInvitations *OrganizationUserInvitationsHandler

+ ProjectUsers *ProjectUsersHandler

+ Projects *ProjectsHandler

+ ServiceIntegrationEndpoints *ServiceIntegrationEndpointsHandler

+ ServiceIntegrations *ServiceIntegrationsHandler

+ ServiceTags *ServiceTagsHandler

+ ServiceTask *ServiceTaskHandler

+ ServiceTypes *ServiceTypesHandler

+ ServiceUsers *ServiceUsersHandler

+ Services *ServicesHandler

+ StaticIPs *StaticIPsHandler

+ TransitGatewayVPCAttachment *TransitGatewayVPCAttachmentHandler

+ UserAgent string

+ VPCPeeringConnections *VPCPeeringConnectionsHandler

+ VPCs *VPCsHandler

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

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

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

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

+ func (c *Client) Init()

+ type ConnectionInfo struct

+ CassandraHosts []string

+ ElasticsearchPassword string

+ ElasticsearchURIs []string

+ ElasticsearchUsername string

+ FlinkHostPorts []string

+ GrafanaURIs []string

+ InfluxDBDatabaseName string

+ InfluxDBPassword string

+ InfluxDBURIs []string

+ InfluxDBUsername string

+ KafkaAccessCert string

+ KafkaAccessKey string

+ KafkaConnectURI string

+ KafkaHosts []string

+ KafkaRestURI string

+ KibanaURI string

+ MySQLParams []MySQLParams

+ MySQLReplicaURI string

+ MySQLStandbyURIs []string

+ MySQLURIs []string

+ OpensearchDashboardsURI string

+ OpensearchPassword string

+ OpensearchURIs []string

+ OpensearchUsername string

+ PostgresParams []PostgresParams

+ PostgresReplicaURI string

+ PostgresStandbyURIs []string

+ PostgresURIs []string

+ RedisPassword string

+ RedisSlaveURIs []string

+ RedisURIs []string

+ SchemaRegistryURI string

+ type ConnectionPool struct

+ ConnectionURI string

+ Database string

+ PoolMode string

+ PoolName string

+ PoolSize int

+ Username string

+ type ConnectionPoolsHandler struct

+ func (h *ConnectionPoolsHandler) Create(ctx context.Context, project string, serviceName string, ...) (*ConnectionPool, error)

+ func (h *ConnectionPoolsHandler) Delete(ctx context.Context, project, serviceName, poolName string) error

+ func (h *ConnectionPoolsHandler) Get(ctx context.Context, project, serviceName, poolName string) (*ConnectionPool, error)

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

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

+ type ConsumerGroup struct

+ GroupName string

+ Offset int64

+ type ContactEmail struct

+ Email string

+ type CreateConnectionPoolRequest struct

+ Database string

+ PoolMode string

+ PoolName string

+ PoolSize int

+ Username *string

+ type CreateDatabaseRequest struct

+ Database string

+ LcCollate string

+ LcType string

+ 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 CreateFlinkApplicationRequest struct

+ ApplicationVersion *FlinkApplicationVersion

+ Name string

+ type CreateFlinkJobRequest struct

+ JobName string

+ Statement string

+ TablesIds []string

+ type CreateFlinkJobResponse struct

+ JobId string

+ JobName string

+ type CreateKafkaACLRequest struct

+ Permission string

+ Topic string

+ Username string

+ type CreateKafkaSchemaRegistryACLRequest struct

+ Permission string

+ Resource string

+ Username string

+ type CreateKafkaTopicRequest struct

+ CleanupPolicy *string

+ Config KafkaTopicConfig

+ MinimumInSyncReplicas *int

+ Partitions *int

+ Replication *int

+ RetentionBytes *int

+ RetentionHours *int

+ Tags []KafkaTopicTag

+ TopicName string

+ type CreateProjectInvitationRequest struct

+ MemberType string

+ UserEmail string

+ type CreateProjectRequest struct

+ AccountId *string

+ AddAccountOwnersAdminAccess *bool

+ BillingAddress *string

+ BillingCurrency string

+ BillingEmails *[]*ContactEmail

+ BillingExtraText *string

+ BillingGroupId string

+ CardID *string

+ Cloud *string

+ CopyFromProject string

+ CountryCode *string

+ Project string

+ Tags map[string]string

+ TechnicalEmails *[]*ContactEmail

+ UseSourceProjectBillingGroup bool

+ VatID *string

+ type CreateServiceIntegrationEndpointRequest struct

+ EndpointName string

+ EndpointType string

+ UserConfig map[string]interface{}

+ type CreateServiceIntegrationRequest struct

+ DestinationEndpointID *string

+ DestinationProject *string

+ DestinationService *string

+ IntegrationType string

+ SourceEndpointID *string

+ SourceProject *string

+ SourceService *string

+ UserConfig map[string]interface{}

+ type CreateServiceRequest struct

+ Cloud string

+ DiskSpaceMB int

+ GroupName string

+ MaintenanceWindow *MaintenanceWindow

+ Plan string

+ ProjectVPCID *string

+ ServiceIntegrations []NewServiceIntegration

+ ServiceName string

+ ServiceType string

+ StaticIPs []string

+ TerminationProtection bool

+ UserConfig map[string]interface{}

+ type CreateServiceUserRequest struct

+ AccessControl *AccessControl

+ Authentication *string

+ Username string

+ type CreateStaticIPRequest struct

+ CloudName string

+ type CreateStaticIPResponse struct

+ type CreateVPCPeeringConnectionRequest struct

+ PeerAzureAppId string

+ PeerAzureTenantId string

+ PeerCloudAccount string

+ PeerRegion *string

+ PeerResourceGroup string

+ PeerVPC string

+ UserPeerNetworkCIDRs []string

+ type CreateVPCRequest struct

+ CloudName string

+ NetworkCIDR string

+ PeeringConnections []*VPCPeeringConnection

+ type Database struct

+ DatabaseName string

+ LcCollate string

+ LcType string

+ type DatabaseListResponse struct

+ Databases []*Database

+ type DatabasesHandler struct

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

+ func (h *DatabasesHandler) Delete(ctx context.Context, project, service, database string) error

+ func (h *DatabasesHandler) Get(ctx context.Context, projectName, serviceName, databaseName string) (*Database, error)

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

+ type DeleteFlinkApplicationDeploymentResponse struct

+ type DeleteStaticIPRequest struct

+ StaticIPAddressID string

+ type DetailedFlinkApplicationResponse struct

+ ApplicationVersions []FlinkApplicationVersion

+ CurrentDeployment FlinkApplicationDeployment

+ type DetailedFlinkApplicationVersionResponse struct

+ CreatedAt string

+ CreatedBy string

+ ID string

+ Version int

+ 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(ctx context.Context, acl ElasticSearchACL) *ElasticSearchACLConfig

+ type ElasticSearchACLResponse struct

+ ElasticSearchACLConfig ElasticSearchACLConfig

+ type ElasticSearchACLsHandler struct

+ func (h *ElasticSearchACLsHandler) Get(ctx context.Context, project, service string) (*ElasticSearchACLResponse, error)

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

+ type ElasticsearchACLRequest struct

+ ElasticSearchACLConfig ElasticSearchACLConfig

+ type ElasticsearchACLRule struct

+ Index string

+ Permission string

+ type Error struct

+ Message string

+ MoreInfo string

+ Status int

+ func (e Error) Error() string

+ 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(ctx context.Context, project, service, applicationId, deploymentId string) (*CancelFlinkApplicationDeploymentResponse, error)

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

+ func (h *FlinkApplicationDeploymentHandler) Delete(ctx context.Context, project, service, applicationId, deploymentId string) (*DeleteFlinkApplicationDeploymentResponse, error)

+ func (h *FlinkApplicationDeploymentHandler) Get(ctx context.Context, project, service, applicationId, deploymentId string) (*GetFlinkApplicationDeploymentResponse, error)

+ func (h *FlinkApplicationDeploymentHandler) List(ctx context.Context, project, service, applicationId string) (*ListFlinkApplicationDeploymentResponse, error)

+ func (h *FlinkApplicationDeploymentHandler) Stop(ctx context.Context, project, service, applicationId, deploymentId string) (*StopFlinkApplicationDeploymentResponse, error)

+ type FlinkApplicationHandler struct

+ func (h *FlinkApplicationHandler) Create(ctx context.Context, project string, service string, ...) (*DetailedFlinkApplicationResponse, error)

+ func (h *FlinkApplicationHandler) Delete(ctx context.Context, project string, service string, applicationID string) (*DetailedFlinkApplicationResponse, error)

+ func (h *FlinkApplicationHandler) Get(ctx context.Context, project string, service string, applicationID string) (*DetailedFlinkApplicationResponse, error)

+ func (h *FlinkApplicationHandler) List(ctx context.Context, project string, service string) (*FlinkApplicationListResponse, error)

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

+ type FlinkApplicationListResponse struct

+ Applications []GenericFlinkApplicationResponse

+ type FlinkApplicationQueryHandler struct

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

+ func (h *FlinkApplicationQueryHandler) Create(ctx context.Context, project, service, applicationId string, ...) (*CreateFlinkApplicationQueryResponse, error)

+ func (h *FlinkApplicationQueryHandler) Delete(ctx context.Context, project, service, applicationId, queryId string) error

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

+ func (h *FlinkApplicationQueryHandler) List(ctx context.Context, project, service, applicationId string) (*ListFlinkApplicationQueryResponse, error)

+ type FlinkApplicationVersion struct

+ Sinks []FlinkApplicationVersionCreateInput

+ Sources []FlinkApplicationVersionCreateInput

+ Statement string

+ type FlinkApplicationVersionCreateInput struct

+ CreateTable string

+ IntegrationID string

+ type FlinkApplicationVersionHandler struct

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

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

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

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

+ type FlinkApplicationVersionRelation struct

+ CreateTable string

+ IntegrationID string

+ type FlinkJobHandler struct

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

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

+ func (h *FlinkJobHandler) List(ctx context.Context, project, service string) (*ListFlinkJobResponse, error)

+ func (h *FlinkJobHandler) Patch(ctx context.Context, project, service string, req PatchFlinkJobRequest) error

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

+ type GCPPrivatelinkConnectionApproveRequest struct

+ UserIPAddress string

+ type GCPPrivatelinkConnectionResponse struct

+ PSCConnectionID string

+ PrivatelinkConnectionID string

+ State string

+ UserIPAddress string

+ type GCPPrivatelinkConnectionsResponse struct

+ Connections []GCPPrivatelinkConnectionResponse

+ type GCPPrivatelinkHandler struct

+ func (h *GCPPrivatelinkHandler) ConnectionApprove(ctx context.Context, project, serviceName, connID string, ...) error

+ func (h *GCPPrivatelinkHandler) ConnectionGet(ctx context.Context, project, serviceName string, connID *string) (*GCPPrivatelinkConnectionResponse, error)

+ func (h *GCPPrivatelinkHandler) ConnectionsList(ctx context.Context, project, serviceName string) (*GCPPrivatelinkConnectionsResponse, error)

+ func (h *GCPPrivatelinkHandler) Create(ctx context.Context, project, serviceName string) (*GCPPrivatelinkResponse, error)

+ func (h *GCPPrivatelinkHandler) Delete(ctx context.Context, project, serviceName string) error

+ func (h *GCPPrivatelinkHandler) Get(ctx context.Context, project, serviceName string) (*GCPPrivatelinkResponse, error)

+ func (h *GCPPrivatelinkHandler) Refresh(ctx context.Context, project, serviceName string) error

+ func (h *GCPPrivatelinkHandler) Update(ctx context.Context, project, serviceName string) (*GCPPrivatelinkResponse, error)

+ type GCPPrivatelinkResponse struct

+ GoogleServiceAttachment string

+ State 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 GetFlinkApplicationDeploymentResponse struct

+ type GetFlinkApplicationQueryResponse struct

+ type GetFlinkJobRequest struct

+ JobId string

+ type GetFlinkJobResponse struct

+ Duration int

+ EndTime *time.Time

+ IsStoppable bool

+ JID string

+ MaxParallelism int

+ Name string

+ Now int

+ Plan struct{ ... }

+ StartTime *time.Time

+ State string

+ StatusCounts struct{ ... }

+ Timestamps struct{ ... }

+ Vertices []interface{}

+ 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 KafkaACL struct

+ ID string

+ Permission string

+ Topic string

+ Username string

+ type KafkaACLHandler struct

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

+ func (h *KafkaACLHandler) Delete(ctx context.Context, project, serviceName, aclID string) error

+ func (h *KafkaACLHandler) Get(ctx context.Context, project, serviceName, aclID string) (*KafkaACL, error)

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

+ type KafkaACLResponse struct

+ ACL []*KafkaACL

+ 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 KafkaConnectorStatus struct

+ State string

+ Tasks []KafkaConnectorTaskStatus

+ type KafkaConnectorStatusResponse struct

+ Status KafkaConnectorStatus

+ type KafkaConnectorTask struct

+ Connector string

+ Task int

+ type KafkaConnectorTaskStatus struct

+ Id int

+ State string

+ Trace string

+ type KafkaConnectorsHandler struct

+ func (h *KafkaConnectorsHandler) Create(ctx context.Context, project, service string, c KafkaConnectorConfig) error

+ func (h *KafkaConnectorsHandler) Delete(ctx context.Context, project, service, name string) error

+ func (h *KafkaConnectorsHandler) GetByName(ctx context.Context, project, service, name string) (*KafkaConnector, error)

+ func (h *KafkaConnectorsHandler) List(ctx context.Context, project, service string) (*KafkaConnectorsResponse, error)

+ func (h *KafkaConnectorsHandler) Status(ctx context.Context, project, service, name string) (*KafkaConnectorStatusResponse, error)

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

+ type KafkaConnectorsResponse struct

+ Connectors []KafkaConnector

+ type KafkaGlobalSchemaConfigHandler struct

+ func (h *KafkaGlobalSchemaConfigHandler) Get(ctx context.Context, project, service string) (*KafkaSchemaConfigResponse, error)

+ func (h *KafkaGlobalSchemaConfigHandler) Update(ctx context.Context, project, service string, c KafkaSchemaConfig) (*KafkaSchemaConfigUpdateResponse, error)

+ type KafkaListTopic struct

+ CleanupPolicy string

+ MinimumInSyncReplicas int

+ Partitions int

+ Replication int

+ RetentionBytes int

+ RetentionHours *int64

+ State string

+ TopicName string

+ type KafkaSchemaConfig struct

+ CompatibilityLevel string

+ type KafkaSchemaConfigResponse struct

+ CompatibilityLevel string

+ type KafkaSchemaConfigUpdateResponse struct

+ type KafkaSchemaRegistryACL struct

+ ID string

+ Permission string

+ Resource string

+ Username string

+ type KafkaSchemaRegistryACLHandler struct

+ func (h *KafkaSchemaRegistryACLHandler) Create(ctx context.Context, project, service string, ...) (*KafkaSchemaRegistryACL, error)

+ func (h *KafkaSchemaRegistryACLHandler) Delete(ctx context.Context, project, serviceName, aclID string) error

+ func (h *KafkaSchemaRegistryACLHandler) Get(ctx context.Context, project, serviceName, aclID string) (*KafkaSchemaRegistryACL, error)

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

+ type KafkaSchemaRegistryACLResponse struct

+ ACL []*KafkaSchemaRegistryACL

+ type KafkaSchemaSubject struct

+ Schema string

+ SchemaType string

+ type KafkaSchemaSubjectResponse struct

+ Id int

+ type KafkaSchemaSubjectVersion struct

+ Id int

+ Schema string

+ SchemaType string

+ Subject string

+ Version int

+ type KafkaSchemaSubjectVersionResponse struct

+ Version KafkaSchemaSubjectVersion

+ type KafkaSchemaSubjectVersions struct

+ Versions []int

+ type KafkaSchemaSubjectVersionsResponse struct

+ type KafkaSchemaSubjects struct

+ Subjects []string

+ type KafkaSchemaSubjectsResponse struct

+ type KafkaSchemaValidateResponse struct

+ IsCompatible bool

+ type KafkaSubjectSchemasHandler struct

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

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

+ func (h *KafkaSubjectSchemasHandler) Get(ctx context.Context, project, service, name string, version int) (*KafkaSchemaSubjectVersionResponse, error)

+ func (h *KafkaSubjectSchemasHandler) GetConfiguration(ctx context.Context, project, service, subjectName string) (*KafkaSchemaConfigResponse, error)

+ func (h *KafkaSubjectSchemasHandler) GetVersions(ctx context.Context, project, service, name string) (*KafkaSchemaSubjectVersionsResponse, error)

+ func (h *KafkaSubjectSchemasHandler) List(ctx context.Context, project, service string) (*KafkaSchemaSubjectsResponse, error)

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

+ func (h *KafkaSubjectSchemasHandler) Validate(ctx context.Context, project, service, name string, version int, ...) (bool, error)

+ type KafkaTopic struct

+ CleanupPolicy string

+ Config KafkaTopicConfigResponse

+ MinimumInSyncReplicas int

+ Partitions []*Partition

+ Replication int

+ RetentionBytes int

+ RetentionHours *int

+ State string

+ Tags []KafkaTopicTag

+ TopicName string

+ 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

+ Tags []KafkaTopicTag

+ 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 KafkaTopicResponse struct

+ Topic *KafkaTopic

+ type KafkaTopicTag struct

+ Key string

+ Value string

+ type KafkaTopicsHandler struct

+ func (h *KafkaTopicsHandler) Create(ctx context.Context, project, service string, req CreateKafkaTopicRequest) error

+ func (h *KafkaTopicsHandler) Delete(ctx context.Context, project, service, topic string) error

+ func (h *KafkaTopicsHandler) Get(ctx context.Context, project, service, topic string) (*KafkaTopic, error)

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

+ func (h *KafkaTopicsHandler) Update(ctx context.Context, project, service, topic string, ...) error

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

+ type KafkaTopicsResponse struct

+ Topics []*KafkaListTopic

+ type KafkaV2TopicsResponse struct

+ Topics []*KafkaTopic

+ type ListClickhouseDatabaseResponse struct

+ Databases []ClickhouseDatabase

+ type ListClickhouseUserResponse struct

+ Users []ClickhouseUser

+ type ListFlinkApplicationDeploymentResponse struct

+ Deployments []FlinkApplicationDeployment

+ type ListFlinkApplicationQueryResponse struct

+ Queries []flinkApplicationQueryBase

+ type ListFlinkJobResponse struct

+ Jobs []struct{ ... }

+ type ListStaticIPResponse struct

+ StaticIPs []StaticIP

+ type MaintenanceUpdate struct

+ Deadline *string

+ Description string

+ StartAfter string

+ StartAt *string

+ type MaintenanceWindow struct

+ DayOfWeek string

+ TimeOfDay string

+ Updates []*MaintenanceUpdate

+ type MirrorMakerReplicationFlowHandler struct

+ func (h *MirrorMakerReplicationFlowHandler) Create(ctx context.Context, project, service string, ...) error

+ func (h *MirrorMakerReplicationFlowHandler) Delete(ctx context.Context, project, service, sourceCluster, targetCluster string) error

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

+ func (h *MirrorMakerReplicationFlowHandler) List(ctx context.Context, project, service string) (*MirrorMakerReplicationFlowsResponse, error)

+ func (h *MirrorMakerReplicationFlowHandler) Update(ctx context.Context, project, service, sourceCluster, targetCluster string, ...) (*MirrorMakerReplicationFlowResponse, error)

+ type MirrorMakerReplicationFlowRequest struct

+ type MirrorMakerReplicationFlowResponse struct

+ ReplicationFlow ReplicationFlow

+ type MirrorMakerReplicationFlowsResponse struct

+ ReplicationFlows []ReplicationFlow

+ type ModifyServiceUserRequest struct

+ AccessControl *AccessControl

+ Authentication *string

+ NewPassword *string

+ Operation *string

+ type MySQLParams struct

+ DatabaseName string

+ Host string

+ Password string

+ Port string

+ SSLMode string

+ User string

+ type NewServiceIntegration struct

+ DestinationEndpointID *string

+ DestinationService *string

+ IntegrationType string

+ SourceEndpointID *string

+ SourceService *string

+ UserConfig map[string]interface{}

+ type NodeState struct

+ Name string

+ ProgressUpdates []ProgressUpdate

+ Role string

+ State string

+ type OpenSearchSecurityPluginConfigurationStatusResponse struct

+ SecurityPluginAdminEnabled bool

+ SecurityPluginAvailable bool

+ SecurityPluginEnabled bool

+ type OpenSearchSecurityPluginEnableRequest struct

+ AdminPassword string

+ type OpenSearchSecurityPluginHandler struct

+ func (h *OpenSearchSecurityPluginHandler) Enable(ctx context.Context, project string, service string, ...) (*OpenSearchSecurityPluginConfigurationStatusResponse, error)

+ func (h *OpenSearchSecurityPluginHandler) Get(ctx context.Context, project string, service string) (*OpenSearchSecurityPluginConfigurationStatusResponse, error)

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

+ type OpenSearchSecurityPluginUpdatePasswordRequest struct

+ AdminPassword string

+ NewPassword string

+ type OrganizationHandler struct

+ func (h *OrganizationHandler) Get(ctx context.Context, id string) (*OrganizationInfo, error)

+ type OrganizationInfo struct

+ AccountID string

+ CreateTime *time.Time

+ ID string

+ Name string

+ UpdateTime *time.Time

+ type OrganizationMemberInfo struct

+ JoinTime *time.Time

+ UserID string

+ UserInfo OrganizationUserInfo

+ type OrganizationUserGroupHandler struct

+ func (h *OrganizationUserGroupHandler) Create(ctx context.Context, orgID string, req OrganizationUserGroupRequest) (*OrganizationUserGroupResponse, error)

+ func (h *OrganizationUserGroupHandler) Delete(ctx context.Context, orgID, userGroupID string) error

+ func (h *OrganizationUserGroupHandler) Get(ctx context.Context, orgID, userGroupID string) (*OrganizationUserGroupResponse, error)

+ func (h *OrganizationUserGroupHandler) List(ctx context.Context, orgID string) (*OrganizationUserGroupListResponse, error)

+ func (h *OrganizationUserGroupHandler) Update(ctx context.Context, orgID, userGroupID string, ...) (*OrganizationUserGroupResponse, error)

+ type OrganizationUserGroupListResponse struct

+ UserGroups []OrganizationUserGroupResponse

+ type OrganizationUserGroupMember struct

+ LastActivityTime *time.Time

+ UserID string

+ UserInfo OrganizationUserGroupMemberUserInfo

+ type OrganizationUserGroupMemberRequest struct

+ MemberIDs []string

+ Operation string

+ type OrganizationUserGroupMemberUserInfo struct

+ City string

+ Country string

+ CreateTime *time.Time

+ Department string

+ JobTitle string

+ RealName string

+ State string

+ UserEmail string

+ type OrganizationUserGroupMembersHandler struct

+ func (h *OrganizationUserGroupMembersHandler) List(ctx context.Context, orgID, userGroupID string) (*OrganizationUserGroupMembersListResponse, error)

+ func (h *OrganizationUserGroupMembersHandler) Modify(ctx context.Context, orgID, userGroupID string, ...) error

+ type OrganizationUserGroupMembersListResponse struct

+ Members []OrganizationUserGroupMember

+ type OrganizationUserGroupRequest struct

+ Description string

+ UserGroupName string

+ type OrganizationUserGroupResponse struct

+ CreateTime *time.Time

+ Description string

+ UpdateTime *time.Time

+ UserGroupID string

+ UserGroupName string

+ type OrganizationUserHandler struct

+ func (h *OrganizationUserHandler) Delete(ctx context.Context, id, userID string) error

+ func (h *OrganizationUserHandler) Get(ctx context.Context, id, userID string) (*OrganizationMemberInfo, error)

+ func (h *OrganizationUserHandler) List(ctx context.Context, 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 *time.Time

+ ExpiryTime *time.Time

+ InvitedBy *string

+ UserEmail string

+ type OrganizationUserInvitationsHandler struct

+ func (h *OrganizationUserInvitationsHandler) Delete(ctx context.Context, id, userEmail string) error

+ func (h *OrganizationUserInvitationsHandler) Invite(ctx context.Context, id string, req OrganizationUserInvitationAddRequest) error

+ func (h *OrganizationUserInvitationsHandler) List(ctx context.Context, id string) (*OrganizationUserInvitationsList, error)

+ type OrganizationUserInvitationsList struct

+ Invitations []OrganizationUserInvitationInfo

+ type OrganizationUserList struct

+ Users []OrganizationMemberInfo

+ type Partition struct

+ ConsumerGroups []*ConsumerGroup

+ EarliestOffset int64

+ ISR int

+ LatestOffset int64

+ Partition int

+ Size int64

+ type PatchFlinkJobRequest struct

+ JobId string

+ type PostgresParams struct

+ DatabaseName string

+ Host string

+ Password string

+ Port string

+ SSLMode string

+ User string

+ type ProgressUpdate struct

+ Completed bool

+ Current int

+ Max int

+ Min int

+ Phase string

+ Unit string

+ type Project struct

+ AccountId string

+ AvailableCredits string

+ BillingAddress string

+ BillingCurrency string

+ BillingEmails []*ContactEmail

+ BillingExtraText string

+ BillingGroupId string

+ BillingGroupName string

+ Card Card

+ CopyFromProject string

+ Country string

+ CountryCode string

+ DefaultCloud string

+ EstimatedBalance string

+ Name string

+ PaymentMethod string

+ Tags map[string]string

+ TechnicalEmails []*ContactEmail

+ VatID string

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

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

+ type ProjectCAResponse struct

+ CACertificate string

+ type ProjectEvent struct

+ Actor string

+ EventDesc string

+ EventType string

+ ServiceName string

+ Time *time.Time

+ type ProjectEventLogEntriesResponse struct

+ Events []*ProjectEvent

+ type ProjectIntegrationEndpointTypesResponse struct

+ EndpointTypes []IntegrationEndpointType

+ type ProjectIntegrationTypesResponse struct

+ IntegrationTypes []IntegrationType

+ type ProjectInvitation struct

+ InviteTime *time.Time

+ InvitingUserEmail string

+ MemberType string

+ UserEmail string

+ type ProjectInvitationsAndUsersListResponse struct

+ ProjectInvitations []*ProjectInvitation

+ ProjectUsers []*ProjectUser

+ type ProjectListResponse struct

+ Projects []*Project

+ type ProjectResponse struct

+ Project *Project

+ type ProjectServiceTypesResponse struct

+ ServiceTypes map[string]ServiceType

+ type ProjectUser struct

+ AuthMethods []string

+ BillingContact bool

+ CreateTime *time.Time

+ Email string

+ MemberType string

+ RealName string

+ TeamId string

+ TeamName string

+ type ProjectUsersHandler struct

+ func (h *ProjectUsersHandler) DeleteInvitation(ctx context.Context, project, email string) error

+ func (h *ProjectUsersHandler) DeleteUser(ctx context.Context, project, email string) error

+ func (h *ProjectUsersHandler) DeleteUserOrInvitation(ctx context.Context, project, email string) error

+ func (h *ProjectUsersHandler) Get(ctx context.Context, project, email string) (*ProjectUser, *ProjectInvitation, error)

+ func (h *ProjectUsersHandler) Invite(ctx context.Context, project string, req CreateProjectInvitationRequest) error

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

+ func (h *ProjectUsersHandler) UpdateInvitation(ctx context.Context, project string, email string, ...) error

+ func (h *ProjectUsersHandler) UpdateUser(ctx context.Context, project string, email string, ...) error

+ func (h *ProjectUsersHandler) UpdateUserOrInvitation(ctx context.Context, project string, email string, ...) error

+ type ProjectsHandler struct

+ func (h *ProjectsHandler) Create(ctx context.Context, req CreateProjectRequest) (*Project, error)

+ func (h *ProjectsHandler) Delete(ctx context.Context, project string) error

+ func (h *ProjectsHandler) Get(ctx context.Context, project string) (*Project, error)

+ func (h *ProjectsHandler) GetEventLog(ctx context.Context, project string) ([]*ProjectEvent, error)

+ func (h *ProjectsHandler) IntegrationEndpointTypes(ctx context.Context, project string) ([]IntegrationEndpointType, error)

+ func (h *ProjectsHandler) IntegrationTypes(ctx context.Context, project string) ([]IntegrationType, error)

+ func (h *ProjectsHandler) List(ctx context.Context) ([]*Project, error)

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

+ func (h *ProjectsHandler) Update(ctx context.Context, project string, req UpdateProjectRequest) (*Project, error)

+ type ReplicationFlow struct

+ EmitHeartbeatsEnabled bool

+ Enabled bool

+ OffsetSyncsTopicLocation string

+ ReplicationPolicyClass string

+ SourceCluster string

+ SyncGroupOffsetsEnabled bool

+ SyncGroupOffsetsIntervalSeconds int

+ TargetCluster string

+ Topics []string

+ TopicsBlacklist []string

+ type Response interface

+ GetError func() error

+ type SAMLFieldMapping struct

+ Email string

+ FirstName string

+ Identity string

+ LastName string

+ RealName string

+ type Service struct

+ ACL []*KafkaACL

+ Backups []*Backup

+ CloudName string

+ Components []*ServiceComponents

+ ConnectionInfo ConnectionInfo

+ ConnectionPools []*ConnectionPool

+ CreateTime *time.Time

+ DiskSpaceMB int

+ Features ServiceFeatures

+ GroupList []string

+ Integrations []*ServiceIntegration

+ MaintenanceWindow MaintenanceWindow

+ Metadata interface{}

+ Name string

+ NodeCount int

+ NodeStates []*NodeState

+ Plan string

+ Powered bool

+ ProjectVPCID *string

+ SchemaRegistryACL []*KafkaSchemaRegistryACL

+ State string

+ TerminationProtection bool

+ Type string

+ URI string

+ URIParams map[string]string

+ UpdateTime *time.Time

+ UserConfig map[string]interface{}

+ Users []*ServiceUser

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

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

+ type ServiceComponents struct

+ Component string

+ Host string

+ KafkaAuthenticationMethod string

+ Port int

+ Route string

+ Ssl *bool

+ Usage string

+ 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 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

+ EndpointConfig map[string]interface{}

+ 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(ctx context.Context, project string, ...) (*ServiceIntegrationEndpoint, error)

+ func (h *ServiceIntegrationEndpointsHandler) Delete(ctx context.Context, project, endpointID string) error

+ func (h *ServiceIntegrationEndpointsHandler) Get(ctx context.Context, project, endpointID string) (*ServiceIntegrationEndpoint, error)

+ func (h *ServiceIntegrationEndpointsHandler) List(ctx context.Context, project string) ([]*ServiceIntegrationEndpoint, error)

+ func (h *ServiceIntegrationEndpointsHandler) Update(ctx context.Context, project string, endpointID string, ...) (*ServiceIntegrationEndpoint, error)

+ type ServiceIntegrationListResponse struct

+ ServiceIntegrations []*ServiceIntegration

+ type ServiceIntegrationResponse struct

+ ServiceIntegration *ServiceIntegration

+ type ServiceIntegrationsHandler struct

+ func (h *ServiceIntegrationsHandler) Create(ctx context.Context, project string, req CreateServiceIntegrationRequest) (*ServiceIntegration, error)

+ func (h *ServiceIntegrationsHandler) Delete(ctx context.Context, project, integrationID string) error

+ func (h *ServiceIntegrationsHandler) Get(ctx context.Context, project, integrationID string) (*ServiceIntegration, error)

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

+ func (h *ServiceIntegrationsHandler) Update(ctx context.Context, project string, integrationID string, ...) (*ServiceIntegration, error)

+ type ServiceListResponse struct

+ Services []*Service

+ type ServicePlan struct

+ BackupConfig *BackupConfig

+ MaxMemoryPercent int

+ NodeCount int

+ Regions interface{}

+ ServicePlan string

+ ServiceType string

+ type ServiceResponse struct

+ Service *Service

+ type ServiceTagsHandler struct

+ func (h *ServiceTagsHandler) Get(ctx context.Context, project, service string) (*ServiceTagsResponse, error)

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

+ type ServiceTagsRequest struct

+ Tags map[string]string

+ type ServiceTagsResponse struct

+ Tags map[string]string

+ type ServiceTask struct

+ CreateTime *time.Time

+ Id string

+ Result string

+ SourcePgVersion string

+ Success *bool

+ TargetPgVersion string

+ TaskType string

+ type ServiceTaskHandler struct

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

+ func (h ServiceTaskHandler) Get(ctx context.Context, project, service, id string) (*ServiceTaskResponse, error)

+ type ServiceTaskRequest struct

+ TargetVersion string

+ TaskType string

+ type ServiceTaskResponse struct

+ Task ServiceTask

+ type ServiceType struct

+ DefaultVersion string

+ Description string

+ LatestAvailableVersion string

+ ServicePlans []ServicePlan

+ UserConfigSchema UserConfigSchema

+ type ServiceTypesHandler struct

+ func (h *ServiceTypesHandler) GetPlan(ctx context.Context, project, serviceType, servicePlan string) (*GetServicePlanResponse, error)

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

+ type ServiceUser struct

+ AccessCert string

+ AccessCertNotValidAfterTime *time.Time

+ AccessControl AccessControl

+ AccessKey string

+ Password string

+ Type string

+ Username string

+ type ServiceUserResponse struct

+ User *ServiceUser

+ type ServiceUsersHandler struct

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

+ func (h *ServiceUsersHandler) Delete(ctx context.Context, project, service, user string) error

+ func (h *ServiceUsersHandler) Get(ctx context.Context, project, serviceName, username string) (*ServiceUser, error)

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

+ func (h *ServiceUsersHandler) Update(ctx context.Context, project, service, username string, ...) (*ServiceUser, error)

+ type ServicesHandler struct

+ func (h *ServicesHandler) Create(ctx context.Context, project string, req CreateServiceRequest) (*Service, error)

+ func (h *ServicesHandler) Delete(ctx context.Context, project, service string) error

+ func (h *ServicesHandler) Get(ctx context.Context, project, service string) (*Service, error)

+ func (h *ServicesHandler) List(ctx context.Context, project string) ([]*Service, error)

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

+ type StaticIP struct

+ CloudName string

+ IPAddress string

+ ServiceName string

+ State string

+ StaticIPAddressID string

+ type StaticIPsHandler struct

+ func (h *StaticIPsHandler) Associate(ctx context.Context, project, staticIPID string, req AssociateStaticIPRequest) error

+ func (h *StaticIPsHandler) Create(ctx context.Context, project string, req CreateStaticIPRequest) (*CreateStaticIPResponse, error)

+ func (h *StaticIPsHandler) Delete(ctx context.Context, project string, req DeleteStaticIPRequest) error

+ func (h *StaticIPsHandler) Dissociate(ctx context.Context, project, staticIPID string) error

+ func (h *StaticIPsHandler) Get(ctx context.Context, project, staticIPID string) (*StaticIP, error)

+ func (h *StaticIPsHandler) List(ctx context.Context, project string) (*ListStaticIPResponse, error)

+ type StopFlinkApplicationDeploymentResponse struct

+ type Token struct

+ State string

+ Token string

+ type TransitGatewayVPCAttachment struct

+ CIDR string

+ PeerCloudAccount string

+ PeerResourceGroup *string

+ PeerVPC string

+ type TransitGatewayVPCAttachmentHandler struct

+ func (h *TransitGatewayVPCAttachmentHandler) Update(ctx context.Context, project, projectVPCId string, ...) (*VPC, error)

+ type TransitGatewayVPCAttachmentRequest struct

+ Add []TransitGatewayVPCAttachment

+ Delete []string

+ type UpdateConnectionPoolRequest struct

+ Database string

+ PoolMode string

+ PoolSize int

+ Username *string

+ type UpdateFlinkApplicationRequest struct

+ Name string

+ type UpdateKafkaTopicRequest struct

+ Config KafkaTopicConfig

+ MinimumInSyncReplicas *int

+ Partitions *int

+ Replication *int

+ RetentionBytes *int

+ RetentionHours *int

+ Tags []KafkaTopicTag

+ type UpdateProjectRequest struct

+ AccountId string

+ AddAccountOwnersAdminAccess *bool

+ BillingAddress *string

+ BillingCurrency string

+ BillingEmails *[]*ContactEmail

+ BillingExtraText *string

+ CardID *string

+ Cloud *string

+ CountryCode *string

+ Name string

+ Tags map[string]string

+ TechnicalEmails *[]*ContactEmail

+ VatID *string

+ type UpdateProjectUserOrInvitationRequest struct

+ MemberType string

+ type UpdateServiceIntegrationEndpointRequest struct

+ UserConfig map[string]interface{}

+ type UpdateServiceIntegrationRequest struct

+ UserConfig map[string]interface{}

+ type UpdateServiceRequest struct

+ Cloud string

+ DiskSpaceMB int

+ GroupName string

+ Karapace *bool

+ MaintenanceWindow *MaintenanceWindow

+ Plan string

+ Powered bool

+ ProjectVPCID *string

+ TerminationProtection bool

+ UserConfig map[string]interface{}

+ 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 VPC struct

+ CloudName string

+ CreateTime *time.Time

+ NetworkCIDR string

+ PeeringConnections []*VPCPeeringConnection

+ ProjectVPCID string

+ State string

+ UpdateTime *time.Time

+ type VPCListResponse struct

+ VPCs []*VPC

+ type VPCPeeringConnection struct

+ CreateTime *time.Time

+ PeerAzureAppId string

+ PeerAzureTenantId string

+ PeerCloudAccount string

+ PeerRegion *string

+ PeerResourceGroup *string

+ PeerVPC string

+ State string

+ StateInfo *map[string]interface{}

+ UpdateTime *time.Time

+ UserPeerNetworkCIDRs []string

+ VPCPeeringConnectionType string

+ type VPCPeeringConnectionsHandler struct

+ func (h *VPCPeeringConnectionsHandler) Create(ctx context.Context, project string, vpcID string, ...) (*VPCPeeringConnection, error)

+ func (h *VPCPeeringConnectionsHandler) Delete(ctx context.Context, project, vpcID, peerCloudAccount, peerVPC string) error

+ func (h *VPCPeeringConnectionsHandler) DeleteVPCPeering(ctx context.Context, project, vpcID, peerCloudAccount, peerVPC string, ...) error

+ func (h *VPCPeeringConnectionsHandler) DeleteVPCPeeringWithResourceGroup(ctx context.Context, ...) error

+ func (h *VPCPeeringConnectionsHandler) Get(ctx context.Context, project string, vpcID string, peerCloudAccount string, ...) (*VPCPeeringConnection, error)

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

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

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

+ type VPCsHandler struct

+ func (h *VPCsHandler) Create(ctx context.Context, project string, req CreateVPCRequest) (*VPC, error)

+ func (h *VPCsHandler) Delete(ctx context.Context, project, vpcID string) error

+ func (h *VPCsHandler) Get(ctx context.Context, project, vpcID string) (*VPC, error)

+ func (h *VPCsHandler) List(ctx context.Context, project string) ([]*VPC, error)

+ type ValidateFlinkApplicationVersionResponse struct

+ type ValidateFlinkApplicationVersionStatementError struct

+ Message string

+ Position flinkPosition

+ type ValidateFlinkJobRequest struct

+ Statement string

+ TableIDs []string

+ type ValidateFlinkJobResponse struct

+ JobValidateError struct{ ... }

v2.0.0-rc.5

Sep 14, 2023

Other modules containing this package

github.com/aiven/aiven-go-client

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