Documentation
¶
Index ¶
- func AuthenticationTypeChoices() []string
- func DowTypeChoices() []string
- func IntegrationStatusTypeChoices() []string
- func KafkaAuthenticationMethodTypeChoices() []string
- func LevelTypeChoices() []string
- func LikelyErrorCauseTypeChoices() []string
- func NodeStateTypeChoices() []string
- func OperationTypeChoices() []string
- func PermissionTypeAltChoices() []string
- func PermissionTypeChoices() []string
- func PhaseTypeChoices() []string
- func PoolModeTypeChoices() []string
- func RoleTypeChoices() []string
- func RouteTypeChoices() []string
- func ServiceNotificationTypeChoices() []string
- func ServiceStateTypeChoices() []string
- func TopicStateTypeChoices() []string
- func UnitTypeChoices() []string
- func UsageTypeChoices() []string
- type AccessControlIn
- type AccessControlOut
- type AclOut
- type AdditionalRegionOut
- type AuthenticationType
- type BackupOut
- type ComponentOut
- type ConnectionPoolOut
- type DowType
- type Handler
- type IntegrationStatusOut
- type IntegrationStatusType
- type KafkaAuthenticationMethodType
- type LevelType
- type LikelyErrorCauseType
- type MaintenanceOut
- type MetadataOut
- type NodeStateOut
- type NodeStateType
- type OperationType
- type PermissionType
- type PermissionTypeAlt
- type PhaseType
- type PoolModeType
- type ProgressUpdateOut
- type RoleType
- type RouteType
- type SchemaRegistryAclOut
- type ServiceIntegrationOut
- type ServiceNotificationOut
- type ServiceNotificationType
- type ServiceStateType
- type ServiceUserCreateIn
- type ServiceUserCreateOut
- type ServiceUserCredentialsModifyIn
- type ServiceUserCredentialsModifyOut
- type ServiceUserCredentialsResetOut
- type ServiceUserGetOut
- type ServiceUserHandler
- func (h *ServiceUserHandler) ServiceUserCreate(ctx context.Context, project string, serviceName string, ...) (*ServiceUserCreateOut, error)
- func (h *ServiceUserHandler) ServiceUserCredentialsModify(ctx context.Context, project string, serviceName string, ...) (*ServiceUserCredentialsModifyOut, error)
- func (h *ServiceUserHandler) ServiceUserCredentialsReset(ctx context.Context, project string, serviceName string, ...) (*ServiceUserCredentialsResetOut, error)
- func (h *ServiceUserHandler) ServiceUserDelete(ctx context.Context, project string, serviceName string, ...) error
- func (h *ServiceUserHandler) ServiceUserGet(ctx context.Context, project string, serviceName string, ...) (*ServiceUserGetOut, error)
- type ShardOut
- type StateOut
- type TechEmailOut
- type TopicOut
- type TopicStateType
- type UnitType
- type UpdateOut
- type UsageType
- type UserOut
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AuthenticationTypeChoices ¶
func AuthenticationTypeChoices() []string
func DowTypeChoices ¶ added in v0.3.0
func DowTypeChoices() []string
func IntegrationStatusTypeChoices ¶ added in v0.3.0
func IntegrationStatusTypeChoices() []string
func KafkaAuthenticationMethodTypeChoices ¶ added in v0.3.0
func KafkaAuthenticationMethodTypeChoices() []string
func LevelTypeChoices ¶ added in v0.3.0
func LevelTypeChoices() []string
func LikelyErrorCauseTypeChoices ¶ added in v0.3.0
func LikelyErrorCauseTypeChoices() []string
func NodeStateTypeChoices ¶ added in v0.3.0
func NodeStateTypeChoices() []string
func OperationTypeChoices ¶
func OperationTypeChoices() []string
func PermissionTypeAltChoices ¶ added in v0.3.0
func PermissionTypeAltChoices() []string
func PermissionTypeChoices ¶ added in v0.3.0
func PermissionTypeChoices() []string
func PhaseTypeChoices ¶ added in v0.3.0
func PhaseTypeChoices() []string
func PoolModeTypeChoices ¶ added in v0.3.0
func PoolModeTypeChoices() []string
func RoleTypeChoices ¶ added in v0.3.0
func RoleTypeChoices() []string
func RouteTypeChoices ¶ added in v0.3.0
func RouteTypeChoices() []string
func ServiceNotificationTypeChoices ¶ added in v0.3.0
func ServiceNotificationTypeChoices() []string
func ServiceStateTypeChoices ¶ added in v0.3.0
func ServiceStateTypeChoices() []string
func TopicStateTypeChoices ¶ added in v0.3.0
func TopicStateTypeChoices() []string
func UnitTypeChoices ¶ added in v0.3.0
func UnitTypeChoices() []string
func UsageTypeChoices ¶ added in v0.3.0
func UsageTypeChoices() []string
Types ¶
type AccessControlIn ¶
type AccessControlIn struct { M3Group string `json:"m3_group,omitempty"` PgAllowReplication *bool `json:"pg_allow_replication,omitempty"` RedisAclCategories *[]string `json:"redis_acl_categories,omitempty"` RedisAclChannels *[]string `json:"redis_acl_channels,omitempty"` RedisAclCommands *[]string `json:"redis_acl_commands,omitempty"` RedisAclKeys *[]string `json:"redis_acl_keys,omitempty"` }
type AccessControlOut ¶
type AccessControlOut struct { M3Group string `json:"m3_group,omitempty"` PgAllowReplication *bool `json:"pg_allow_replication,omitempty"` RedisAclCategories []string `json:"redis_acl_categories,omitempty"` RedisAclChannels []string `json:"redis_acl_channels,omitempty"` RedisAclCommands []string `json:"redis_acl_commands,omitempty"` RedisAclKeys []string `json:"redis_acl_keys,omitempty"` }
type AclOut ¶
type AclOut struct { Id string `json:"id,omitempty"` Permission PermissionType `json:"permission"` Topic string `json:"topic"` Username string `json:"username"` }
type AdditionalRegionOut ¶
type AuthenticationType ¶
type AuthenticationType string
const ( AuthenticationTypeNull AuthenticationType = "null" AuthenticationTypeCachingSha2Password AuthenticationType = "caching_sha2_password" AuthenticationTypeMysqlNativePassword AuthenticationType = "mysql_native_password" )
type ComponentOut ¶
type ComponentOut struct { Component string `json:"component"` Host string `json:"host"` KafkaAuthenticationMethod KafkaAuthenticationMethodType `json:"kafka_authentication_method,omitempty"` Path string `json:"path,omitempty"` Port int `json:"port"` PrivatelinkConnectionId string `json:"privatelink_connection_id,omitempty"` Route RouteType `json:"route"` Ssl *bool `json:"ssl,omitempty"` Usage UsageType `json:"usage"` }
type ConnectionPoolOut ¶
type Handler ¶
type Handler interface { // ServiceUserCreate create a new (sub) user for service // POST /v1/project/{project}/service/{service_name}/user // https://api.aiven.io/doc/#tag/Service/operation/ServiceUserCreate ServiceUserCreate(ctx context.Context, project string, serviceName string, in *ServiceUserCreateIn) (*ServiceUserCreateOut, error) // ServiceUserCredentialsModify modify service user credentials // PUT /v1/project/{project}/service/{service_name}/user/{service_username} // https://api.aiven.io/doc/#tag/Service/operation/ServiceUserCredentialsModify ServiceUserCredentialsModify(ctx context.Context, project string, serviceName string, serviceUsername string, in *ServiceUserCredentialsModifyIn) (*ServiceUserCredentialsModifyOut, error) // ServiceUserCredentialsReset reset service user credentials // PUT /v1/project/{project}/service/{service_name}/user/{service_username}/credentials/reset // https://api.aiven.io/doc/#tag/Service/operation/ServiceUserCredentialsReset ServiceUserCredentialsReset(ctx context.Context, project string, serviceName string, serviceUsername string) (*ServiceUserCredentialsResetOut, error) // ServiceUserDelete delete a service user // DELETE /v1/project/{project}/service/{service_name}/user/{service_username} // https://api.aiven.io/doc/#tag/Service/operation/ServiceUserDelete ServiceUserDelete(ctx context.Context, project string, serviceName string, serviceUsername string) error // ServiceUserGet get details for a single user // GET /v1/project/{project}/service/{service_name}/user/{service_username} // https://api.aiven.io/doc/#tag/Service/operation/ServiceUserGet ServiceUserGet(ctx context.Context, project string, serviceName string, serviceUsername string) (*ServiceUserGetOut, error) }
type IntegrationStatusOut ¶
type IntegrationStatusType ¶ added in v0.3.0
type IntegrationStatusType string
const ( IntegrationStatusTypeFailed IntegrationStatusType = "failed" IntegrationStatusTypeInactive IntegrationStatusType = "inactive" IntegrationStatusTypeRunning IntegrationStatusType = "running" IntegrationStatusTypeStarting IntegrationStatusType = "starting" IntegrationStatusTypeUnknown IntegrationStatusType = "unknown" )
type KafkaAuthenticationMethodType ¶ added in v0.3.0
type KafkaAuthenticationMethodType string
const ( KafkaAuthenticationMethodTypeCertificate KafkaAuthenticationMethodType = "certificate" KafkaAuthenticationMethodTypeSasl KafkaAuthenticationMethodType = "sasl" )
type LikelyErrorCauseType ¶ added in v0.3.0
type LikelyErrorCauseType string
const ( LikelyErrorCauseTypeNull LikelyErrorCauseType = "null" LikelyErrorCauseTypeDestination LikelyErrorCauseType = "destination" LikelyErrorCauseTypeIntegration LikelyErrorCauseType = "integration" LikelyErrorCauseTypeSource LikelyErrorCauseType = "source" LikelyErrorCauseTypeUnknown LikelyErrorCauseType = "unknown" )
type MaintenanceOut ¶
type MetadataOut ¶
type MetadataOut struct { EndOfLifeHelpArticleUrl string `json:"end_of_life_help_article_url,omitempty"` EndOfLifePolicyUrl string `json:"end_of_life_policy_url,omitempty"` ServiceEndOfLifeTime *time.Time `json:"service_end_of_life_time,omitempty"` UpgradeToServiceType string `json:"upgrade_to_service_type,omitempty"` UpgradeToVersion string `json:"upgrade_to_version,omitempty"` }
type NodeStateOut ¶
type NodeStateOut struct { Name string `json:"name"` ProgressUpdates []ProgressUpdateOut `json:"progress_updates,omitempty"` Role RoleType `json:"role,omitempty"` Shard *ShardOut `json:"shard,omitempty"` State NodeStateType `json:"state"` }
type NodeStateType ¶ added in v0.3.0
type NodeStateType string
const ( NodeStateTypeLeaving NodeStateType = "leaving" NodeStateTypeRunning NodeStateType = "running" NodeStateTypeSettingUpVm NodeStateType = "setting_up_vm" NodeStateTypeSyncingData NodeStateType = "syncing_data" NodeStateTypeTimingOut NodeStateType = "timing_out" NodeStateTypeUnknown NodeStateType = "unknown" )
type OperationType ¶
type OperationType string
const ( OperationTypeAcknowledgeRenewal OperationType = "acknowledge-renewal" OperationTypeResetCredentials OperationType = "reset-credentials" OperationTypeSetAccessControl OperationType = "set-access-control" )
type PermissionType ¶ added in v0.3.0
type PermissionType string
const ( PermissionTypeAdmin PermissionType = "admin" PermissionTypeRead PermissionType = "read" PermissionTypeReadwrite PermissionType = "readwrite" PermissionTypeWrite PermissionType = "write" )
type PermissionTypeAlt ¶ added in v0.3.0
type PermissionTypeAlt string
const ( PermissionTypeAltSchemaRegistryRead PermissionTypeAlt = "schema_registry_read" PermissionTypeAltSchemaRegistryWrite PermissionTypeAlt = "schema_registry_write" )
type PoolModeType ¶ added in v0.3.0
type PoolModeType string
const ( PoolModeTypeSession PoolModeType = "session" PoolModeTypeTransaction PoolModeType = "transaction" PoolModeTypeStatement PoolModeType = "statement" )
type ProgressUpdateOut ¶
type SchemaRegistryAclOut ¶
type SchemaRegistryAclOut struct { Id string `json:"id,omitempty"` Permission PermissionTypeAlt `json:"permission"` Resource string `json:"resource"` Username string `json:"username"` }
type ServiceIntegrationOut ¶
type ServiceIntegrationOut struct { Active bool `json:"active"` Description string `json:"description"` DestEndpoint string `json:"dest_endpoint,omitempty"` DestEndpointId string `json:"dest_endpoint_id,omitempty"` DestProject string `json:"dest_project"` DestService string `json:"dest_service,omitempty"` DestServiceType string `json:"dest_service_type"` Enabled bool `json:"enabled"` IntegrationStatus *IntegrationStatusOut `json:"integration_status,omitempty"` IntegrationType string `json:"integration_type"` ServiceIntegrationId string `json:"service_integration_id"` SourceEndpoint string `json:"source_endpoint,omitempty"` SourceEndpointId string `json:"source_endpoint_id,omitempty"` SourceProject string `json:"source_project"` SourceService string `json:"source_service"` SourceServiceType string `json:"source_service_type"` UserConfig map[string]any `json:"user_config,omitempty"` }
type ServiceNotificationOut ¶
type ServiceNotificationOut struct { Level LevelType `json:"level"` Message string `json:"message"` Metadata MetadataOut `json:"metadata"` Type ServiceNotificationType `json:"type"` }
type ServiceNotificationType ¶ added in v0.3.0
type ServiceNotificationType string
const ( ServiceNotificationTypeServiceEndOfLife ServiceNotificationType = "service_end_of_life" ServiceNotificationTypeServicePoweredOffRemoval ServiceNotificationType = "service_powered_off_removal" )
type ServiceStateType ¶ added in v0.3.0
type ServiceStateType string
const ( ServiceStateTypePoweroff ServiceStateType = "POWEROFF" ServiceStateTypeRebalancing ServiceStateType = "REBALANCING" ServiceStateTypeRebuilding ServiceStateType = "REBUILDING" ServiceStateTypeRunning ServiceStateType = "RUNNING" )
type ServiceUserCreateIn ¶
type ServiceUserCreateIn struct { AccessControl *AccessControlIn `json:"access_control,omitempty"` Authentication AuthenticationType `json:"authentication,omitempty"` Username string `json:"username"` }
type ServiceUserCreateOut ¶
type ServiceUserCreateOut struct { AccessCert string `json:"access_cert,omitempty"` AccessCertNotValidAfterTime *time.Time `json:"access_cert_not_valid_after_time,omitempty"` AccessControl *AccessControlOut `json:"access_control,omitempty"` AccessKey string `json:"access_key,omitempty"` Authentication AuthenticationType `json:"authentication,omitempty"` ExpiringCertNotValidAfterTime *time.Time `json:"expiring_cert_not_valid_after_time,omitempty"` Password string `json:"password"` Type string `json:"type"` Username string `json:"username"` }
type ServiceUserCredentialsModifyIn ¶
type ServiceUserCredentialsModifyIn struct { AccessControl *AccessControlIn `json:"access_control,omitempty"` Authentication AuthenticationType `json:"authentication,omitempty"` NewPassword string `json:"new_password,omitempty"` Operation OperationType `json:"operation"` }
type ServiceUserCredentialsModifyOut ¶
type ServiceUserCredentialsModifyOut struct { Acl []AclOut `json:"acl,omitempty"` Backups []BackupOut `json:"backups,omitempty"` CloudDescription string `json:"cloud_description,omitempty"` CloudName string `json:"cloud_name"` Components []ComponentOut `json:"components,omitempty"` ConnectionInfo map[string]any `json:"connection_info,omitempty"` ConnectionPools []ConnectionPoolOut `json:"connection_pools,omitempty"` CreateTime time.Time `json:"create_time"` Databases []string `json:"databases,omitempty"` DiskSpaceMb *float64 `json:"disk_space_mb,omitempty"` Features map[string]any `json:"features,omitempty"` GroupList []string `json:"group_list"` Maintenance *MaintenanceOut `json:"maintenance,omitempty"` Metadata map[string]any `json:"metadata,omitempty"` NodeCount *int `json:"node_count,omitempty"` NodeCpuCount *int `json:"node_cpu_count,omitempty"` NodeMemoryMb *float64 `json:"node_memory_mb,omitempty"` NodeStates []NodeStateOut `json:"node_states,omitempty"` Plan string `json:"plan"` ProjectVpcId string `json:"project_vpc_id"` SchemaRegistryAcl []SchemaRegistryAclOut `json:"schema_registry_acl,omitempty"` ServiceIntegrations []ServiceIntegrationOut `json:"service_integrations"` ServiceName string `json:"service_name"` ServiceNotifications []ServiceNotificationOut `json:"service_notifications,omitempty"` ServiceType string `json:"service_type"` ServiceTypeDescription string `json:"service_type_description,omitempty"` ServiceUri string `json:"service_uri"` ServiceUriParams map[string]any `json:"service_uri_params,omitempty"` State ServiceStateType `json:"state"` Tags map[string]string `json:"tags,omitempty"` TechEmails []TechEmailOut `json:"tech_emails,omitempty"` TerminationProtection bool `json:"termination_protection"` Topics []TopicOut `json:"topics,omitempty"` UpdateTime time.Time `json:"update_time"` UserConfig map[string]any `json:"user_config"` Users []UserOut `json:"users,omitempty"` }
type ServiceUserCredentialsResetOut ¶
type ServiceUserCredentialsResetOut struct { Acl []AclOut `json:"acl,omitempty"` Backups []BackupOut `json:"backups,omitempty"` CloudDescription string `json:"cloud_description,omitempty"` CloudName string `json:"cloud_name"` Components []ComponentOut `json:"components,omitempty"` ConnectionInfo map[string]any `json:"connection_info,omitempty"` ConnectionPools []ConnectionPoolOut `json:"connection_pools,omitempty"` CreateTime time.Time `json:"create_time"` Databases []string `json:"databases,omitempty"` DiskSpaceMb *float64 `json:"disk_space_mb,omitempty"` Features map[string]any `json:"features,omitempty"` GroupList []string `json:"group_list"` Maintenance *MaintenanceOut `json:"maintenance,omitempty"` Metadata map[string]any `json:"metadata,omitempty"` NodeCount *int `json:"node_count,omitempty"` NodeCpuCount *int `json:"node_cpu_count,omitempty"` NodeMemoryMb *float64 `json:"node_memory_mb,omitempty"` NodeStates []NodeStateOut `json:"node_states,omitempty"` Plan string `json:"plan"` ProjectVpcId string `json:"project_vpc_id"` SchemaRegistryAcl []SchemaRegistryAclOut `json:"schema_registry_acl,omitempty"` ServiceIntegrations []ServiceIntegrationOut `json:"service_integrations"` ServiceName string `json:"service_name"` ServiceNotifications []ServiceNotificationOut `json:"service_notifications,omitempty"` ServiceType string `json:"service_type"` ServiceTypeDescription string `json:"service_type_description,omitempty"` ServiceUri string `json:"service_uri"` ServiceUriParams map[string]any `json:"service_uri_params,omitempty"` State ServiceStateType `json:"state"` Tags map[string]string `json:"tags,omitempty"` TechEmails []TechEmailOut `json:"tech_emails,omitempty"` TerminationProtection bool `json:"termination_protection"` Topics []TopicOut `json:"topics,omitempty"` UpdateTime time.Time `json:"update_time"` UserConfig map[string]any `json:"user_config"` Users []UserOut `json:"users,omitempty"` }
type ServiceUserGetOut ¶
type ServiceUserGetOut struct { AccessCert string `json:"access_cert,omitempty"` AccessCertNotValidAfterTime *time.Time `json:"access_cert_not_valid_after_time,omitempty"` AccessControl *AccessControlOut `json:"access_control,omitempty"` AccessKey string `json:"access_key,omitempty"` Authentication AuthenticationType `json:"authentication,omitempty"` ExpiringCertNotValidAfterTime *time.Time `json:"expiring_cert_not_valid_after_time,omitempty"` Password string `json:"password"` Type string `json:"type"` Username string `json:"username"` }
type ServiceUserHandler ¶
type ServiceUserHandler struct {
// contains filtered or unexported fields
}
func NewHandler ¶
func NewHandler(doer doer) ServiceUserHandler
func (*ServiceUserHandler) ServiceUserCreate ¶
func (h *ServiceUserHandler) ServiceUserCreate(ctx context.Context, project string, serviceName string, in *ServiceUserCreateIn) (*ServiceUserCreateOut, error)
func (*ServiceUserHandler) ServiceUserCredentialsModify ¶
func (h *ServiceUserHandler) ServiceUserCredentialsModify(ctx context.Context, project string, serviceName string, serviceUsername string, in *ServiceUserCredentialsModifyIn) (*ServiceUserCredentialsModifyOut, error)
func (*ServiceUserHandler) ServiceUserCredentialsReset ¶
func (h *ServiceUserHandler) ServiceUserCredentialsReset(ctx context.Context, project string, serviceName string, serviceUsername string) (*ServiceUserCredentialsResetOut, error)
func (*ServiceUserHandler) ServiceUserDelete ¶
func (*ServiceUserHandler) ServiceUserGet ¶
func (h *ServiceUserHandler) ServiceUserGet(ctx context.Context, project string, serviceName string, serviceUsername string) (*ServiceUserGetOut, error)
type StateOut ¶
type StateOut struct { Errors []string `json:"errors"` LikelyErrorCause LikelyErrorCauseType `json:"likely_error_cause,omitempty"` Nodes map[string]any `json:"nodes"` Status IntegrationStatusType `json:"status"` }
type TechEmailOut ¶
type TechEmailOut struct {
Email string `json:"email"`
}
type TopicOut ¶
type TopicOut struct { CleanupPolicy string `json:"cleanup_policy"` MinInsyncReplicas int `json:"min_insync_replicas"` Partitions int `json:"partitions"` Replication int `json:"replication"` RetentionBytes int `json:"retention_bytes"` RetentionHours int `json:"retention_hours"` State TopicStateType `json:"state,omitempty"` TopicName string `json:"topic_name"` }
type TopicStateType ¶ added in v0.3.0
type TopicStateType string
const ( TopicStateTypeActive TopicStateType = "ACTIVE" TopicStateTypeConfiguring TopicStateType = "CONFIGURING" TopicStateTypeDeleting TopicStateType = "DELETING" )
type UserOut ¶
type UserOut struct { AccessCert string `json:"access_cert,omitempty"` AccessCertNotValidAfterTime *time.Time `json:"access_cert_not_valid_after_time,omitempty"` AccessControl *AccessControlOut `json:"access_control,omitempty"` AccessKey string `json:"access_key,omitempty"` Authentication AuthenticationType `json:"authentication,omitempty"` ExpiringCertNotValidAfterTime *time.Time `json:"expiring_cert_not_valid_after_time,omitempty"` Password string `json:"password"` Type string `json:"type"` Username string `json:"username"` }
Click to show internal directories.
Click to hide internal directories.