elasticsearch

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

+ type AdvancedSecurityOptions struct

+ AnonymousAuthEnabled bool

+ Enabled bool

+ InternalUserDatabaseEnabled bool

+ type AutoTuneOptions struct

+ DesiredState string

+ type CognitoOptions struct

+ Enabled bool

+ IdentityPoolID string

+ RoleARN string

+ UserPoolID string

type CreateDomainInput

+ AdvancedSecurityOptions *AdvancedSecurityOptions

+ AutoTuneOptions *AutoTuneOptions

+ CognitoOptions *CognitoOptions

+ LogPublishingOptions map[string]LogPublishingOption

+ Tags map[string]string

+ VPCOptions *VPCOptions

type Domain

+ AdvancedSecurityOptions *AdvancedSecurityOptions

+ AutoTuneOptions *AutoTuneOptions

+ CognitoOptions *CognitoOptions

+ ConfigUpdatedAt time.Time

+ ConfigVersion int

+ CreatedAt time.Time

+ LogPublishingOptions map[string]LogPublishingOption

+ VPCOptions *VPCOptions

+ type LogPublishingOption struct

+ CloudWatchLogsLogGroupARN string

+ Enabled bool

type Package

+ PackageSource PackageSource

+ type PackageSource struct

+ S3BucketName string

+ S3Key string

type UpdateConfig

+ AdvancedSecurityOptions *AdvancedSecurityOptions

+ AutoTuneOptions *AutoTuneOptions

+ CognitoOptions *CognitoOptions

+ LogPublishingOptions map[string]LogPublishingOption

+ VPCOptions *VPCOptions

+ type VPCOptions struct

+ SecurityGroupIDs []string

+ SubnetIDs []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 ErrConnectionNotFound = errors.New("ResourceNotFoundException")

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

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

+ var ErrInvalidParameter = ErrValidation

+ var ErrNilAppContext = errors.New("AppContext is required")

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

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

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

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

+ type ClusterConfig struct

+ ColdStorageEnabled bool

+ DedicatedMasterCount int

+ DedicatedMasterEnabled bool

+ DedicatedMasterType string

+ InstanceCount int

+ InstanceType string

+ WarmCount int

+ WarmEnabled bool

+ WarmType string

+ ZoneAwarenessConfig ZoneAwarenessConfig

+ ZoneAwarenessEnabled bool

+ type CreateDomainInput struct

+ AccessPolicies string

+ AdvancedOptions map[string]string

+ ClusterConfig ClusterConfig

+ EBSOptions EBSOptions

+ ElasticsearchVersion string

+ EncryptionAtRestEnabled bool

+ EnforceHTTPS bool

+ Name string

+ NodeToNodeEncryptionEnabled bool

+ SnapshotOptions SnapshotOptions

+ TLSSecurityPolicy string

+ type CrossClusterDomainInfo struct

+ DomainName string

+ OwnerID string

+ Region string

+ type DNSRegistrar interface

+ Deregister func(hostname string)

+ Register func(hostname string)

+ type Domain struct

+ ARN string

+ AccessPolicies string

+ AdvancedOptions map[string]string

+ ClusterConfig ClusterConfig

+ DomainID string

+ EBSOptions EBSOptions

+ ElasticsearchVersion string

+ EncryptionAtRestEnabled bool

+ Endpoint string

+ EnforceHTTPS bool

+ Name string

+ NodeToNodeEncryptionEnabled bool

+ SnapshotOptions SnapshotOptions

+ Status string

+ TLSSecurityPolicy string

+ Tags *tags.Tags

+ type EBSOptions struct

+ EBSEnabled bool

+ Iops int

+ Throughput int

+ VolumeSize int

+ VolumeType string

+ type EngineConfig interface

+ GetElasticsearchEngine func() string

+ type Handler struct

+ AccountID string

+ Backend *InMemoryBackend

+ Region string

+ func NewHandler(backend *InMemoryBackend) *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 InMemoryBackend struct

+ func NewInMemoryBackend(accountID, region string) *InMemoryBackend

+ func (b *InMemoryBackend) AcceptInboundCrossClusterSearchConnection(ctx context.Context, connectionID string) (*InboundConnection, error)

+ func (b *InMemoryBackend) AddDomainInternal(ctx context.Context, d Domain)

+ func (b *InMemoryBackend) AddInboundConnectionInternal(ctx context.Context, conn InboundConnection)

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

+ func (b *InMemoryBackend) AssociatePackage(ctx context.Context, packageID, domainName string) error

+ func (b *InMemoryBackend) AuthorizeVpcEndpointAccess(ctx context.Context, domainName, account string) error

+ func (b *InMemoryBackend) CancelDomainConfigChange(ctx context.Context, domainName string) (*Domain, error)

+ func (b *InMemoryBackend) CancelElasticsearchServiceSoftwareUpdate(ctx context.Context, domainName string) (*Domain, error)

+ func (b *InMemoryBackend) CreateDomain(ctx context.Context, inp CreateDomainInput) (*Domain, error)

+ func (b *InMemoryBackend) CreateOutboundCrossClusterSearchConnection(ctx context.Context, localDomain, remoteDomain CrossClusterDomainInfo, ...) (*OutboundConnection, error)

+ func (b *InMemoryBackend) CreatePackage(ctx context.Context, name, packageType, description string) (*Package, error)

+ func (b *InMemoryBackend) CreateVpcEndpoint(ctx context.Context, domainARN string, vpcOptions map[string]string) (*VpcEndpoint, error)

+ func (b *InMemoryBackend) DeleteDomain(ctx context.Context, name string) (*Domain, error)

+ func (b *InMemoryBackend) DeleteElasticsearchServiceRole() error

+ func (b *InMemoryBackend) DeleteInboundCrossClusterSearchConnection(ctx context.Context, connectionID string) (*InboundConnection, error)

+ func (b *InMemoryBackend) DeleteOutboundCrossClusterSearchConnection(ctx context.Context, connectionID string) (*OutboundConnection, error)

+ func (b *InMemoryBackend) DeletePackage(ctx context.Context, packageID string) (*Package, error)

+ func (b *InMemoryBackend) DeleteVpcEndpoint(ctx context.Context, vpcEndpointID string) (*VpcEndpoint, error)

+ func (b *InMemoryBackend) DescribeDomain(ctx context.Context, name string) (*Domain, error)

+ func (b *InMemoryBackend) DescribeDomainAutoTunes(ctx context.Context, domainName string) error

+ func (b *InMemoryBackend) DescribeDomainChangeProgress(ctx context.Context, domainName string) error

+ func (b *InMemoryBackend) DescribeInboundCrossClusterSearchConnections(ctx context.Context) []*InboundConnection

+ func (b *InMemoryBackend) DescribeOutboundCrossClusterSearchConnections(ctx context.Context) []*OutboundConnection

+ func (b *InMemoryBackend) DescribePackages(ctx context.Context, packageIDs []string) []*Package

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

+ func (b *InMemoryBackend) DescribeReservedElasticsearchInstances(ctx context.Context) []ReservedInstance

+ func (b *InMemoryBackend) DescribeVpcEndpoints(ctx context.Context, vpcEndpointIDs []string) []*VpcEndpoint

+ func (b *InMemoryBackend) DissociatePackage(ctx context.Context, packageID, domainName string) error

+ func (b *InMemoryBackend) GetPackageVersionHistory(ctx context.Context, packageID string) ([]*Package, error)

+ func (b *InMemoryBackend) GetUpgradeHistory(ctx context.Context, domainName string) error

+ func (b *InMemoryBackend) GetUpgradeStatus(ctx context.Context, domainName string) error

+ func (b *InMemoryBackend) ListDomainNames(ctx context.Context) []string

+ func (b *InMemoryBackend) ListDomainsForPackage(ctx context.Context, packageID string) ([]string, error)

+ func (b *InMemoryBackend) ListPackagesForDomain(ctx context.Context, domainName string) []*Package

+ func (b *InMemoryBackend) ListTags(ctx context.Context, domainARN string) (map[string]string, error)

+ func (b *InMemoryBackend) ListVpcEndpointAccess(ctx context.Context, domainName string) ([]string, error)

+ func (b *InMemoryBackend) ListVpcEndpoints(ctx context.Context) []*VpcEndpoint

+ func (b *InMemoryBackend) ListVpcEndpointsForDomain(ctx context.Context, domainName string) []*VpcEndpoint

+ func (b *InMemoryBackend) PurchaseReservedElasticsearchInstanceOffering(ctx context.Context, offeringID, name string, count int) (*ReservedInstance, error)

+ func (b *InMemoryBackend) Region() string

+ func (b *InMemoryBackend) RejectInboundCrossClusterSearchConnection(ctx context.Context, connectionID string) (*InboundConnection, error)

+ func (b *InMemoryBackend) RemoveTags(ctx context.Context, domainARN string, keys []string) error

+ func (b *InMemoryBackend) Reset()

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

+ func (b *InMemoryBackend) RevokeVpcEndpointAccess(ctx context.Context, domainName, account string) error

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

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

+ func (b *InMemoryBackend) StartElasticsearchServiceSoftwareUpdate(ctx context.Context, domainName string) (*Domain, error)

+ func (b *InMemoryBackend) UpdateDomainConfig(ctx context.Context, name string, cfg UpdateConfig) (*Domain, error)

+ func (b *InMemoryBackend) UpdatePackage(ctx context.Context, packageID, description string) (*Package, error)

+ func (b *InMemoryBackend) UpdateVpcEndpoint(ctx context.Context, vpcEndpointID string, vpcOptions map[string]string) (*VpcEndpoint, error)

+ func (b *InMemoryBackend) UpgradeElasticsearchDomain(ctx context.Context, domainName, targetVersion string) (*Domain, error)

+ type InboundConnection struct

+ ConnectionID string

+ ConnectionStatus string

+ DestDomainInfo CrossClusterDomainInfo

+ SourceDomainInfo CrossClusterDomainInfo

+ type OutboundConnection struct

+ ConnectionAlias string

+ ConnectionID string

+ ConnectionStatus string

+ LocalDomainInfo CrossClusterDomainInfo

+ RemoteDomainInfo CrossClusterDomainInfo

+ type Package struct

+ Description string

+ ID string

+ Name string

+ PackageType string

+ Status string

+ type Provider struct

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

+ func (p *Provider) Name() string

+ type ReservedInstance struct

+ Count int

+ Duration int

+ FixedPrice float64

+ InstanceType string

+ OfferingID string

+ ReservationID string

+ ReservationName string

+ State string

+ UsagePrice float64

+ type ReservedInstanceOffering struct

+ Currency string

+ Duration int

+ FixedPrice float64

+ InstanceType string

+ OfferingID string

+ PaymentOption string

+ UsagePrice float64

+ type SnapshotOptions struct

+ AutomatedSnapshotStartHour int

+ type UpdateConfig struct

+ AccessPolicies *string

+ AdvancedOptions map[string]string

+ ClusterConfig *ClusterConfig

+ EBSOptions *EBSOptions

+ EncryptionAtRestEnabled *bool

+ EnforceHTTPS *bool

+ NodeToNodeEncryptionEnabled *bool

+ SnapshotOptions *SnapshotOptions

+ TLSSecurityPolicy *string

+ type VpcEndpoint struct

+ AuthorizedAccts []string

+ DomainARN string

+ Endpoint string

+ ID string

+ OwnerAccountID string

+ Status string

+ VpcOptions map[string]string

+ type ZoneAwarenessConfig struct

+ AvailabilityZoneCount int

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