Documentation ¶
Index ¶
- Constants
- Variables
- func GetMockCertReader() certs.OpensearchCertReader
- func OpensearchMockTransport() http.RoundTripper
- func RemoveFromSlice[T comparable](original, toRemove []T) []T
- func SetMockCertReader(r certs.OpensearchCertReader)
- type AsyncClient
- type AsyncOpensearchClient
- func (c *AsyncOpensearchClient) IsInitialized() bool
- func (c *AsyncOpensearchClient) Lock()
- func (c *AsyncOpensearchClient) SetClient(setter setterFunc)
- func (c *AsyncOpensearchClient) Unlock()
- func (c *AsyncOpensearchClient) UnsetClient()
- func (c *AsyncOpensearchClient) WaitForInit()
- func (c *AsyncOpensearchClient) WaitForInitWithTimeout(timeout time.Duration) bool
- type MockInstallState
Constants ¶
View Source
const (
OpensearchURL = "https://mock-opensearch.example.com"
)
Variables ¶
View Source
var Validate = validator.New()
Functions ¶
func GetMockCertReader ¶ added in v0.9.2
func GetMockCertReader() certs.OpensearchCertReader
func OpensearchMockTransport ¶ added in v0.9.2
func OpensearchMockTransport() http.RoundTripper
func RemoveFromSlice ¶ added in v0.12.0
func RemoveFromSlice[T comparable](original, toRemove []T) []T
func SetMockCertReader ¶ added in v0.9.2
func SetMockCertReader(r certs.OpensearchCertReader)
Types ¶
type AsyncClient ¶ added in v0.8.2
type AsyncClient[T any] struct { Client T // contains filtered or unexported fields }
func NewAsyncClient ¶ added in v0.8.2
func NewAsyncClient[T any]() *AsyncClient[T]
func (*AsyncClient[T]) BackgroundInitClient ¶ added in v0.8.2
func (c *AsyncClient[T]) BackgroundInitClient(setter func() T)
BackgroundInitClient will intialize the client only if it is curently unset. This can be called multiple times.
func (*AsyncClient[T]) IsSet ¶ added in v0.8.2
func (c *AsyncClient[T]) IsSet() bool
func (*AsyncClient[T]) SetClient ¶ added in v0.8.2
func (c *AsyncClient[T]) SetClient(client T)
SetClient will always update the client regardless of its previous confition.
func (*AsyncClient[T]) WaitForInit ¶ added in v0.8.2
func (c *AsyncClient[T]) WaitForInit()
type AsyncOpensearchClient ¶
type AsyncOpensearchClient struct { *opensearch.Client // contains filtered or unexported fields }
func NewAsyncOpensearchClient ¶
func NewAsyncOpensearchClient() *AsyncOpensearchClient
func (*AsyncOpensearchClient) IsInitialized ¶ added in v0.10.0
func (c *AsyncOpensearchClient) IsInitialized() bool
func (*AsyncOpensearchClient) Lock ¶
func (c *AsyncOpensearchClient) Lock()
func (*AsyncOpensearchClient) SetClient ¶
func (c *AsyncOpensearchClient) SetClient(setter setterFunc)
func (*AsyncOpensearchClient) Unlock ¶
func (c *AsyncOpensearchClient) Unlock()
func (*AsyncOpensearchClient) UnsetClient ¶
func (c *AsyncOpensearchClient) UnsetClient()
func (*AsyncOpensearchClient) WaitForInit ¶
func (c *AsyncOpensearchClient) WaitForInit()
func (*AsyncOpensearchClient) WaitForInitWithTimeout ¶ added in v0.9.2
func (c *AsyncOpensearchClient) WaitForInitWithTimeout(timeout time.Duration) bool
type MockInstallState ¶ added in v0.9.2
type MockInstallState struct {
// contains filtered or unexported fields
}
func (*MockInstallState) CompleteInstall ¶ added in v0.9.2
func (s *MockInstallState) CompleteInstall()
func (*MockInstallState) IsCompleted ¶ added in v0.9.2
func (s *MockInstallState) IsCompleted() bool
func (*MockInstallState) IsStarted ¶ added in v0.9.2
func (s *MockInstallState) IsStarted() bool
func (*MockInstallState) StartInstall ¶ added in v0.9.2
func (s *MockInstallState) StartInstall()
func (*MockInstallState) Uninstall ¶ added in v0.9.2
func (s *MockInstallState) Uninstall()
Click to show internal directories.
Click to hide internal directories.