opensearch

package

Go to main page

Versions in this module

v1

v1.5.0

Aug 24, 2026

v1.4.0

Aug 19, 2026

v1.3.5

Aug 19, 2026

v1.3.4

Aug 18, 2026

v1.3.3

Aug 17, 2026

v1.3.2

Aug 16, 2026

v1.3.1

Aug 16, 2026

Changes in this version

type Application

+ Tags *tags.Tags

type DomainIndex

+ IndexSchema any

type Package

+ PackageUserList []string

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