opensearch

package

Go to main page

Versions in this module

v1

v1.3.0

Aug 3, 2026

v1.2.0

Aug 3, 2026

Changes in this version

+ var ErrAttachmentConflict = errors.New("ConflictException")

+ var ErrAttachmentNotFound = errors.New("ResourceNotFoundException")

+ var ErrCapabilityNotFound = errors.New("ResourceNotFoundException")

+ var ErrInsightNotFound = errors.New("ResourceNotFoundException")

+ var ErrMigrationNotFound = errors.New("ResourceNotFoundException")

+ var ErrScheduledActionNotFound = errors.New("ResourceNotFoundException")

+ var ErrWorkspaceNotFound = errors.New("ResourceNotFoundException")

type Application

+ CreatedAt float64

+ LastUpdatedAt float64

+ type Capability struct

+ ApplicationID string

+ CapabilityName string

+ Status string

+ StatusUntil time.Time

type DataSource

+ Status string

+ type DataSourceAttachment struct

+ ApplicationID string

+ AttachmentID string

+ CreatedAt time.Time

+ DataSourceArn string

+ Status string

+ type DomainInformation struct

+ DomainName string

+ OwnerID string

+ Region string

type DomainPackageDetails

+ LastUpdated float64

+ PackageName string

+ PackageType string

+ type ExportOptionsInput struct

+ IncludeReferencesDeep bool

+ Objects []SavedObjectIdentifierInput

+ Types []string

type InMemoryBackend

+ func (b *InMemoryBackend) AttachDataSource(applicationID, dataSourceArn string, workspaceConfig *WorkspaceConfigInput, ...) (*DataSourceAttachment, error)

+ func (b *InMemoryBackend) DeregisterCapability(applicationID, capabilityName string) error

+ func (b *InMemoryBackend) DescribeDataSourceAttachment(applicationID, dataSourceArn string) (*DataSourceAttachment, error)

+ func (b *InMemoryBackend) DetachDataSource(applicationID, dataSourceArn string) (*DataSourceAttachment, error)

+ func (b *InMemoryBackend) GetCapability(applicationID, capabilityName string) (*Capability, error)

+ func (b *InMemoryBackend) GetDefaultApplicationSetting() string

+ func (b *InMemoryBackend) GetMigration(migrationID string) (*Migration, error)

+ func (b *InMemoryBackend) ListDataSourceAttachments(applicationID string) []*DataSourceAttachment

+ func (b *InMemoryBackend) ListMigrations(applicationID, statusFilter string) ([]*Migration, error)

+ func (b *InMemoryBackend) PutDefaultApplicationSetting(applicationArn string, setAsDefault bool) (string, error)

+ func (b *InMemoryBackend) RegisterCapability(applicationID, capabilityName string) (*Capability, error)

+ func (b *InMemoryBackend) RollbackServiceSoftwareUpdate(domainName string) (*RollbackServiceSoftwareOptions, error)

+ func (b *InMemoryBackend) StartMigration(applicationID, sourceArn string, workspace *MigrationWorkspaceInput, ...) (*Migration, error)

+ func (b *InMemoryBackend) ValidateInsightEntity(entityType, entityValue string) error

type InboundConnection

+ ConnectionMode string

+ LocalDomainInfo DomainInformation

+ RemoteDomainInfo DomainInformation

+ StatusMessage string

+ type Migration struct

+ ApplicationID string

+ CreatedAt time.Time

+ ExportedCount int

+ ImportedCount int

+ MigrationID string

+ SourceArn string

+ Status string

+ UpdatedAt time.Time

+ type MigrationWorkspaceInput struct

+ CreateWorkspace bool

+ Name string

+ Type string

+ WorkspaceID string

type OutboundConnection

+ ConnectionMode string

+ Endpoint string

+ SkipUnavailable string

+ StatusMessage string

+ type RollbackServiceSoftwareOptions struct

+ CurrentVersion string

+ Description string

+ NewVersion string

+ RollbackAvailable bool

+ type SavedObjectIdentifierInput struct

+ ID string

+ Type string

type StorageBackend

+ AttachDataSource func(applicationID, dataSourceArn string, workspaceConfig *WorkspaceConfigInput, ...) (*DataSourceAttachment, error)

+ DeregisterCapability func(applicationID, capabilityName string) error

+ DescribeDataSourceAttachment func(applicationID, dataSourceArn string) (*DataSourceAttachment, error)

+ DetachDataSource func(applicationID, dataSourceArn string) (*DataSourceAttachment, error)

+ GetCapability func(applicationID, capabilityName string) (*Capability, error)

+ GetDefaultApplicationSetting func() string

+ GetMigration func(migrationID string) (*Migration, error)

+ ListDataSourceAttachments func(applicationID string) []*DataSourceAttachment

+ ListMigrations func(applicationID, statusFilter string) ([]*Migration, error)

+ PutDefaultApplicationSetting func(applicationArn string, setAsDefault bool) (string, error)

+ RegisterCapability func(applicationID, capabilityName string) (*Capability, error)

+ RollbackServiceSoftwareUpdate func(domainName string) (*RollbackServiceSoftwareOptions, error)

+ StartMigration func(applicationID, sourceArn string, workspace *MigrationWorkspaceInput, ...) (*Migration, error)

+ ValidateInsightEntity func(entityType, entityValue string) error

+ type Workspace struct

+ ApplicationID string

+ CreatedAt time.Time

+ Name string

+ Type string

+ WorkspaceID string

+ type WorkspaceConfigInput struct

+ Name string

+ WorkspaceType string

v1.1.4

Jul 20, 2026

v1.1.3

Jul 20, 2026

v1.1.2

Jul 20, 2026

v1.1.1

Jul 20, 2026

v1.1.0

Jul 19, 2026

Changes in this version

+ const EngineDocker

+ const EngineStub

+ var ErrApplicationAlreadyExists = errors.New("ResourceAlreadyExistsException")

+ var ErrApplicationNotFound = errors.New("ResourceNotFoundException")

+ var ErrConnectionNotFound = errors.New("ResourceNotFoundException")

+ var ErrDataSourceAlreadyExists = errors.New("ResourceAlreadyExistsException")

+ var ErrDataSourceNotFound = errors.New("ResourceNotFoundException")

+ var ErrDomainAlreadyExists = errors.New("ResourceAlreadyExistsException")

+ var ErrDomainNotFound = errors.New("ResourceNotFoundException")

+ var ErrInvalidParameter = errors.New("ValidationException")

+ var ErrNilAppContext = errors.New("nil AppContext passed to OpenSearch Provider.Init")

+ var ErrPackageNotFound = errors.New("ResourceNotFoundException")

+ var ErrValidation = errors.New("ValidationException")

+ type AdditionalLimit struct

+ LimitName string

+ LimitValues []string

+ type AdvancedSecurityOptions struct

+ AnonymousAuthEnabled bool

+ Enabled bool

+ InternalUserDatabaseEnabled bool

+ SAMLOptions *SAMLOptionsInput

+ type AppConfig struct

+ Key string

+ Value string

+ type AppDataSource struct

+ DataSourceArn string

+ type AppSetting struct

+ Key string

+ Value string

+ type Application struct

+ ARN string

+ AppConfigs []AppConfig

+ DataSources []AppDataSource

+ ID string

+ Name string

+ type AuthorizedPrincipal struct

+ Principal string

+ PrincipalType string

+ type AutoTune struct

+ AutoTuneDetails AutoTuneDetails

+ AutoTuneType string

+ type AutoTuneConfig struct

+ DesiredState string

+ DomainName string

+ MaintenanceSchedules []AutoTuneMaintenanceSchedule

+ type AutoTuneDetails struct

+ ScheduledAutoTuneDetails ScheduledAutoTuneDetails

+ type AutoTuneDuration struct

+ Unit string

+ Value int

+ type AutoTuneMaintenanceSchedule struct

+ CronExpression string

+ Duration AutoTuneDuration

+ StartAt float64

+ type BlueGreenDeploymentOptions struct

+ Enabled bool

+ type ClusterConfig struct

+ BlueGreenDeploymentOptions *BlueGreenDeploymentOptions

+ ColdStorageEnabled bool

+ DedicatedMasterCount int

+ DedicatedMasterEnabled bool

+ DedicatedMasterType string

+ InstanceCount int

+ InstanceType string

+ MultiAZWithStandbyEnabled bool

+ WarmCount int

+ WarmEnabled bool

+ WarmType string

+ ZoneAwarenessConfig *ZoneAwarenessConfig

+ ZoneAwarenessEnabled bool

+ type CognitoOptions struct

+ Enabled bool

+ IdentityPoolID string

+ RoleARN string

+ UserPoolID string

+ type CreateDomainInput struct

+ AccessPolicies string

+ AdvancedSecurityOptions *AdvancedSecurityOptions

+ ClusterConfig ClusterConfig

+ CognitoOptions *CognitoOptions

+ DomainEndpointOptions *DomainEndpointOptions

+ EBSOptions *EBSOptions

+ EnableSoftwareUpdateOptions *EnableSoftwareUpdateOptions

+ EncryptionAtRestOptions *EncryptionAtRestOptions

+ EngineVersion string

+ IdentityCenterOptions *IdentityCenterOptions

+ LogPublishingOptions map[string]*LogPublishingOption

+ Name string

+ NodeToNodeEncryptionOptions *NodeToNodeEncryptionOptions

+ OffPeakWindowOptions *OffPeakWindowOptions

+ SnapshotOptions *SnapshotOptions

+ Tags map[string]string

+ VPCOptions *VPCOptions

+ type DNSRegistrar interface

+ Deregister func(hostname string)

+ Register func(hostname string)

+ type DataSource struct

+ DataSourceType string

+ Description string

+ DomainName string

+ Name string

+ type DirectQueryDataSource struct

+ DataSourceArn string

+ DataSourceType string

+ Description string

+ Name string

+ OpenSearchArns []string

+ type Domain struct

+ ARN string

+ AccessPolicies string

+ AdvancedSecurityOptions *AdvancedSecurityOptions

+ ClusterConfig ClusterConfig

+ CognitoOptions *CognitoOptions

+ Created bool

+ Deleted bool

+ DomainEndpointOptions *DomainEndpointOptions

+ DomainID string

+ EBSOptions *EBSOptions

+ EnableSoftwareUpdateOptions *EnableSoftwareUpdateOptions

+ EncryptionAtRestOptions *EncryptionAtRestOptions

+ Endpoint string

+ EngineVersion string

+ IdentityCenterOptions *IdentityCenterOptions

+ LastChangeID string

+ LogPublishingOptions map[string]*LogPublishingOption

+ Name string

+ NodeToNodeEncryptionOptions *NodeToNodeEncryptionOptions

+ OffPeakWindowOptions *OffPeakWindowOptions

+ ProcessingStatus string

+ ProcessingUntil time.Time

+ ServiceSoftware *ServiceSoftwareOptions

+ SnapshotOptions *SnapshotOptions

+ Status string

+ Tags *tags.Tags

+ VPCOptions *VPCOptions

+ type DomainEndpointOptions struct

+ CustomEndpoint string

+ CustomEndpointCertificateArn string

+ CustomEndpointEnabled bool

+ EnforceHTTPS bool

+ TLSSecurityPolicy string

+ type DomainEntry struct

+ EngineVersion string

+ Name string

+ type DomainIndex struct

+ Aliases map[string]any

+ DocumentCount int

+ Documents map[string]map[string]any

+ DomainName string

+ IndexName string

+ IndexStatus string

+ Mappings map[string]any

+ Settings map[string]any

+ type DomainMaintenance struct

+ Action string

+ CreatedAt float64

+ DomainName string

+ MaintenanceID string

+ NodeID string

+ Status string

+ StatusMessage string

+ UpdatedAt float64

+ type DomainPackageDetails struct

+ DomainName string

+ PackageID string

+ State string

+ type DryRunStatus struct

+ CreationDate string

+ DomainName string

+ DryRunID string

+ DryRunStatus string

+ UpdateDate string

+ ValidationFailures []map[string]any

+ type EBSOptions struct

+ EBSEnabled bool

+ IOPS int

+ KMSKeyID string

+ Throughput int

+ VolumeSize int

+ VolumeType string

+ type EnableSoftwareUpdateOptions struct

+ AutoSoftwareUpdateEnabled bool

+ type EncryptionAtRestOptions struct

+ Enabled bool

+ KMSKeyID string

+ type EngineConfig interface

+ GetOpenSearchEngine func() string

+ type Handler struct

+ AccountID string

+ Backend StorageBackend

+ Region string

+ func NewHandler(backend StorageBackend) *Handler

+ func (h *Handler) ChaosOperations() []string

+ func (h *Handler) ChaosRegions() []string

+ func (h *Handler) ChaosServiceName() string

+ func (h *Handler) ExtractOperation(c *echo.Context) string

+ func (h *Handler) ExtractResource(c *echo.Context) string

+ func (h *Handler) GetSupportedOperations() []string

+ func (h *Handler) Handle(c *echo.Context) error

+ func (h *Handler) Handler() echo.HandlerFunc

+ func (h *Handler) MatchPriority() int

+ func (h *Handler) Name() string

+ func (h *Handler) Reset()

+ func (h *Handler) Restore(ctx context.Context, data []byte) error

+ func (h *Handler) RouteMatcher() service.Matcher

+ func (h *Handler) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ func (h *Handler) Snapshot(ctx context.Context) []byte

+ type IdentityCenterOptions struct

+ EnabledAPIAccess bool

+ IdentityCenterApplicationARN string

+ IdentityCenterInstanceARN string

+ IdentityStoreID string

+ RolesKey string

+ SubjectKey string

+ type InMemoryBackend struct

+ func NewInMemoryBackend(accountID, region string) *InMemoryBackend

+ func (b *InMemoryBackend) AcceptInboundConnection(connectionID string) (*InboundConnection, error)

+ func (b *InMemoryBackend) AccountID() string

+ func (b *InMemoryBackend) AddDataSource(domainName, name, description, dataSourceType string) (string, error)

+ func (b *InMemoryBackend) AddDirectQueryDataSource(name, description, dataSourceType string, openSearchArns []string) (string, error)

+ func (b *InMemoryBackend) AddDomainInternal(name, engineVersion string)

+ func (b *InMemoryBackend) AddPackageInternal(packageID, packageName, packageType string)

+ func (b *InMemoryBackend) AddTags(domainARN string, kv map[string]string) error

+ func (b *InMemoryBackend) AssociatePackage(packageID, domainName string) (*DomainPackageDetails, error)

+ func (b *InMemoryBackend) AssociatePackages(domainName string, packageIDs []string) ([]DomainPackageDetails, error)

+ func (b *InMemoryBackend) AuthorizeVpcEndpointAccess(domainName, account, service string) (*AuthorizedPrincipal, error)

+ func (b *InMemoryBackend) BatchGetServerlessCollections(ids, names []string) []*ServerlessCollection

+ func (b *InMemoryBackend) CancelDomainConfigChange(domainName string, dryRun bool) ([]string, bool, error)

+ func (b *InMemoryBackend) CancelServiceSoftwareUpdate(domainName string) (*ServiceSoftwareOptions, error)

+ func (b *InMemoryBackend) CountDocuments(domainName, indexName string) (int, error)

+ func (b *InMemoryBackend) CreateApplication(name string, appConfigs []AppConfig, dataSources []AppDataSource) (*Application, error)

+ func (b *InMemoryBackend) CreateDomain(input CreateDomainInput) (*Domain, error)

+ func (b *InMemoryBackend) CreateIndex(domainName, indexName string, mappings, settings, aliases map[string]any) (*DomainIndex, error)

+ func (b *InMemoryBackend) CreateOutboundConnection(connectionAlias string, localDomainInfo, remoteDomainInfo map[string]any) (*OutboundConnection, error)

+ func (b *InMemoryBackend) CreatePackage(name, pkgType, description string, source *PackageSource, ...) (*Package, error)

+ func (b *InMemoryBackend) CreateServerlessAccessPolicy(policyType, name, description, policy string) (*ServerlessAccessPolicy, error)

+ func (b *InMemoryBackend) CreateServerlessCollection(name, collectionType, description, kmsKeyArn string, tagMap map[string]string) (*ServerlessCollection, error)

+ func (b *InMemoryBackend) CreateServerlessEncryptionPolicy(policyType, name, description, policy string) (*ServerlessEncryptionPolicy, error)

+ func (b *InMemoryBackend) CreateServerlessNetworkPolicy(policyType, name, description, policy string) (*ServerlessNetworkPolicy, error)

+ func (b *InMemoryBackend) CreateServerlessSecurityConfig(configType, description string, samlOptions *ServerlessSAMLOptions) (*ServerlessSecurityConfig, error)

+ func (b *InMemoryBackend) CreateVpcEndpoint(domainArn string, vpcOptions map[string]any) (*VpcEndpoint, error)

+ func (b *InMemoryBackend) DeleteApplication(id string) error

+ func (b *InMemoryBackend) DeleteDataSource(domainName, name string) error

+ func (b *InMemoryBackend) DeleteDirectQueryDataSource(name string) error

+ func (b *InMemoryBackend) DeleteDocument(domainName, indexName, docID string) error

+ func (b *InMemoryBackend) DeleteDomain(name string) (*Domain, error)

+ func (b *InMemoryBackend) DeleteInboundConnection(connectionID string) (*InboundConnection, error)

+ func (b *InMemoryBackend) DeleteIndex(domainName, indexName string) (*DomainIndex, error)

+ func (b *InMemoryBackend) DeleteOutboundConnection(connectionID string) (*OutboundConnection, error)

+ func (b *InMemoryBackend) DeletePackage(packageID string) (*Package, error)

+ func (b *InMemoryBackend) DeleteServerlessAccessPolicy(policyType, name string) error

+ func (b *InMemoryBackend) DeleteServerlessCollection(id string) (*ServerlessCollection, error)

+ func (b *InMemoryBackend) DeleteServerlessEncryptionPolicy(policyType, name string) error

+ func (b *InMemoryBackend) DeleteServerlessNetworkPolicy(policyType, name string) error

+ func (b *InMemoryBackend) DeleteServerlessSecurityConfig(id string) error

+ func (b *InMemoryBackend) DeleteVpcEndpoint(id string) (*VpcEndpoint, error)

+ func (b *InMemoryBackend) DescribeDomain(name string) (*Domain, error)

+ func (b *InMemoryBackend) DescribeDomains(names []string) ([]*Domain, error)

+ func (b *InMemoryBackend) DescribeInboundConnections() []*InboundConnection

+ func (b *InMemoryBackend) DescribeInstanceTypeLimits(instanceType, _ string) (*InstanceTypeLimits, error)

+ func (b *InMemoryBackend) DescribeOutboundConnections() []*OutboundConnection

+ func (b *InMemoryBackend) DescribePackages(ids []string) ([]*Package, error)

+ func (b *InMemoryBackend) DescribeReservedInstanceOfferings() []*ReservedInstanceOffering

+ func (b *InMemoryBackend) DescribeReservedInstances() []*ReservedInstance

+ func (b *InMemoryBackend) DescribeVpcEndpoints(ids []string) ([]*VpcEndpoint, []map[string]any)

+ func (b *InMemoryBackend) DissociatePackage(packageID, domainName string) (*DomainPackageDetails, error)

+ func (b *InMemoryBackend) DissociatePackages(domainName string, packageIDs []string) ([]DomainPackageDetails, error)

+ func (b *InMemoryBackend) DomainDocumentCount(domainName string) int

+ func (b *InMemoryBackend) GetApplication(id string) (*Application, error)

+ func (b *InMemoryBackend) GetAutoTune(domainName string) ([]*AutoTune, error)

+ func (b *InMemoryBackend) GetChangeProgress(domainName string) (map[string]any, error)

+ func (b *InMemoryBackend) GetCompatibleVersions(domainName string) []map[string]any

+ func (b *InMemoryBackend) GetDataSource(domainName, name string) (*DataSource, error)

+ func (b *InMemoryBackend) GetDefaultApplicationSettings(applicationType string) ([]AppSetting, error)

+ func (b *InMemoryBackend) GetDirectQueryDataSource(name string) (*DirectQueryDataSource, error)

+ func (b *InMemoryBackend) GetDocument(domainName, indexName, docID string) (map[string]any, error)

+ func (b *InMemoryBackend) GetDomainHealth(domainName string) (map[string]any, error)

+ func (b *InMemoryBackend) GetDomainMaintenanceStatus(domainName, maintenanceID string) (*DomainMaintenance, error)

+ func (b *InMemoryBackend) GetDomainNodes(domainName string) ([]map[string]any, error)

+ func (b *InMemoryBackend) GetDryRunProgress(domainName string) (*DryRunStatus, error)

+ func (b *InMemoryBackend) GetIndex(domainName, indexName string) (*DomainIndex, error)

+ func (b *InMemoryBackend) GetPackageVersionHistory(packageID string) ([]*PackageVersionHistory, error)

+ func (b *InMemoryBackend) GetServerlessAccessPolicy(policyType, name string) (*ServerlessAccessPolicy, error)

+ func (b *InMemoryBackend) GetServerlessEncryptionPolicy(policyType, name string) (*ServerlessEncryptionPolicy, error)

+ func (b *InMemoryBackend) GetServerlessSecurityConfig(id string) (*ServerlessSecurityConfig, error)

+ func (b *InMemoryBackend) GetUpgradeHistory(domainName string) ([]*UpgradeHistory, error)

+ func (b *InMemoryBackend) GetUpgradeStatus(domainName string) (string, string, string, error)

+ func (b *InMemoryBackend) IndexDocument(domainName, indexName, docID string, doc map[string]any) (string, bool, error)

+ func (b *InMemoryBackend) ListApplications() []*Application

+ func (b *InMemoryBackend) ListDataSources(domainName string) ([]*DataSource, error)

+ func (b *InMemoryBackend) ListDirectQueryDataSources() []*DirectQueryDataSource

+ func (b *InMemoryBackend) ListDomainEntriesFiltered(engineType string) []DomainEntry

+ func (b *InMemoryBackend) ListDomainMaintenances(domainName string) ([]*DomainMaintenance, error)

+ func (b *InMemoryBackend) ListDomainNames() []string

+ func (b *InMemoryBackend) ListDomainNamesByEngine(engineType string) []string

+ func (b *InMemoryBackend) ListDomainsForPackage(packageID string) []string

+ func (b *InMemoryBackend) ListInstanceTypeDetails(_, _ string) []map[string]any

+ func (b *InMemoryBackend) ListPackagesForDomain(domainName string) []*Package

+ func (b *InMemoryBackend) ListScheduledActions(domainName string) []*ScheduledAction

+ func (b *InMemoryBackend) ListServerlessAccessPolicies(policyType string) []*ServerlessAccessPolicy

+ func (b *InMemoryBackend) ListServerlessEncryptionPolicies(policyType string) []*ServerlessEncryptionPolicy

+ func (b *InMemoryBackend) ListServerlessNetworkPolicies(policyType string) []*ServerlessNetworkPolicy

+ func (b *InMemoryBackend) ListServerlessSecurityConfigs(configType string) []*ServerlessSecurityConfig

+ func (b *InMemoryBackend) ListTags(domainARN string) (map[string]string, error)

+ func (b *InMemoryBackend) ListVpcEndpointAccess(domainName string) ([]AuthorizedPrincipal, error)

+ func (b *InMemoryBackend) ListVpcEndpoints() []*VpcEndpoint

+ func (b *InMemoryBackend) ListVpcEndpointsForDomain(domainArn string) []*VpcEndpoint

+ func (b *InMemoryBackend) PreviewDomainConfig(name string, input UpdateDomainConfigInput) (*Domain, error)

+ func (b *InMemoryBackend) PurchaseReservedInstanceOffering(offeringID, name string, count int) (*ReservedInstance, error)

+ func (b *InMemoryBackend) PutDefaultApplicationSettings(applicationType string, settings []AppSetting) error

+ func (b *InMemoryBackend) Region() string

+ func (b *InMemoryBackend) RejectInboundConnection(connectionID string) (*InboundConnection, error)

+ func (b *InMemoryBackend) RemoveTags(domainARN string, keys []string) error

+ func (b *InMemoryBackend) Reset()

+ func (b *InMemoryBackend) Restore(ctx context.Context, data []byte) error

+ func (b *InMemoryBackend) RevokeVpcEndpointAccess(domainName, account string) error

+ func (b *InMemoryBackend) SearchIndex(domainName, indexName string, query map[string]any, size int) (*SearchResult, error)

+ func (b *InMemoryBackend) SetAutoTune(domainName, desiredState string, schedules []AutoTuneMaintenanceSchedule) error

+ func (b *InMemoryBackend) SetClock(fn func() time.Time)

+ func (b *InMemoryBackend) SetDNSRegistrar(dns DNSRegistrar)

+ func (b *InMemoryBackend) SetProcessingDelay(d time.Duration)

+ func (b *InMemoryBackend) Snapshot(ctx context.Context) []byte

+ func (b *InMemoryBackend) StartDomainMaintenance(domainName, action, nodeID string) (*DomainMaintenance, error)

+ func (b *InMemoryBackend) StartServiceSoftwareUpdate(domainName, scheduleAt string) (*ServiceSoftwareOptions, error)

+ func (b *InMemoryBackend) UpdateApplication(id string, appConfigs []AppConfig, dataSources []AppDataSource) (*Application, error)

+ func (b *InMemoryBackend) UpdateDataSource(domainName, name, description string) error

+ func (b *InMemoryBackend) UpdateDirectQueryDataSource(name, description string, openSearchArns []string) (*DirectQueryDataSource, error)

+ func (b *InMemoryBackend) UpdateDomainConfig(name string, input UpdateDomainConfigInput) (*Domain, error)

+ func (b *InMemoryBackend) UpdateIndex(domainName, indexName string, mappings, settings map[string]any) (*DomainIndex, error)

+ func (b *InMemoryBackend) UpdatePackage(packageID, description string) (*Package, error)

+ func (b *InMemoryBackend) UpdatePackageScope(packageID, _ string, _ []string) (*Package, error)

+ func (b *InMemoryBackend) UpdateScheduledAction(domainName string, action *ScheduledAction) (*ScheduledAction, error)

+ func (b *InMemoryBackend) UpdateServerlessAccessPolicy(policyType, name, description, policy, policyVersion string) (*ServerlessAccessPolicy, error)

+ func (b *InMemoryBackend) UpdateServerlessEncryptionPolicy(policyType, name, description, policy, policyVersion string) (*ServerlessEncryptionPolicy, error)

+ func (b *InMemoryBackend) UpdateServerlessSecurityConfig(id, description, configVersion string, samlOptions *ServerlessSAMLOptions) (*ServerlessSecurityConfig, error)

+ func (b *InMemoryBackend) UpdateVpcEndpoint(id string, vpcOptions map[string]any) (*VpcEndpoint, error)

+ func (b *InMemoryBackend) UpgradeDomain(domainName, upgradeName string) error

+ type InboundConnection struct

+ ConnectionID string

+ Status string

+ StatusUntil time.Time

+ type InstanceTypeLimits struct

+ AdditionalLimits []AdditionalLimit

+ InstanceLimits map[string]any

+ InstanceType string

+ StorageTypes []StorageType

+ type LogPublishingOption struct

+ CloudWatchLogsLogGroupARN string

+ Enabled bool

+ type NodeToNodeEncryptionOptions struct

+ Enabled bool

+ type OffPeakWindow struct

+ WindowStartTime *WindowStartTime

+ type OffPeakWindowOptions struct

+ Enabled bool

+ OffPeakWindow *OffPeakWindow

+ type OutboundConnection struct

+ ConnectionAlias string

+ ConnectionID string

+ LocalDomainInfo map[string]any

+ RemoteDomainInfo map[string]any

+ Status string

+ StatusUntil time.Time

+ type Package struct

+ AvailablePackageVersion string

+ CreatedAt float64

+ PackageDescription string

+ PackageEncryptionOptions *PackageEncryptionOptions

+ PackageID string

+ PackageName string

+ PackageSource *PackageSource

+ PackageStatus string

+ PackageType string

+ VersionHistory []*PackageVersionHistory

+ type PackageEncryptionOptions struct

+ EncryptionEnabled bool

+ KmsKeyIdentifier string

+ type PackageSource struct

+ S3BucketName string

+ S3Key string

+ type PackageVersionHistory struct

+ CommitMessage string

+ CreatedAt float64

+ PackageVersion string

+ type Provider struct

+ func (p *Provider) Init(ctx *service.AppContext) (service.Registerable, error)

+ func (p *Provider) Name() string

+ type ReservedInstance struct

+ CurrencyCode string

+ Duration int

+ FixedPrice float64

+ InstanceCount int

+ InstanceType string

+ PaymentOption string

+ ReservationName string

+ ReservedInstanceID string

+ ReservedInstanceOfferingID string

+ StartTime float64

+ State string

+ UsagePrice float64

+ type ReservedInstanceOffering struct

+ CurrencyCode string

+ Duration int

+ FixedPrice float64

+ InstanceType string

+ PaymentOption string

+ ReservedInstanceOfferingID string

+ UsagePrice float64

+ type SAMLOptionsInput struct

+ Enabled bool

+ IDPEntityID string

+ IDPMetadataContent string

+ RolesKey string

+ SessionTimeoutMinutes int

+ SubjectKey string

+ type ScheduledAction struct

+ Cancellable bool

+ Description string

+ ID string

+ Mandatory bool

+ ScheduledBy string

+ ScheduledTime float64

+ Severity string

+ Status string

+ Type string

+ type ScheduledAutoTuneDetails struct

+ Action string

+ ActionType string

+ Date float64

+ Severity string

+ type SearchHit struct

+ ID string

+ Index string

+ Source map[string]any

+ type SearchResult struct

+ Hits []SearchHit

+ Total int

+ type ServerlessAccessPolicy struct

+ CreatedDate float64

+ Description string

+ LastModifiedDate float64

+ Name string

+ Policy string

+ PolicyVersion string

+ Type string

+ type ServerlessCollection struct

+ Arn string

+ CollectionEndpoint string

+ CreatedDate float64

+ DashboardEndpoint string

+ Description string

+ ID string

+ KmsKeyArn string

+ LastModifiedDate float64

+ Name string

+ Status string

+ StatusUntil time.Time

+ Tags map[string]string

+ Type string

+ type ServerlessEncryptionPolicy struct

+ CreatedDate float64

+ Description string

+ LastModifiedDate float64

+ Name string

+ Policy string

+ PolicyVersion string

+ Type string

+ type ServerlessNetworkPolicy struct

+ CreatedDate float64

+ Description string

+ LastModifiedDate float64

+ Name string

+ Policy string

+ PolicyVersion string

+ Type string

+ type ServerlessSAMLOptions struct

+ GroupAttribute string

+ Metadata string

+ SessionTimeout int

+ UserAttribute string

+ type ServerlessSecurityConfig struct

+ ConfigVersion string

+ CreatedDate float64

+ Description string

+ ID string

+ LastModifiedDate float64

+ SamlOptions *ServerlessSAMLOptions

+ Type string

+ type ServiceSoftwareOptions struct

+ AutomatedUpdateDate string

+ Cancellable bool

+ CurrentVersion string

+ Description string

+ NewVersion string

+ OptionalDeployment bool

+ UpdateAvailable bool

+ UpdateStatus string

+ type SnapshotOptions struct

+ AutomatedSnapshotStartHour int

+ type StorageBackend interface

+ AcceptInboundConnection func(connectionID string) (*InboundConnection, error)

+ AccountID func() string

+ AddDataSource func(domainName, name, description, dataSourceType string) (string, error)

+ AddDirectQueryDataSource func(name, description, dataSourceType string, openSearchArns []string) (string, error)

+ AddTags func(domainARN string, kv map[string]string) error

+ AssociatePackage func(packageID, domainName string) (*DomainPackageDetails, error)

+ AssociatePackages func(domainName string, packageIDs []string) ([]DomainPackageDetails, error)

+ AuthorizeVpcEndpointAccess func(domainName, account, service string) (*AuthorizedPrincipal, error)

+ BatchGetServerlessCollections func(ids, names []string) []*ServerlessCollection

+ CancelDomainConfigChange func(domainName string, dryRun bool) ([]string, bool, error)

+ CancelServiceSoftwareUpdate func(domainName string) (*ServiceSoftwareOptions, error)

+ CountDocuments func(domainName, indexName string) (int, error)

+ CreateApplication func(name string, appConfigs []AppConfig, dataSources []AppDataSource) (*Application, error)

+ CreateDomain func(input CreateDomainInput) (*Domain, error)

+ CreateIndex func(domainName, indexName string, mappings, settings, aliases map[string]any) (*DomainIndex, error)

+ CreateOutboundConnection func(connectionAlias string, localDomainInfo, remoteDomainInfo map[string]any) (*OutboundConnection, error)

+ CreatePackage func(name, pkgType, description string, source *PackageSource, ...) (*Package, error)

+ CreateServerlessAccessPolicy func(policyType, name, description, policy string) (*ServerlessAccessPolicy, error)

+ CreateServerlessCollection func(name, collectionType, description, kmsKeyArn string, tags map[string]string) (*ServerlessCollection, error)

+ CreateServerlessEncryptionPolicy func(policyType, name, description, policy string) (*ServerlessEncryptionPolicy, error)

+ CreateServerlessNetworkPolicy func(policyType, name, description, policy string) (*ServerlessNetworkPolicy, error)

+ CreateServerlessSecurityConfig func(configType, description string, samlOptions *ServerlessSAMLOptions) (*ServerlessSecurityConfig, error)

+ CreateVpcEndpoint func(domainArn string, vpcOptions map[string]any) (*VpcEndpoint, error)

+ DeleteApplication func(id string) error

+ DeleteDataSource func(domainName, name string) error

+ DeleteDirectQueryDataSource func(name string) error

+ DeleteDocument func(domainName, indexName, docID string) error

+ DeleteDomain func(name string) (*Domain, error)

+ DeleteInboundConnection func(connectionID string) (*InboundConnection, error)

+ DeleteIndex func(domainName, indexName string) (*DomainIndex, error)

+ DeleteOutboundConnection func(connectionID string) (*OutboundConnection, error)

+ DeletePackage func(packageID string) (*Package, error)

+ DeleteServerlessAccessPolicy func(policyType, name string) error

+ DeleteServerlessCollection func(id string) (*ServerlessCollection, error)

+ DeleteServerlessEncryptionPolicy func(policyType, name string) error

+ DeleteServerlessNetworkPolicy func(policyType, name string) error

+ DeleteServerlessSecurityConfig func(id string) error

+ DeleteVpcEndpoint func(id string) (*VpcEndpoint, error)

+ DescribeDomain func(name string) (*Domain, error)

+ DescribeDomains func(names []string) ([]*Domain, error)

+ DescribeInboundConnections func() []*InboundConnection

+ DescribeInstanceTypeLimits func(instanceType, engineVersion string) (*InstanceTypeLimits, error)

+ DescribeOutboundConnections func() []*OutboundConnection

+ DescribePackages func(ids []string) ([]*Package, error)

+ DescribeReservedInstanceOfferings func() []*ReservedInstanceOffering

+ DescribeReservedInstances func() []*ReservedInstance

+ DescribeVpcEndpoints func(ids []string) ([]*VpcEndpoint, []map[string]any)

+ DissociatePackage func(packageID, domainName string) (*DomainPackageDetails, error)

+ DissociatePackages func(domainName string, packageIDs []string) ([]DomainPackageDetails, error)

+ DomainDocumentCount func(domainName string) int

+ GetApplication func(id string) (*Application, error)

+ GetAutoTune func(domainName string) ([]*AutoTune, error)

+ GetChangeProgress func(domainName string) (map[string]any, error)

+ GetCompatibleVersions func(domainName string) []map[string]any

+ GetDataSource func(domainName, name string) (*DataSource, error)

+ GetDefaultApplicationSettings func(applicationType string) ([]AppSetting, error)

+ GetDirectQueryDataSource func(name string) (*DirectQueryDataSource, error)

+ GetDocument func(domainName, indexName, docID string) (map[string]any, error)

+ GetDomainHealth func(domainName string) (map[string]any, error)

+ GetDomainMaintenanceStatus func(domainName, maintenanceID string) (*DomainMaintenance, error)

+ GetDomainNodes func(domainName string) ([]map[string]any, error)

+ GetDryRunProgress func(domainName string) (*DryRunStatus, error)

+ GetIndex func(domainName, indexName string) (*DomainIndex, error)

+ GetPackageVersionHistory func(packageID string) ([]*PackageVersionHistory, error)

+ GetServerlessAccessPolicy func(policyType, name string) (*ServerlessAccessPolicy, error)

+ GetServerlessEncryptionPolicy func(policyType, name string) (*ServerlessEncryptionPolicy, error)

+ GetServerlessSecurityConfig func(id string) (*ServerlessSecurityConfig, error)

+ GetUpgradeHistory func(domainName string) ([]*UpgradeHistory, error)

+ GetUpgradeStatus func(domainName string) (upgradeName, upgradeStatus, upgradeStep string, err error)

+ IndexDocument func(domainName, indexName, docID string, doc map[string]any) (string, bool, error)

+ ListApplications func() []*Application

+ ListDataSources func(domainName string) ([]*DataSource, error)

+ ListDirectQueryDataSources func() []*DirectQueryDataSource

+ ListDomainEntriesFiltered func(engineType string) []DomainEntry

+ ListDomainMaintenances func(domainName string) ([]*DomainMaintenance, error)

+ ListDomainNames func() []string

+ ListDomainNamesByEngine func(engineType string) []string

+ ListDomainsForPackage func(packageID string) []string

+ ListInstanceTypeDetails func(engineVersion, instanceType string) []map[string]any

+ ListPackagesForDomain func(domainName string) []*Package

+ ListScheduledActions func(domainName string) []*ScheduledAction

+ ListServerlessAccessPolicies func(policyType string) []*ServerlessAccessPolicy

+ ListServerlessEncryptionPolicies func(policyType string) []*ServerlessEncryptionPolicy

+ ListServerlessNetworkPolicies func(policyType string) []*ServerlessNetworkPolicy

+ ListServerlessSecurityConfigs func(configType string) []*ServerlessSecurityConfig

+ ListTags func(domainARN string) (map[string]string, error)

+ ListVpcEndpointAccess func(domainName string) ([]AuthorizedPrincipal, error)

+ ListVpcEndpoints func() []*VpcEndpoint

+ ListVpcEndpointsForDomain func(domainArn string) []*VpcEndpoint

+ PreviewDomainConfig func(name string, input UpdateDomainConfigInput) (*Domain, error)

+ PurchaseReservedInstanceOffering func(offeringID, name string, count int) (*ReservedInstance, error)

+ PutDefaultApplicationSettings func(applicationType string, settings []AppSetting) error

+ Region func() string

+ RejectInboundConnection func(connectionID string) (*InboundConnection, error)

+ RemoveTags func(domainARN string, keys []string) error

+ Reset func()

+ Restore func(ctx context.Context, data []byte) error

+ RevokeVpcEndpointAccess func(domainName, account string) error

+ SearchIndex func(domainName, indexName string, query map[string]any, size int) (*SearchResult, error)

+ SetAutoTune func(domainName, desiredState string, schedules []AutoTuneMaintenanceSchedule) error

+ Snapshot func(ctx context.Context) []byte

+ StartDomainMaintenance func(domainName, action, nodeID string) (*DomainMaintenance, error)

+ StartServiceSoftwareUpdate func(domainName, scheduleAt string) (*ServiceSoftwareOptions, error)

+ UpdateApplication func(id string, appConfigs []AppConfig, dataSources []AppDataSource) (*Application, error)

+ UpdateDataSource func(domainName, name, description string) error

+ UpdateDirectQueryDataSource func(name, description string, openSearchArns []string) (*DirectQueryDataSource, error)

+ UpdateDomainConfig func(name string, input UpdateDomainConfigInput) (*Domain, error)

+ UpdateIndex func(domainName, indexName string, mappings, settings map[string]any) (*DomainIndex, error)

+ UpdatePackage func(packageID, description string) (*Package, error)

+ UpdatePackageScope func(packageID, operation string, domainNames []string) (*Package, error)

+ UpdateScheduledAction func(domainName string, action *ScheduledAction) (*ScheduledAction, error)

+ UpdateServerlessAccessPolicy func(policyType, name, description, policy, policyVersion string) (*ServerlessAccessPolicy, error)

+ UpdateServerlessEncryptionPolicy func(policyType, name, description, policy, policyVersion string) (*ServerlessEncryptionPolicy, error)

+ UpdateServerlessSecurityConfig func(id, description, configVersion string, samlOptions *ServerlessSAMLOptions) (*ServerlessSecurityConfig, error)

+ UpdateVpcEndpoint func(id string, vpcOptions map[string]any) (*VpcEndpoint, error)

+ UpgradeDomain func(domainName, upgradeName string) error

+ type StorageType struct

+ StorageSubTypeName string

+ StorageTypeLimits []StorageTypeLimit

+ StorageTypeName string

+ type StorageTypeLimit struct

+ LimitName string

+ LimitValues []string

+ type UpdateDomainConfigInput struct

+ AccessPolicies string

+ AdvancedSecurityOptions *AdvancedSecurityOptions

+ ClusterConfig *ClusterConfig

+ CognitoOptions *CognitoOptions

+ DomainEndpointOptions *DomainEndpointOptions

+ EBSOptions *EBSOptions

+ EnableSoftwareUpdateOptions *EnableSoftwareUpdateOptions

+ EncryptionAtRestOptions *EncryptionAtRestOptions

+ EngineVersion string

+ IdentityCenterOptions *IdentityCenterOptions

+ LogPublishingOptions map[string]*LogPublishingOption

+ NodeToNodeEncryptionOptions *NodeToNodeEncryptionOptions

+ OffPeakWindowOptions *OffPeakWindowOptions

+ SnapshotOptions *SnapshotOptions

+ VPCOptions *VPCOptions

+ type UpgradeHistory struct

+ StartTimestamp float64

+ StepsList []UpgradeStepItem

+ UpgradeName string

+ UpgradeStatus string

+ type UpgradeStepItem struct

+ Issues []string

+ ProgressPercent float64

+ UpgradeStep string

+ UpgradeStepStatus string

+ type VPCOptions struct

+ SecurityGroupIDs []string

+ SubnetIDs []string

+ VPCID string

+ type VpcEndpoint struct

+ DomainArn string

+ Endpoint string

+ Status string

+ StatusUntil time.Time

+ VpcEndpointID string

+ VpcEndpointOwner string

+ VpcOptions map[string]any

+ type WindowStartTime struct

+ Hours int

+ Minutes int

+ type ZoneAwarenessConfig struct

+ AvailabilityZoneCount int

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