testing

package
v2.0.0-beta.9 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 23, 2020 License: MIT Imports: 31 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AddDashboardCell

func AddDashboardCell(
	init func(DashboardFields, *testing.T) (platform.DashboardService, string, func()),
	t *testing.T,
)

AddDashboardCell testing

func AddLogEntry

func AddLogEntry(
	init func(KeyValueLogFields, *testing.T) (platform.KeyValueLog, func()),
	t *testing.T,
)

AddLogEntry tests the AddLogEntry for the KeyValueLog contract

func AddTarget

func AddTarget(
	init func(TargetFields, *testing.T) (influxdb.ScraperTargetStoreService, string, func()),
	t *testing.T,
)

AddTarget testing.

func AuthorizationService

func AuthorizationService(
	init func(AuthorizationFields, *testing.T) (platform.AuthorizationService, string, func()), t *testing.T,
)

AuthorizationService tests all the service functions.

func BenchmarkIndexWalk

func BenchmarkIndexWalk(b *testing.B, store kv.Store, resourceCount, fetchCount int)

func BucketService

func BucketService(
	init func(BucketFields, *testing.T) (influxdb.BucketService, string, func()),
	t *testing.T,
	opts ...BucketSvcOpts)

BucketService tests all the service functions.

func CheckService

func CheckService(
	init func(CheckFields, *testing.T) (influxdb.CheckService, string, func()),
	t *testing.T,
)

CheckService tests all the service functions.

func CleanupDBRPMappings

func CleanupDBRPMappings(ctx context.Context, s platform.DBRPMappingService) error

CleanupDBRPMappings finds and removes all dbrp mappings

func CompareAndSetPassword

func CompareAndSetPassword(
	init func(PasswordFields, *testing.T) (influxdb.PasswordsService, func()),
	t *testing.T)

CompareAndSetPassword tests implementations of PasswordsService.

func ComparePassword

func ComparePassword(
	init func(PasswordFields, *testing.T) (influxdb.PasswordsService, func()),
	t *testing.T)

ComparePassword tests setting and comparing passwords.

func Create

func Create(t *testing.T, init func(*testing.T, TenantFields) (influxdb.TenantService, func()))

Create tests various cases of creation for the services in the TenantService. For example, when you create a user, do you create system buckets? How are URMs organized?

func CreateAuthorization

func CreateAuthorization(
	init func(AuthorizationFields, *testing.T) (platform.AuthorizationService, string, func()),
	t *testing.T,
)

CreateAuthorization testing

func CreateBucket

func CreateBucket(
	init func(BucketFields, *testing.T) (influxdb.BucketService, string, func()),
	t *testing.T,
)

CreateBucket testing

func CreateCheck

func CreateCheck(
	init func(CheckFields, *testing.T) (influxdb.CheckService, string, func()),
	t *testing.T,
)

CreateCheck testing

func CreateDBRPMapping

func CreateDBRPMapping(
	init func(DBRPMappingFields, *testing.T) (platform.DBRPMappingService, func()),
	t *testing.T,
)

CreateDBRPMapping testing

func CreateDashboard

func CreateDashboard(
	init func(DashboardFields, *testing.T) (platform.DashboardService, string, func()),
	t *testing.T,
)

CreateDashboard testing

func CreateLabel

func CreateLabel(
	init func(LabelFields, *testing.T) (influxdb.LabelService, string, func()),
	t *testing.T,
)

func CreateLabelMapping

func CreateLabelMapping(
	init func(LabelFields, *testing.T) (influxdb.LabelService, string, func()),
	t *testing.T,
)

func CreateNotificationEndpoint

func CreateNotificationEndpoint(
	init func(NotificationEndpointFields, *testing.T) (influxdb.NotificationEndpointService, influxdb.SecretService, func()),
	t *testing.T,
)

CreateNotificationEndpoint testing.

func CreateNotificationRule

func CreateNotificationRule(
	init func(NotificationRuleFields, *testing.T) (influxdb.NotificationRuleStore, func()),
	t *testing.T,
)

CreateNotificationRule testing.

func CreateOrganization

func CreateOrganization(
	init func(OrganizationFields, *testing.T) (influxdb.OrganizationService, string, func()),
	t *testing.T,
)

CreateOrganization testing

func CreateSession

func CreateSession(
	init func(SessionFields, *testing.T) (platform.SessionService, string, func()),
	t *testing.T,
)

CreateSession testing

func CreateSource

func CreateSource(
	init func(SourceFields, *testing.T) (platform.SourceService, string, func()),
	t *testing.T,
)

CreateSource testing

func CreateTelegrafConfig

func CreateTelegrafConfig(
	init func(TelegrafConfigFields, *testing.T) (platform.TelegrafConfigStore, func()),
	t *testing.T,
)

CreateTelegrafConfig testing.

func CreateUser

func CreateUser(
	init func(UserFields, *testing.T) (platform.UserService, string, func()),
	t *testing.T,
)

CreateUser testing

func CreateUserResourceMapping

func CreateUserResourceMapping(
	init func(UserResourceFields, *testing.T) (platform.UserResourceMappingService, func()),
	t *testing.T,
)

func CreateVariable

func CreateVariable(init func(VariableFields, *testing.T) (platform.VariableService, string, func()), t *testing.T)

CreateVariable tests platform.VariableService CreateVariable interface method

func DashboardService

func DashboardService(
	init func(DashboardFields, *testing.T) (platform.DashboardService, string, func()), t *testing.T,
)

DashboardService tests all the service functions.

func Delete

func Delete(t *testing.T, init func(*testing.T, TenantFields) (influxdb.TenantService, func()))

Delete tests various cases of deletion for the services in the TenantService. An example: if you delete a bucket the corresponding user resource mapping is not present.

func DeleteAuthorization

func DeleteAuthorization(
	init func(AuthorizationFields, *testing.T) (platform.AuthorizationService, string, func()),
	t *testing.T,
)

DeleteAuthorization testing

func DeleteBucket

func DeleteBucket(
	init func(BucketFields, *testing.T) (influxdb.BucketService, string, func()),
	t *testing.T,
)

DeleteBucket testing

func DeleteCheck

func DeleteCheck(
	init func(CheckFields, *testing.T) (influxdb.CheckService, string, func()),
	t *testing.T,
)

DeleteCheck testing

func DeleteDBRPMapping

func DeleteDBRPMapping(
	init func(DBRPMappingFields, *testing.T) (platform.DBRPMappingService, func()),
	t *testing.T,
)

DeleteDBRPMapping testing

func DeleteDashboard

func DeleteDashboard(
	init func(DashboardFields, *testing.T) (platform.DashboardService, string, func()),
	t *testing.T,
)

DeleteDashboard testing

func DeleteLabel

func DeleteLabel(
	init func(LabelFields, *testing.T) (influxdb.LabelService, string, func()),
	t *testing.T,
)

func DeleteLabelMapping

func DeleteLabelMapping(
	init func(LabelFields, *testing.T) (influxdb.LabelService, string, func()),
	t *testing.T,
)

func DeleteNotificationEndpoint

func DeleteNotificationEndpoint(
	init func(NotificationEndpointFields, *testing.T) (influxdb.NotificationEndpointService, influxdb.SecretService, func()),
	t *testing.T,
)

DeleteNotificationEndpoint testing.

func DeleteNotificationRule

func DeleteNotificationRule(
	init func(NotificationRuleFields, *testing.T) (influxdb.NotificationRuleStore, func()),
	t *testing.T,
)

DeleteNotificationRule testing.

func DeleteOrganization

func DeleteOrganization(
	init func(OrganizationFields, *testing.T) (influxdb.OrganizationService, string, func()),
	t *testing.T,
)

DeleteOrganization testing

func DeleteSecrets

func DeleteSecrets(
	init func(f SecretServiceFields, t *testing.T) (platform.SecretService, func()),
	t *testing.T,
)

DeleteSecrets tests the DeleteSecrets method for the SecretService interface.

func DeleteSource

func DeleteSource(
	init func(SourceFields, *testing.T) (platform.SourceService, string, func()),
	t *testing.T,
)

DeleteSource testing

func DeleteTelegrafConfig

func DeleteTelegrafConfig(
	init func(TelegrafConfigFields, *testing.T) (platform.TelegrafConfigStore, func()),
	t *testing.T,
)

DeleteTelegrafConfig testing.

func DeleteUser

func DeleteUser(
	init func(UserFields, *testing.T) (platform.UserService, string, func()),
	t *testing.T,
)

DeleteUser testing

func DeleteUserResourceMapping

func DeleteUserResourceMapping(
	init func(UserResourceFields, *testing.T) (platform.UserResourceMappingService, func()),
	t *testing.T,
)

func DeleteVariable

func DeleteVariable(init func(VariableFields, *testing.T) (platform.VariableService, string, func()), t *testing.T)

DeleteVariable tests platform.VariableService DeleteVariable interface method

func ErrorsEqual

func ErrorsEqual(t *testing.T, actual, expected error)

ErrorsEqual checks to see if the provided errors are equivalent.

func ExpireSession

func ExpireSession(
	init func(SessionFields, *testing.T) (platform.SessionService, string, func()),
	t *testing.T,
)

ExpireSession testing

func FindAuthorizationByID

func FindAuthorizationByID(
	init func(AuthorizationFields, *testing.T) (platform.AuthorizationService, string, func()),
	t *testing.T,
)

FindAuthorizationByID testing

func FindAuthorizationByToken

func FindAuthorizationByToken(
	init func(AuthorizationFields, *testing.T) (platform.AuthorizationService, string, func()),
	t *testing.T,
)

FindAuthorizationByToken testing

func FindAuthorizations

func FindAuthorizations(
	init func(AuthorizationFields, *testing.T) (platform.AuthorizationService, string, func()),
	t *testing.T,
)

FindAuthorizations testing

func FindBucket

func FindBucket(
	init func(BucketFields, *testing.T) (influxdb.BucketService, string, func()),
	t *testing.T,
)

FindBucket testing

func FindBucketByID

func FindBucketByID(
	init func(BucketFields, *testing.T) (influxdb.BucketService, string, func()),
	t *testing.T,
)

FindBucketByID testing

func FindBuckets

func FindBuckets(
	init func(BucketFields, *testing.T) (influxdb.BucketService, string, func()),
	t *testing.T,
)

FindBuckets testing

func FindCheck

func FindCheck(
	init func(CheckFields, *testing.T) (influxdb.CheckService, string, func()),
	t *testing.T,
)

FindCheck testing

func FindCheckByID

func FindCheckByID(
	init func(CheckFields, *testing.T) (influxdb.CheckService, string, func()),
	t *testing.T,
)

FindCheckByID testing

func FindChecks

func FindChecks(
	init func(CheckFields, *testing.T) (influxdb.CheckService, string, func()),
	t *testing.T,
)

FindChecks testing

func FindDBRPMapping

func FindDBRPMapping(
	init func(DBRPMappingFields, *testing.T) (platform.DBRPMappingService, func()),
	t *testing.T,
)

FindDBRPMapping testing

func FindDBRPMappingByKey

func FindDBRPMappingByKey(
	init func(DBRPMappingFields, *testing.T) (platform.DBRPMappingService, func()),
	t *testing.T,
)

FindDBRPMappingByKey testing

func FindDBRPMappings

func FindDBRPMappings(
	init func(DBRPMappingFields, *testing.T) (platform.DBRPMappingService, func()),
	t *testing.T,
)

FindDBRPMappings testing

func FindDashboardByID

func FindDashboardByID(
	init func(DashboardFields, *testing.T) (platform.DashboardService, string, func()),
	t *testing.T,
)

FindDashboardByID testing

func FindDashboards

func FindDashboards(
	init func(DashboardFields, *testing.T) (platform.DashboardService, string, func()),
	t *testing.T,
)

FindDashboards testing

func FindLabelByID

func FindLabelByID(
	init func(LabelFields, *testing.T) (influxdb.LabelService, string, func()),
	t *testing.T,
)

func FindLabels

func FindLabels(
	init func(LabelFields, *testing.T) (influxdb.LabelService, string, func()),
	t *testing.T,
)

func FindNotificationEndpointByID

func FindNotificationEndpointByID(
	init func(NotificationEndpointFields, *testing.T) (influxdb.NotificationEndpointService, influxdb.SecretService, func()),
	t *testing.T,
)

FindNotificationEndpointByID testing.

func FindNotificationEndpoints

func FindNotificationEndpoints(
	init func(NotificationEndpointFields, *testing.T) (influxdb.NotificationEndpointService, influxdb.SecretService, func()),
	t *testing.T,
)

FindNotificationEndpoints testing

func FindNotificationRuleByID

func FindNotificationRuleByID(
	init func(NotificationRuleFields, *testing.T) (influxdb.NotificationRuleStore, func()),
	t *testing.T,
)

FindNotificationRuleByID testing.

func FindNotificationRules

func FindNotificationRules(
	init func(NotificationRuleFields, *testing.T) (influxdb.NotificationRuleStore, func()),
	t *testing.T,
)

FindNotificationRules testing

func FindOrganization

func FindOrganization(
	init func(OrganizationFields, *testing.T) (influxdb.OrganizationService, string, func()),
	t *testing.T,
)

FindOrganization testing

func FindOrganizationByID

func FindOrganizationByID(
	init func(OrganizationFields, *testing.T) (influxdb.OrganizationService, string, func()),
	t *testing.T,
)

FindOrganizationByID testing

func FindOrganizations

func FindOrganizations(
	init func(OrganizationFields, *testing.T) (influxdb.OrganizationService, string, func()),
	t *testing.T,
)

FindOrganizations testing

func FindSession

func FindSession(
	init func(SessionFields, *testing.T) (platform.SessionService, string, func()),
	t *testing.T,
)

FindSession testing

func FindSourceByID

func FindSourceByID(
	init func(SourceFields, *testing.T) (platform.SourceService, string, func()),
	t *testing.T,
)

FindSourceByID testing

func FindSources

func FindSources(
	init func(SourceFields, *testing.T) (platform.SourceService, string, func()),
	t *testing.T,
)

FindSources testing

func FindTelegrafConfigByID

func FindTelegrafConfigByID(
	init func(TelegrafConfigFields, *testing.T) (platform.TelegrafConfigStore, func()),
	t *testing.T,
)

FindTelegrafConfigByID testing.

func FindTelegrafConfigs

func FindTelegrafConfigs(
	init func(TelegrafConfigFields, *testing.T) (platform.TelegrafConfigStore, func()),
	t *testing.T,
)

FindTelegrafConfigs testing

func FindUser

func FindUser(
	init func(UserFields, *testing.T) (platform.UserService, string, func()),
	t *testing.T,
)

FindUser testing

func FindUserByID

func FindUserByID(
	init func(UserFields, *testing.T) (platform.UserService, string, func()),
	t *testing.T,
)

FindUserByID testing

func FindUserResourceMappings

func FindUserResourceMappings(
	init func(UserResourceFields, *testing.T) (platform.UserResourceMappingService, func()),
	t *testing.T,
)

func FindUsers

func FindUsers(
	init func(UserFields, *testing.T) (platform.UserService, string, func()),
	t *testing.T,
)

FindUsers testing

func FindVariableByID

func FindVariableByID(init func(VariableFields, *testing.T) (platform.VariableService, string, func()), t *testing.T)

FindVariableByID tests platform.VariableService FindVariableByID interface method

func FindVariables

func FindVariables(init func(VariableFields, *testing.T) (platform.VariableService, string, func()), t *testing.T)

FindVariables tests platform.variableService FindVariables interface method

func FirstLogEntry

func FirstLogEntry(
	init func(KeyValueLogFields, *testing.T) (platform.KeyValueLog, func()),
	t *testing.T,
)

FirstLogEntry tests the FirstLogEntry method for the KeyValueLog contract.

func FloatPtr

func FloatPtr(f float64) *float64

FloatPtr takes the ref of a float number.

func ForEachLogEntry

func ForEachLogEntry(
	init func(KeyValueLogFields, *testing.T) (platform.KeyValueLog, func()),
	t *testing.T,
)

ForEachLogEntry tests the AddLogEntry for the KeyValueLog contract

func GetDashboardCellView

func GetDashboardCellView(
	init func(DashboardFields, *testing.T) (platform.DashboardService, string, func()),
	t *testing.T,
)

GetDashboardCellView is the conformance test for the retrieving a dashboard cell.

func GetSecretKeys

func GetSecretKeys(
	init func(f SecretServiceFields, t *testing.T) (platform.SecretService, func()),
	t *testing.T,
)

GetSecretKeys tests the GetSecretKeys method for the SecretService interface.

func GetTargetByID

func GetTargetByID(
	init func(TargetFields, *testing.T) (influxdb.ScraperTargetStoreService, string, func()),
	t *testing.T,
)

GetTargetByID testing

func IDPtr

func IDPtr(id influxdb.ID) *influxdb.ID

IDPtr returns a pointer to an influxdb.ID.

func IDUnique

func IDUnique(
	init func(BucketFields, *testing.T) (influxdb.BucketService, string, func()),
	t *testing.T,
)

CreateBucket testing

func KVConcurrentUpdate

func KVConcurrentUpdate(
	init func(KVStoreFields, *testing.T) (kv.Store, func()),
	t *testing.T,
)

KVConcurrentUpdate tests concurrent calls to update.

func KVCursor

func KVCursor(
	init func(KVStoreFields, *testing.T) (kv.Store, func()),
	t *testing.T,
)

KVCursor tests the cursor contract for the key value store.

func KVCursorWithHints

func KVCursorWithHints(
	init func(KVStoreFields, *testing.T) (kv.Store, func()),
	t *testing.T,
)

KVCursor tests the cursor contract for the key value store.

func KVDelete

func KVDelete(
	init func(KVStoreFields, *testing.T) (kv.Store, func()),
	t *testing.T,
)

KVDelete tests the delete method contract for the key value store.

func KVForwardCursor

func KVForwardCursor(
	init func(KVStoreFields, *testing.T) (kv.Store, func()),
	t *testing.T,
)

KVForwardCursor tests the forward cursor contract for the key value store.

func KVGet

func KVGet(
	init func(KVStoreFields, *testing.T) (kv.Store, func()),
	t *testing.T,
)

KVGet tests the get method contract for the key value store.

func KVGetBatch

func KVGetBatch(
	init func(KVStoreFields, *testing.T) (kv.Store, func()),
	t *testing.T,
)

KVGetBatch tests the get batch method contract for the key value store.

func KVPut

func KVPut(
	init func(KVStoreFields, *testing.T) (kv.Store, func()),
	t *testing.T,
)

KVPut tests the get method contract for the key value store.

func KVStore

func KVStore(
	init func(KVStoreFields, *testing.T) (kv.Store, func()),
	t *testing.T,
)

KVStore tests the key value store contract

func KVUpdate

func KVUpdate(
	init func(KVStoreFields, *testing.T) (kv.Store, func()),
	t *testing.T,
)

KVUpdate tests the update method contract for the key value store.

func KVView

func KVView(
	init func(KVStoreFields, *testing.T) (kv.Store, func()),
	t *testing.T,
)

KVView tests the view method contract for the key value store.

func KeyValueLog

func KeyValueLog(
	init func(KeyValueLogFields, *testing.T) (platform.KeyValueLog, func()), t *testing.T,
)

KeyValueLog tests all the service functions.

func LabelService

func LabelService(
	init func(LabelFields, *testing.T) (influxdb.LabelService, string, func()),
	t *testing.T,
)

LabelService tests all the service functions.

func LastLogEntry

func LastLogEntry(
	init func(KeyValueLogFields, *testing.T) (platform.KeyValueLog, func()),
	t *testing.T,
)

LastLogEntry tests the LastLogEntry method for the KeyValueLog contract.

func ListTargets

func ListTargets(
	init func(TargetFields, *testing.T) (influxdb.ScraperTargetStoreService, string, func()),
	t *testing.T,
)

ListTargets testing

func LoadSecret

func LoadSecret(
	init func(f SecretServiceFields, t *testing.T) (platform.SecretService, func()),
	t *testing.T,
)

LoadSecret tests the LoadSecret method for the SecretService interface.

func Migrator

func Migrator(t *testing.T, store kv.Store, newMigrator func(*zap.Logger, NowFunc) *kv.Migrator)

Migrator tests a migrator against a provided store. The migrator is constructed via a provided constructor function which takes a logger and a now function used to derive time.

func MustCreateLabels

func MustCreateLabels(ctx context.Context, svc *kv.Service, labels ...*platform.Label)

func MustCreateMappings

func MustCreateMappings(ctx context.Context, svc *kv.Service, ms ...*platform.UserResourceMapping)

func MustCreateOrgs

func MustCreateOrgs(ctx context.Context, svc *kv.Service, os ...*platform.Organization)

func MustCreateUsers

func MustCreateUsers(ctx context.Context, svc *kv.Service, us ...*platform.User)

func MustIDBase16

func MustIDBase16(s string) platform.ID

MustIDBase16 is an helper to ensure a correct ID is built during testing.

func MustIDBase16Ptr

func MustIDBase16Ptr(s string) *platform.ID

MustIDBase16Ptr is an helper to ensure a correct ID ptr ref is built during testing.

func MustMakeUsersOrgMember

func MustMakeUsersOrgMember(ctx context.Context, svc *kv.Service, oid platform.ID, uids ...platform.ID)

func MustMakeUsersOrgOwner

func MustMakeUsersOrgOwner(ctx context.Context, svc *kv.Service, oid platform.ID, uids ...platform.ID)

func NewDocumentIntegrationTest

func NewDocumentIntegrationTest(store kv.Store) func(t *testing.T)

NewDocumentIntegrationTest will test the documents related funcs.

func NotificationEndpointService

func NotificationEndpointService(
	init func(NotificationEndpointFields, *testing.T) (influxdb.NotificationEndpointService, influxdb.SecretService, func()), t *testing.T,
)

NotificationEndpointService tests all the service functions.

func NotificationRuleStore

func NotificationRuleStore(
	init func(NotificationRuleFields, *testing.T) (influxdb.NotificationRuleStore, func()), t *testing.T,
)

NotificationRuleStore tests all the service functions.

func OnboardInitialUser

func OnboardInitialUser(
	init func(OnboardingFields, *testing.T) (platform.OnboardingService, func()),
	t *testing.T,
)

OnboardInitialUser testing

func OrganizationService

func OrganizationService(
	init func(OrganizationFields, *testing.T) (influxdb.OrganizationService, string, func()), t *testing.T,
)

OrganizationService tests all the service functions.

func PasswordsService

func PasswordsService(
	init func(PasswordFields, *testing.T) (influxdb.PasswordsService, func()), t *testing.T,
)

PasswordsService tests all the service functions.

func PatchCheck

func PatchCheck(
	init func(CheckFields, *testing.T) (influxdb.CheckService, string, func()),
	t *testing.T,
)

PatchCheck testing

func PatchNotificationEndpoint

func PatchNotificationEndpoint(
	init func(NotificationEndpointFields, *testing.T) (influxdb.NotificationEndpointService, influxdb.SecretService, func()),
	t *testing.T,
)

PatchNotificationEndpoint testing.

func PatchNotificationRule

func PatchNotificationRule(
	init func(NotificationRuleFields, *testing.T) (influxdb.NotificationRuleStore, func()),
	t *testing.T,
)

PatchNotificationRule testing.

func PatchSecrets

func PatchSecrets(
	init func(f SecretServiceFields, t *testing.T) (platform.SecretService, func()),
	t *testing.T,
)

PatchSecrets tests the PatchSecrets method for the SecretService interface.

func PutSecret

func PutSecret(
	init func(f SecretServiceFields, t *testing.T) (platform.SecretService, func()),
	t *testing.T,
)

PutSecret tests the PutSecret method for the SecretService interface.

func PutSecrets

func PutSecrets(
	init func(f SecretServiceFields, t *testing.T) (platform.SecretService, func()),
	t *testing.T,
)

PutSecrets tests the PutSecrets method for the SecretService interface.

func RemoveDashboardCell

func RemoveDashboardCell(
	init func(DashboardFields, *testing.T) (platform.DashboardService, string, func()),
	t *testing.T,
)

RemoveDashboardCell testing

func RemoveTarget

func RemoveTarget(init func(TargetFields, *testing.T) (influxdb.ScraperTargetStoreService, string, func()),
	t *testing.T)

RemoveTarget testing

func RenewSession

func RenewSession(
	init func(SessionFields, *testing.T) (platform.SessionService, string, func()),
	t *testing.T,
)

RenewSession testing

func ReplaceDashboardCells

func ReplaceDashboardCells(
	init func(DashboardFields, *testing.T) (platform.DashboardService, string, func()),
	t *testing.T,
)

ReplaceDashboardCells testing

func ScraperService

func ScraperService(
	init func(TargetFields, *testing.T) (influxdb.ScraperTargetStoreService, string, func()), t *testing.T,
)

ScraperService tests all the service functions.

func SecretService

func SecretService(
	init func(SecretServiceFields, *testing.T) (platform.SecretService, func()),
	t *testing.T,
)

SecretService will test all methods for the secrets service.

func SessionService

func SessionService(
	init func(SessionFields, *testing.T) (platform.SessionService, string, func()), t *testing.T,
)

SessionService tests all the service functions.

func SetPassword

func SetPassword(
	init func(PasswordFields, *testing.T) (influxdb.PasswordsService, func()),
	t *testing.T)

SetPassword tests overriding the password of a known user

func TelegrafConfigStore

func TelegrafConfigStore(
	init func(TelegrafConfigFields, *testing.T) (platform.TelegrafConfigStore, func()), t *testing.T,
)

TelegrafConfigStore tests all the service functions.

func TenantService

func TenantService(t *testing.T, init func(*testing.T, TenantFields) (influxdb.TenantService, func()))

TenantService tests the tenant service functions. These tests stress the relation between the services embedded by the TenantService. The individual functionality of services is tested elsewhere.

func TestIndex

func TestIndex(t *testing.T, store kv.Store)

func UpdateAuthorization

func UpdateAuthorization(
	init func(AuthorizationFields, *testing.T) (platform.AuthorizationService, string, func()),
	t *testing.T,
)

UpdateAuthorization testing

func UpdateBucket

func UpdateBucket(
	init func(BucketFields, *testing.T) (influxdb.BucketService, string, func()),
	t *testing.T,
)

UpdateBucket testing

func UpdateCheck

func UpdateCheck(
	init func(CheckFields, *testing.T) (influxdb.CheckService, string, func()),
	t *testing.T,
)

UpdateCheck testing

func UpdateDashboard

func UpdateDashboard(
	init func(DashboardFields, *testing.T) (platform.DashboardService, string, func()),
	t *testing.T,
)

UpdateDashboard testing

func UpdateDashboardCell

func UpdateDashboardCell(
	init func(DashboardFields, *testing.T) (platform.DashboardService, string, func()),
	t *testing.T,
)

UpdateDashboardCell testing

func UpdateDashboardCellView

func UpdateDashboardCellView(
	init func(DashboardFields, *testing.T) (platform.DashboardService, string, func()),
	t *testing.T,
)

UpdateDashboardCellView is the conformance test for the updating a dashboard cell.

func UpdateLabel

func UpdateLabel(
	init func(LabelFields, *testing.T) (influxdb.LabelService, string, func()),
	t *testing.T,
)

func UpdateNotificationEndpoint

func UpdateNotificationEndpoint(
	init func(NotificationEndpointFields, *testing.T) (influxdb.NotificationEndpointService, influxdb.SecretService, func()),
	t *testing.T,
)

UpdateNotificationEndpoint testing.

func UpdateNotificationRule

func UpdateNotificationRule(
	init func(NotificationRuleFields, *testing.T) (influxdb.NotificationRuleStore, func()),
	t *testing.T,
)

UpdateNotificationRule testing.

func UpdateOrganization

func UpdateOrganization(
	init func(OrganizationFields, *testing.T) (influxdb.OrganizationService, string, func()),
	t *testing.T,
)

UpdateOrganization testing

func UpdateTarget

func UpdateTarget(
	init func(TargetFields, *testing.T) (influxdb.ScraperTargetStoreService, string, func()),
	t *testing.T,
)

UpdateTarget testing

func UpdateTelegrafConfig

func UpdateTelegrafConfig(
	init func(TelegrafConfigFields, *testing.T) (platform.TelegrafConfigStore, func()),
	t *testing.T,
)

UpdateTelegrafConfig testing.

func UpdateUser

func UpdateUser(
	init func(UserFields, *testing.T) (platform.UserService, string, func()),
	t *testing.T,
)

UpdateUser testing

func UpdateVariable

func UpdateVariable(init func(VariableFields, *testing.T) (platform.VariableService, string, func()), t *testing.T)

UpdateVariable tests platform.VariableService UpdateVariable interface method

func UserResourceMappingService

func UserResourceMappingService(
	init func(UserResourceFields, *testing.T) (platform.UserResourceMappingService, func()),
	t *testing.T,
)

UserResourceMappingService tests all the service functions.

func UserService

func UserService(
	init func(UserFields, *testing.T) (platform.UserService, string, func()), t *testing.T,
)

UserService tests all the service functions.

func VariableService

func VariableService(
	init func(VariableFields, *testing.T) (platform.VariableService, string, func()), t *testing.T,
)

VariableService tests all the service functions.

Types

type AuthorizationFields

type AuthorizationFields struct {
	IDGenerator    platform.IDGenerator
	TokenGenerator platform.TokenGenerator
	TimeGenerator  platform.TimeGenerator
	Authorizations []*platform.Authorization
	Users          []*platform.User
	Orgs           []*platform.Organization
}

AuthorizationFields will include the IDGenerator, and authorizations

type BucketFields

type BucketFields struct {
	IDGenerator   influxdb.IDGenerator
	OrgBucketIDs  influxdb.IDGenerator
	TimeGenerator influxdb.TimeGenerator
	Buckets       []*influxdb.Bucket
	Organizations []*influxdb.Organization
}

BucketFields will include the IDGenerator, and buckets

type BucketSvcOpts

type BucketSvcOpts struct {
	NoHooks bool
}

func WithoutHooks

func WithoutHooks() BucketSvcOpts

WithoutHooks allows the test suite to be run without being able to hook into the underlieing implementation of theservice in most cases that is to remove specific id generation controls.

type CheckFields

type CheckFields struct {
	IDGenerator          influxdb.IDGenerator
	TimeGenerator        influxdb.TimeGenerator
	Checks               []influxdb.Check
	Organizations        []*influxdb.Organization
	UserResourceMappings []*influxdb.UserResourceMapping
	Tasks                []influxdb.TaskCreate
}

CheckFields will include the IDGenerator, and checks

type DBRPMappingFields

type DBRPMappingFields struct {
	DBRPMappings []*platform.DBRPMapping
}

DBRPMappingFields will include the dbrpMappings

func (DBRPMappingFields) Populate

Populate creates all entities in DBRPMappingFields

type DashboardFields

type DashboardFields struct {
	IDGenerator   platform.IDGenerator
	TimeGenerator platform.TimeGenerator
	Dashboards    []*platform.Dashboard
	Views         []*platform.View
}

DashboardFields will include the IDGenerator, and dashboards

type KVStoreFields

type KVStoreFields struct {
	Bucket []byte
	Pairs  []kv.Pair
}

KVStoreFields are background data that has to be set before the test runs.

type KeyValueLogFields

type KeyValueLogFields struct {
	LogEntries []LogEntry
}

KeyValueLogFields will include the IDGenerator, and keyValueLogs

type LabelFields

type LabelFields struct {
	Labels      []*influxdb.Label
	Mappings    []*influxdb.LabelMapping
	IDGenerator influxdb.IDGenerator
}

LabelFields include the IDGenerator, labels and their mappings

type LogEntry

type LogEntry struct {
	Key   []byte
	Value []byte
	Time  time.Time
}

A log entry is a comparable data structure that is used for testing

type NotificationEndpointFields

type NotificationEndpointFields struct {
	IDGenerator           influxdb.IDGenerator
	TimeGenerator         influxdb.TimeGenerator
	NotificationEndpoints []influxdb.NotificationEndpoint
	Orgs                  []*influxdb.Organization
	UserResourceMappings  []*influxdb.UserResourceMapping
}

NotificationEndpointFields includes prepopulated data for mapping tests.

type NotificationRuleFields

type NotificationRuleFields struct {
	IDGenerator          influxdb.IDGenerator
	TimeGenerator        influxdb.TimeGenerator
	NotificationRules    []influxdb.NotificationRule
	Orgs                 []*influxdb.Organization
	UserResourceMappings []*influxdb.UserResourceMapping
	Tasks                []influxdb.TaskCreate
	Endpoints            []influxdb.NotificationEndpoint
}

NotificationRuleFields includes prepopulated data for mapping tests.

type NowFunc

type NowFunc func() time.Time

NowFunc is a function which returns a time

type OnboardingFields

type OnboardingFields struct {
	IDGenerator    platform.IDGenerator
	TokenGenerator platform.TokenGenerator
	TimeGenerator  platform.TimeGenerator
	IsOnboarding   bool
}

OnboardingFields will include the IDGenerator, TokenGenerator and IsOnboarding

type OrganizationFields

type OrganizationFields struct {
	IDGenerator   *mock.MockIDGenerator
	Organizations []*influxdb.Organization
	TimeGenerator influxdb.TimeGenerator
	OrgBucketIDs  *mock.MockIDGenerator
}

OrganizationFields will include the IDGenerator, and organizations

type PasswordFields

type PasswordFields struct {
	IDGenerator influxdb.IDGenerator
	Users       []*influxdb.User
	Passwords   []string // passwords are indexed against the Users field
}

PasswordFields will include the IDGenerator, and users and their passwords.

type Secret

type Secret struct {
	OrganizationID platform.ID
	Env            map[string]string
}

A secret is a comparable data structure that is used for testing

type SecretServiceFields

type SecretServiceFields struct {
	Secrets []Secret
}

SecretServiceFields contain the

type SessionFields

type SessionFields struct {
	IDGenerator    platform.IDGenerator
	TokenGenerator platform.TokenGenerator
	Sessions       []*platform.Session
	Users          []*platform.User
}

SessionFields will include the IDGenerator, TokenGenerator, Sessions, and Users

type SourceFields

type SourceFields struct {
	IDGenerator platform.IDGenerator
	Sources     []*platform.Source
}

SourceFields will include the IDGenerator, and sources

type TargetFields

type TargetFields struct {
	IDGenerator          influxdb.IDGenerator
	Targets              []*influxdb.ScraperTarget
	UserResourceMappings []*influxdb.UserResourceMapping
	Organizations        []*influxdb.Organization
}

TargetFields will include the IDGenerator, and targets

type TelegrafConfigFields

type TelegrafConfigFields struct {
	IDGenerator          platform.IDGenerator
	TelegrafConfigs      []*platform.TelegrafConfig
	UserResourceMappings []*platform.UserResourceMapping
}

TelegrafConfigFields includes prepopulated data for mapping tests.

type TenantFields

type TenantFields struct {
	Users                []*influxdb.User
	Passwords            []string // passwords are indexed against the Users field
	UserResourceMappings []*influxdb.UserResourceMapping
	Organizations        []*influxdb.Organization
	Buckets              []*influxdb.Bucket
}

type UserFields

type UserFields struct {
	IDGenerator platform.IDGenerator
	Users       []*platform.User
}

UserFields will include the IDGenerator, and users

type UserResourceFields

type UserResourceFields struct {
	Organizations        []*platform.Organization
	Users                []*platform.User
	Buckets              []*platform.Bucket
	UserResourceMappings []*platform.UserResourceMapping
}

UserResourceFields includes prepopulated data for mapping tests

type VariableFields

type VariableFields struct {
	Variables     []*platform.Variable
	IDGenerator   platform.IDGenerator
	TimeGenerator platform.TimeGenerator
}

VariableFields defines fields for a variable test

Jump to

Keyboard shortcuts

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