test

Documentation

Index

• type MockBackendDriver
  • func NewMockBackendDriver(stateTracker *util.MockInstallState) *MockBackendDriver
  • func (d *MockBackendDriver) DeleteCluster(_ context.Context, id string) error
  • func (d *MockBackendDriver) GetClusterStatus(_ context.Context, id string) (*capabilityv1.NodeCapabilityStatus, error)
  • func (d *MockBackendDriver) GetInstallStatus(_ context.Context) backenddriver.InstallState
  • func (d *MockBackendDriver) Name() string
  • func (d *MockBackendDriver) SetClusterStatus(_ context.Context, id string, enabled bool) error
  • func (d *MockBackendDriver) SetSyncTime()
  • func (d *MockBackendDriver) StoreCluster(_ context.Context, req *corev1.Reference, friendlyName string) error
  • func (d *MockBackendDriver) StoreClusterMetadata(_ context.Context, id, name string) error
  • func (d *MockBackendDriver) StoreClusterReadUser(_ context.Context, _, _, _ string) error
• type MockManagementDriver
  • func NewMockManagementDriver(stateTracker *util.MockInstallState) *MockManagementDriver
  • func (d *MockManagementDriver) AdminPassword(_ context.Context) ([]byte, error)
  • func (d *MockManagementDriver) CreateOrUpdateCluster(_ context.Context, cluster *loggingadmin.OpensearchClusterV2, _ string, ...) error
  • func (d *MockManagementDriver) CreateOrUpdateSnapshotSchedule(_ context.Context, snapshot *loggingadmin.SnapshotSchedule, _ []string) error
  • func (d *MockManagementDriver) DeleteCluster(_ context.Context) error
  • func (d *MockManagementDriver) DeleteSnapshotSchedule(_ context.Context, ref *loggingadmin.SnapshotReference) error
  • func (d *MockManagementDriver) DoUpgrade(_ context.Context, _ string) error
  • func (d *MockManagementDriver) GetCluster(_ context.Context) (*loggingadmin.OpensearchClusterV2, error)
  • func (d *MockManagementDriver) GetSnapshotSchedule(_ context.Context, ref *loggingadmin.SnapshotReference, _ []string) (*loggingadmin.SnapshotSchedule, error)
  • func (d *MockManagementDriver) GetStorageClasses(context.Context) ([]string, error)
  • func (d *MockManagementDriver) ListAllSnapshotSchedules(_ context.Context) (*loggingadmin.SnapshotStatusList, error)
  • func (d *MockManagementDriver) NewOpensearchClientForCluster(context.Context) *opensearch.Client
  • func (d *MockManagementDriver) UpgradeAvailable(_ context.Context, _ string) (bool, error)

Types

type MockBackendDriver

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

func NewMockBackendDriver

func NewMockBackendDriver(stateTracker *util.MockInstallState) *MockBackendDriver

func (*MockBackendDriver) DeleteCluster

func (d *MockBackendDriver) DeleteCluster(_ context.Context, id string) error

func (*MockBackendDriver) GetClusterStatus

func (d *MockBackendDriver) GetClusterStatus(_ context.Context, id string) (*capabilityv1.NodeCapabilityStatus, error)

func (*MockBackendDriver) GetInstallStatus

func (d *MockBackendDriver) GetInstallStatus(_ context.Context) backenddriver.InstallState

func (*MockBackendDriver) Name

func (d *MockBackendDriver) Name() string

func (*MockBackendDriver) SetClusterStatus

func (d *MockBackendDriver) SetClusterStatus(_ context.Context, id string, enabled bool) error

func (*MockBackendDriver) SetSyncTime

func (d *MockBackendDriver) SetSyncTime()

func (*MockBackendDriver) StoreCluster

func (d *MockBackendDriver) StoreCluster(_ context.Context, req *corev1.Reference, friendlyName string) error

func (*MockBackendDriver) StoreClusterMetadata

func (d *MockBackendDriver) StoreClusterMetadata(_ context.Context, id, name string) error

func (*MockBackendDriver) StoreClusterReadUser

func (d *MockBackendDriver) StoreClusterReadUser(_ context.Context, _, _, _ string) error

type MockManagementDriver

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

func NewMockManagementDriver

func NewMockManagementDriver(stateTracker *util.MockInstallState) *MockManagementDriver

func (*MockManagementDriver) AdminPassword

func (d *MockManagementDriver) AdminPassword(_ context.Context) ([]byte, error)

func (*MockManagementDriver) CreateOrUpdateCluster

func (d *MockManagementDriver) CreateOrUpdateCluster(
	_ context.Context,
	cluster *loggingadmin.OpensearchClusterV2,
	_ string,
	_ string,
) error

func (*MockManagementDriver) CreateOrUpdateSnapshotSchedule

func (d *MockManagementDriver) CreateOrUpdateSnapshotSchedule(_ context.Context, snapshot *loggingadmin.SnapshotSchedule, _ []string) error

func (*MockManagementDriver) DeleteCluster

func (d *MockManagementDriver) DeleteCluster(_ context.Context) error

func (*MockManagementDriver) DeleteSnapshotSchedule

func (d *MockManagementDriver) DeleteSnapshotSchedule(_ context.Context, ref *loggingadmin.SnapshotReference) error

func (*MockManagementDriver) DoUpgrade

func (d *MockManagementDriver) DoUpgrade(_ context.Context, _ string) error

func (*MockManagementDriver) GetCluster

func (d *MockManagementDriver) GetCluster(_ context.Context) (*loggingadmin.OpensearchClusterV2, error)

func (*MockManagementDriver) GetSnapshotSchedule

func (d *MockManagementDriver) GetSnapshotSchedule(
	_ context.Context,
	ref *loggingadmin.SnapshotReference,
	_ []string,
) (*loggingadmin.SnapshotSchedule, error)

func (*MockManagementDriver) GetStorageClasses

func (d *MockManagementDriver) GetStorageClasses(context.Context) ([]string, error)

func (*MockManagementDriver) ListAllSnapshotSchedules

func (d *MockManagementDriver) ListAllSnapshotSchedules(_ context.Context) (*loggingadmin.SnapshotStatusList, error)

func (*MockManagementDriver) NewOpensearchClientForCluster

func (d *MockManagementDriver) NewOpensearchClientForCluster(context.Context) *opensearch.Client

func (*MockManagementDriver) UpgradeAvailable

func (d *MockManagementDriver) UpgradeAvailable(_ context.Context, _ string) (bool, error)