es

package
v1.10.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 4, 2026 License: MIT Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Domain 

type Domain struct {
	DomainName           string
	ARN                  string
	DomainId             string
	ElasticsearchVersion string
	Endpoint             string
	Processing           bool
	Created              bool
	Deleted              bool
	InstanceType         string
	InstanceCount        int
	Tags                 map[string]string
	CreatedTime          time.Time
	Lifecycle            *lifecycle.Machine
}

Domain represents an Elasticsearch domain.

type ESDocument 

type ESDocument struct {
	ID     string
	Index  string
	Source map[string]any
}

ESDocument represents an indexed document.

type ESService 

type ESService struct {
	// contains filtered or unexported fields
}

ESService is the cloudmock implementation of the AWS Elasticsearch Service API.

func New 

func New(accountID, region string) *ESService

New returns a new ESService.

func (*ESService) Actions 

func (s *ESService) Actions() []service.Action

Actions returns the list of API actions supported.

func (*ESService) HandleRequest 

func (s *ESService) HandleRequest(ctx *service.RequestContext) (*service.Response, error)

HandleRequest routes an incoming request to the appropriate handler.

func (*ESService) HealthCheck 

func (s *ESService) HealthCheck() error

HealthCheck always returns nil.

func (*ESService) Name 

func (s *ESService) Name() string

Name returns the AWS service name used for routing.

type Store 

type Store struct {
	// contains filtered or unexported fields
}

Store manages all Elasticsearch resources.

func NewStore 

func NewStore(accountID, region string) *Store

NewStore creates a new Elasticsearch store.

func (*Store) AddTags 

func (s *Store) AddTags(arn string, tags map[string]string) bool

func (*Store) ClusterHealth 

func (s *Store) ClusterHealth(domainName string) (string, bool)

func (*Store) CreateDomain 

func (s *Store) CreateDomain(name, version, instanceType string, instanceCount int, tags map[string]string) (*Domain, bool)

func (*Store) DeleteDomain 

func (s *Store) DeleteDomain(name string) (*Domain, bool)

func (*Store) GetDomain 

func (s *Store) GetDomain(name string) (*Domain, bool)

func (*Store) IndexDocument 

func (s *Store) IndexDocument(domainName, index, docID string, source map[string]any) (string, bool)

func (*Store) ListDomainNames 

func (s *Store) ListDomainNames() []*Domain

func (*Store) ListTags 

func (s *Store) ListTags(arn string) (map[string]string, bool)

func (*Store) RemoveTags 

func (s *Store) RemoveTags(arn string, keys []string) bool

func (*Store) SearchDocuments 

func (s *Store) SearchDocuments(domainName, index string, query map[string]any) ([]ESDocument, bool)

func (*Store) UpdateDomainConfig 

func (s *Store) UpdateDomainConfig(name, version, instanceType string, instanceCount int) (*Domain, bool)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.