Documentation ¶
Index ¶
- Constants
- func CloseDatabase(t *testing.T, connection *dbr.Connection)
- func EnsureTestNetworkForDB(t *testing.T, ctx context.Context) (func(), error)
- func FixTables() map[string]string
- func InitTestDBTables(t *testing.T, connectionURL string) error
- type BrokerStorage
- type Config
- type Deprovisioning
- type Encrypter
- type Instances
- type LMSTenants
- type Operations
- type Orchestrations
- type Provisioning
- type RuntimeStates
- type UpgradeKyma
Constants ¶
View Source
const ( DbUser = "admin" DbPass = "nimda" DbName = "broker" DbPort = "5432" DockerUserNetwork = "test_network" EnvPipelineBuild = "PIPELINE_BUILD" )
Variables ¶
This section is empty.
Functions ¶
func CloseDatabase ¶
func CloseDatabase(t *testing.T, connection *dbr.Connection)
func EnsureTestNetworkForDB ¶
Types ¶
type BrokerStorage ¶
type BrokerStorage interface { Instances() Instances Operations() Operations Provisioning() Provisioning Deprovisioning() Deprovisioning LMSTenants() LMSTenants Orchestrations() Orchestrations RuntimeStates() RuntimeStates }
func NewFromConfig ¶
func NewFromConfig(cfg Config, log logrus.FieldLogger) (BrokerStorage, *dbr.Connection, error)
func NewMemoryStorage ¶
func NewMemoryStorage() BrokerStorage
type Config ¶
type Config struct { User string `envconfig:"default=postgres"` Password string `envconfig:"default=password"` Host string `envconfig:"default=localhost"` Port string `envconfig:"default=5432"` Name string `envconfig:"default=broker"` SSLMode string `envconfig:"default=disable"` SecretKey string `envconfig:"optional"` MaxOpenConns int `envconfig:"default=8"` MaxIdleConns int `envconfig:"default=2"` ConnMaxLifetime time.Duration `envconfig:"default=30m"` }
func InitTestDBContainer ¶
func (*Config) ConnectionURL ¶
type Deprovisioning ¶
type Deprovisioning interface { InsertDeprovisioningOperation(operation internal.DeprovisioningOperation) error GetDeprovisioningOperationByID(operationID string) (*internal.DeprovisioningOperation, error) GetDeprovisioningOperationByInstanceID(instanceID string) (*internal.DeprovisioningOperation, error) UpdateDeprovisioningOperation(operation internal.DeprovisioningOperation) (*internal.DeprovisioningOperation, error) }
type Encrypter ¶
type Encrypter struct {
// contains filtered or unexported fields
}
func NewEncrypter ¶
type Instances ¶
type Instances interface { FindAllJoinedWithOperations(prct ...predicate.Predicate) ([]internal.InstanceWithOperation, error) FindAllInstancesForRuntimes(runtimeIdList []string) ([]internal.Instance, error) FindAllInstancesForSubAccounts(subAccountslist []string) ([]internal.Instance, error) GetByID(instanceID string) (*internal.Instance, error) Insert(instance internal.Instance) error Update(instance internal.Instance) error Delete(instanceID string) error GetInstanceStats() (internal.InstanceStats, error) GetNumberOfInstancesForGlobalAccountID(globalAccountID string) (int, error) List(dbmodel.InstanceFilter) ([]internal.Instance, int, int, error) }
type LMSTenants ¶
type Operations ¶
type Operations interface { Provisioning Deprovisioning UpgradeKyma GetOperationByID(operationID string) (*internal.Operation, error) GetOperationsInProgressByType(operationType dbmodel.OperationType) ([]internal.Operation, error) GetOperationStats() (internal.OperationStats, error) GetOperationsForIDs(operationIDList []string) ([]internal.Operation, error) GetOperationStatsForOrchestration(orchestrationID string) (map[domain.LastOperationState]int, error) }
type Orchestrations ¶
type Orchestrations interface { Insert(orchestration internal.Orchestration) error Update(orchestration internal.Orchestration) error GetByID(orchestrationID string) (*internal.Orchestration, error) List(filter dbmodel.OrchestrationFilter) ([]internal.Orchestration, int, int, error) ListByState(state string) ([]internal.Orchestration, error) }
type Provisioning ¶
type Provisioning interface { InsertProvisioningOperation(operation internal.ProvisioningOperation) error GetProvisioningOperationByID(operationID string) (*internal.ProvisioningOperation, error) GetProvisioningOperationByInstanceID(instanceID string) (*internal.ProvisioningOperation, error) UpdateProvisioningOperation(operation internal.ProvisioningOperation) (*internal.ProvisioningOperation, error) }
type RuntimeStates ¶
type RuntimeStates interface { Insert(runtimeState internal.RuntimeState) error GetByOperationID(operationID string) (internal.RuntimeState, error) ListByRuntimeID(runtimeID string) ([]internal.RuntimeState, error) }
type UpgradeKyma ¶
type UpgradeKyma interface { InsertUpgradeKymaOperation(operation internal.UpgradeKymaOperation) error UpdateUpgradeKymaOperation(operation internal.UpgradeKymaOperation) (*internal.UpgradeKymaOperation, error) GetUpgradeKymaOperationByID(operationID string) (*internal.UpgradeKymaOperation, error) GetUpgradeKymaOperationByInstanceID(instanceID string) (*internal.UpgradeKymaOperation, error) ListUpgradeKymaOperationsByInstanceID(instanceID string) ([]internal.UpgradeKymaOperation, error) ListUpgradeKymaOperationsByOrchestrationID(orchestrationID string, filter dbmodel.OperationFilter) ([]internal.UpgradeKymaOperation, int, int, error) }
Click to show internal directories.
Click to hide internal directories.