util

package

v0.0.0-...-21b7018 Latest Latest Go to latest Published: Jun 25, 2025 License: Apache-2.0 Imports: 12 Imported by: 0

Details

View Source

const (
	SwitchoverAnnotationKey = "switchoverRetry"
	RetryFailedComment      = "retry failed"
)

This section is empty.

func ArrayContains(slice []int32, searchElement int32) bool

func FilterSlice(slice []string, f func(string) bool) []string

func GetIntEnvironmentVariable(varName string, defaultValue int) (int, error)

func Hash(o interface{}) (string, error)

Hash returns hash SHA-256 of object

func Min(a, b int32) int32

type Credentials struct {
	Username string
	Password string
}

func NewCredentials(username, password string) Credentials

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

func NewRestClient(url string, httpClient http.Client, credentials Credentials) *RestClient

func (rc RestClient) GetArrayData(path, key string, filter func(string) bool) ([]string, error)

func (rc RestClient) SendBasicRequest(method string, path string, body io.Reader, useHeaders bool) (statusCode int, responseBody []byte, err error)

func (rc RestClient) SendRequest(method string, path string, body io.Reader) (int, []byte, error)

func (rc RestClient) SendRequestWithStatusCodeCheck(method string, path string, body io.Reader) ([]byte, error)

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

func NewStatusUpdater(client client.Client, cr *opensearchservice.OpenSearchService) StatusUpdater

func (su StatusUpdater) UpdateStatusWithRetry(statusUpdateFunc func(*opensearchservice.OpenSearchService)) error