testutils

package

Go to main page

Versions in this module

v0

v0.7.0

Apr 9, 2026

Changes in this version

+ func SetupTestBinary(tb testing.TB, statusServer string, f func() error)

+ func WaitForServer(tb testing.TB, statusServer string)

v0.6.1

Mar 19, 2026

v0.6.0

Mar 18, 2026

v0.5.0

Mar 16, 2026

Changes in this version

+ const RepoResourceTypeTest

+ const TestAdminRole

+ const TestBlockedRole

+ const TestReadAllowedRole

+ const TestTenantCertCommonName

+ const TestWriteAllowedRole

+ var RepoActionResourceTypes map[authz.RepoAction]authz.RepoResourceTypeName

+ var RepoPolicyData = repoPolicies

+ var RepoResourceTypeActions = map[authz.RepoResourceTypeName][]authz.RepoAction

+ var RepoRolePolicies = make(map[constants.Role][]...)

+ func NewRepoAuthzLoader(ctx context.Context, r repo.Repo, config *config.Config) *authz_loader.AuthzLoader[authz.RepoResourceTypeName, authz.RepoAction]

+ func NewTestPlugins(plugins ...plugincatalog.BuiltInPlugin) ([]plugincatalog.BuiltInPlugin, []plugincatalog.PluginConfig)

type OrbitalJob

+ func (OrbitalJob) CheckAuthz(ctx context.Context, ...) (bool, error)

+ type PluginConfig struct

+ Tags []string

+ YamlConfiguration string

type TestModel

+ func (TestModel) TableResourceType() authz.RepoResourceTypeName

+ func (m TestModel) CheckAuthz(ctx context.Context, ...) (bool, error)

v0.4.1

Mar 6, 2026

v0.4.0

Mar 6, 2026

Changes in this version

+ func NewEvent(m func(*model.Event)) *model.Event

type TestModel

+ Data json.RawMessage

v0.3.0

Feb 23, 2026

Changes in this version

+ func GetAuthClientMap(ctx context.Context, tb testing.TB, r repo.Repo, opts ...AuthClientOpt) map[any]any

+ func GetClientMap(identifier string, groupNames []string) map[any]any

+ func GetGrouplessClientMap() map[any]any

+ func GetInvalidClientMap(opts ...ClientMapOpt) map[any]any

+ func NewDefaultWorkflowConfig(enabled bool) *model.WorkflowConfig

+ type AuthClientData struct

+ Group *model.Group

+ GroupID string

+ Identifier string

+ func NewAuthClient(ctx context.Context, tb testing.TB, r repo.Repo, opts ...AuthClientOpt) AuthClientData

+ func (cd AuthClientData) GetClientMap(opts ...ClientMapOpt) map[any]any

+ type AuthClientOpt func(*AuthClientData)

+ func WithAuditorRole() AuthClientOpt

+ func WithIdentifier(identifier string) AuthClientOpt

+ func WithKeyAdminRole() AuthClientOpt

+ func WithTenantAdminRole() AuthClientOpt

+ type ClientMapOpt func(*auth.ClientData)

+ func WithAdditionalGroup(groupName string) ClientMapOpt

+ func WithOverriddenGroup(numGroups int) ClientMapOpt

+ func WithOverriddenIdentifier(identifier string) ClientMapOpt

+ type KeyConfigOpt func(*model.KeyConfiguration)

+ func WithAuthClientDataKC(authClient AuthClientData) KeyConfigOpt

type TestDBConfig

+ TenantRole model.TenantRole

type TestDBConfigOpt

+ func WithTenantRole(role model.TenantRole) TestDBConfigOpt

v0.2.1

Feb 5, 2026

v0.2.0

Feb 4, 2026

v0.1.2

Feb 4, 2026

v0.1.1

Feb 4, 2026

v0.1.0

Feb 4, 2026

Changes in this version

+ const DaysToExpiration

+ const DefaultThrottleInterval

+ const MaxPSQLSchemaName

+ const TestCertURL

+ const TestDefaultKeystoreCommonName

+ const TestHostPrefix

+ const TestLocalityID

+ const TestProfileArn

+ const TestRoleArn

+ const TestTenant

+ const TestTrustAnchorArn

+ var CertIssuer = MockPlugin

+ var ErrFailedConversion = errors.New("failed to convert to TCPAddr")

+ var ErrRegisterFailed = errors.New("failed to register callback")

+ var ErrUnregisterFailed = errors.New("failed to unregister callback")

+ var IdentityManagementGroupMembership = map[string][]IdentityManagementUserRef

+ var IdentityManagementGroups = map[string]string

+ var IdentityPlugin = MockPlugin

+ var KeyStorePlugin = MockPlugin

+ var KeystoreProviderPlugin = MockPlugin

+ var Notification = MockPlugin

+ var SupportedRegions = []config.Region

+ var SupportedRegionsMap = RegionsToMapSlice(SupportedRegions)

+ var SystemInfo = MockPlugin

+ var TestBaseConfig = commoncfg.BaseConfig

+ var TestDB = config.Database

+ var TestModelName = "test_models"

+ var TestRegistryConfig = &commoncfg.GRPCClient

+ var TestSessionManagerConfig = &commoncfg.GRPCClient

+ var ValidKeystoreAccountInfo = map[string]string

+ func CreateCACertificatePEM(t *testing.T) []byte

+ func CreateCertificateChain(t *testing.T, subject pkix.Name, pkey *rsa.PrivateKey) string

+ func CreateCertificatePEM(t *testing.T, csr *x509.CertificateRequest, pkey *rsa.PrivateKey) []byte

+ func CreateCtxWithTenant(tenant string) context.Context

+ func CreateDBTenant(tb testing.TB, dbCon *multitenancy.DB, tenant *model.Tenant)

+ func CreateTestEntities(ctx context.Context, tb testing.TB, r repo.Repo, entities ...repo.Resource)

+ func DeleteTestEntities(ctx context.Context, tb testing.TB, r repo.Repo, entities ...repo.Resource)

+ func GetFreePort() (int, error)

+ func GetFreePortString() (string, error)

+ func GetJSONBody[t any](tb testing.TB, w *httptest.ResponseRecorder) t

+ func GetPluginDir(dir string) string

+ func GetTestURL(tb testing.TB, tenant, path string) string

+ func InjectClientDataIntoContext(ctx context.Context, identifier string, groups []string) context.Context

+ func MakeHTTPRequest(tb testing.TB, server cmkapi.ServeMux, opt RequestOptions) *httptest.ResponseRecorder

+ func NewAMQPClient(tb testing.TB, amqpCfg AMQPCfg) (*amqp.Client, config.AMQP)

+ func NewAPIServer(tb testing.TB, dbCon *multitenancy.DB, testCfg TestAPIServerConfig) cmkapi.ServeMux

+ func NewCertificate(m func(*model.Certificate)) *model.Certificate

+ func NewGRPCSuite(tb testing.TB, registrars ...ServiceRegistrar) (*grpc.Server, *commongrpc.DynamicClientConn)

+ func NewGroup(m func(*model.Group)) *model.Group

+ func NewHTTPRequest(tb testing.TB, opt RequestOptions) *http.Request

+ func NewImportParams(m func(*model.ImportParams)) *model.ImportParams

+ func NewIsolatedDB(tb testing.TB, cfg config.Database) config.Database

+ func NewKey(m func(*model.Key)) *model.Key

+ func NewKeyConfig(m func(*model.KeyConfiguration)) *model.KeyConfiguration

+ func NewKeyLabel(m func(l *model.KeyLabel)) *model.KeyLabel

+ func NewKeyVersion(m func(*model.KeyVersion)) *model.KeyVersion

+ func NewKeystore(m func(*model.Keystore)) *model.Keystore

+ func NewKeystoreConfig(m func(*model.KeystoreConfig)) *model.KeystoreConfig

+ func NewMigrator() db.Migrator

+ func NewMutator[T any](baseProv func() T) func(mutatorFn ...func(*T)) T

+ func NewSystem(m func(*model.System)) *model.System

+ func NewTag(m func(*model.Tag)) *model.Tag

+ func NewTenant(m func(t *model.Tenant)) *model.Tenant

+ func NewTestDB(tb testing.TB, cfg TestDBConfig, opts ...TestDBConfigOpt) (*multitenancy.DB, []string, config.Database)

+ func NewUserManager() manager.User

+ func NewWorkflow(m func(*model.Workflow)) *model.Workflow

+ func NewWorkflowApprover(m func(approver *model.WorkflowApprover)) *model.WorkflowApprover

+ func NewWorkflowConfig(m func(m *model.TenantConfig)) *model.TenantConfig

+ func RegionsToMapSlice(regions []config.Region) []map[string]string

+ func RunTestQuery(db *multitenancy.DB, tenant string, queries ...string)

+ func SetupLoggerWithBuffer() *slog.Logger

+ func SetupMockPlugins(mocks ...MockPlugin) []plugincatalog.PluginConfig

+ func StartPostgresSQL(tb testing.TB, cfg *config.Database, ...)

+ func StartRabbitMQ(tb testing.TB, opts ...testcontainers.ContainerCustomizer) string

+ func StartRedis(tb testing.TB, cfg *config.Scheduler, ...)

+ func WithJSON(tb testing.TB, i any) io.Reader

+ func WithString(tb testing.TB, i any) io.Reader

+ func WithTenantID(ctx context.Context, db *multitenancy.DB, tenantID string, ...) error

+ type AMQPCfg struct

+ Source string

+ Target string

+ type CryptoCert struct

+ RootCA string

+ Subject string

+ type ErrorForced struct

+ func NewDBErrorForced(db *multitenancy.DB, forcedErr error) *ErrorForced

+ func (e *ErrorForced) Register()

+ func (e *ErrorForced) Unregister()

+ func (e *ErrorForced) WithCreate() *ErrorForced

+ func (e *ErrorForced) WithDelete() *ErrorForced

+ func (e *ErrorForced) WithQuery() *ErrorForced

+ func (e *ErrorForced) WithRaw() *ErrorForced

+ func (e *ErrorForced) WithRow() *ErrorForced

+ func (e *ErrorForced) WithUpdate() *ErrorForced

+ type IdentityManagementUserRef struct

+ Email string

+ ID string

+ type MockPlugin struct

+ type OrbitalJob struct

+ CreatedAt int64

+ Data []byte

+ ErrorMessage string

+ ExternalID string

+ ID uuid.UUID

+ Status string

+ Type string

+ UpdatedAt int64

+ func (OrbitalJob) IsSharedModel() bool

+ func (OrbitalJob) TableName() string

+ type RequestOptions struct

+ AdditionalContext map[any]any

+ Body io.Reader

+ Endpoint string

+ Headers map[string]string

+ Method string

+ Tenant string

+ type ServiceRegistrar func(*grpc.Server)

+ type TLSFiles struct

+ ClientCertPath string

+ ClientKeyPath string

+ Dir string

+ RootCACertPath string

+ RootCAKeyPath string

+ ServerCertPath string

+ ServerKeyPath string

+ func CreateTLSFiles(t *testing.T) TLSFiles

+ type TestAPIServerConfig struct

+ Config config.Config

+ GRPCCon *commongrpc.DynamicClientConn

+ Plugins []MockPlugin

+ type TestDBConfig struct

+ CreateDatabase bool

+ Logger logger.Interface

+ SharedVersion *int64

+ TenantVersion *int64

+ WithIsolatedService bool

+ WithOrbital bool

+ type TestDBConfigOpt func(*TestDBConfig)

+ func WithGenerateTenants(count int) TestDBConfigOpt

+ func WithInitTenants(tenants ...model.Tenant) TestDBConfigOpt

+ type TestMockAMQPOperator struct

+ func NewMockAMQPOperator(t *testing.T, numReconcile int, success bool, connConfig amqp.ConnectionInfo, ...) *TestMockAMQPOperator

+ func (o *TestMockAMQPOperator) Reset()

+ func (o *TestMockAMQPOperator) Start(ctx context.Context)

+ func (o *TestMockAMQPOperator) Stop(ctx context.Context)

+ type TestModel struct

+ CreatedAt time.Time

+ Description string

+ ID uuid.UUID

+ Name string

+ UpdatedAt time.Time

+ func (TestModel) IsSharedModel() bool

+ func (TestModel) TableName() string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL