opensearchbackupservice

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

type IOSS3BackupService interface {
	OSS3BackupVerify(models.S3BackupDetails, *fiber.Ctx) (models.S3BackupManagedResponse, error)
}

type IOpenSearchclient interface {
	CreateAWSClient(models.S3BackupDetails, string) (*elastic.Client, error)
}

type IOpensearchOperations interface {
	CreateTestIndex(*elastic.Client, *fiber.Ctx, string) (bool, error)
	CreateSnapshotRepo(*elastic.Client, *fiber.Ctx, SnapshotRepoRequestS3, string) (bool, error)
	CreateSnapshot(*elastic.Client, *fiber.Ctx, string, string, string) (bool, error)
	GetSnapshotStatus(*elastic.Client, *fiber.Ctx, string, string) (string, error)
	DeleteTestSnapshot(*elastic.Client, *fiber.Ctx, string, string) (bool, error)
	DeleteTestSnapshotRepo(*elastic.Client, *fiber.Ctx, string) (bool, error)
	DeleteTestIndex(*elastic.Client, *fiber.Ctx, string) (bool, error)
}

type MockOSOperations struct {
	CreateTestIndexFunc        func(*elastic.Client, *fiber.Ctx, string) (bool, error)
	CreateSnapshotRepoFunc     func(*elastic.Client, *fiber.Ctx, SnapshotRepoRequestS3, string) (bool, error)
	CreateSnapshotFunc         func(*elastic.Client, *fiber.Ctx, string, string, string) (bool, error)
	GetSnapshotStatusFunc      func(*elastic.Client, *fiber.Ctx, string, string) (string, error)
	DeleteTestSnapshotFunc     func(*elastic.Client, *fiber.Ctx, string, string) (bool, error)
	DeleteTestSnapshotRepoFunc func(*elastic.Client, *fiber.Ctx, string) (bool, error)
	DeleteTestIndexFunc        func(*elastic.Client, *fiber.Ctx, string) (bool, error)
}

type MockOSS3BackupService struct {
	OSS3BackupVerifyFunc func(models.S3BackupDetails, *fiber.Ctx) (models.S3BackupManagedResponse, error)
}

type MockOpensearchClient struct {
	CreateAWSClientFunc func(models.S3BackupDetails, string) (*elastic.Client, error)
}

type OSS3BackupService struct {
	OSClient     IOpenSearchclient
	OSOperations IOpensearchOperations
	Log          logger.Logger
}

type OpenSearchclient struct{}

type OpensearchOperations struct {
	Log logger.Logger
}

type SnapshotRepoRequest struct {
	Type     string                 `json:"type"`
	Settings map[string]interface{} `json:"settings"`
}

type SnapshotRepoRequestS3 struct {
	Bucket   string
	BasePath string
	RoleArn  string
	Region   string
}

type SnapshotRequest struct {
	Indices           string `json:"indices"`
	IgnoreUnavailable bool   `json:"ignore_unavailable"`
	AllowNoIndices    bool   `json:"allow_no_indices"`
}

type SnapshotStatus struct {
	Snapshots []snapshotStatus `json:"snapshots"`
}

type TestMockFunc struct {
	TestCase bool
	Err      error
}