testing

package
v2.0.6 Latest Latest
Warning

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

 Go to latest Published: Apr 29, 2021 License: MIT Imports: 23 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var DBRPMappingCmpOptionsV2 = cmp.Options{
	cmp.Comparer(func(x, y []byte) bool {
		return bytes.Equal(x, y)
	}),
	cmp.Transformer("Sort", func(in []*influxdb.DBRPMappingV2) []*influxdb.DBRPMappingV2 {
		out := make([]*influxdb.DBRPMappingV2, len(in))
		copy(out, in)
		sort.Slice(out, func(i, j int) bool {
			return out[i].ID < out[j].ID
		})
		return out
	}),
}

Functions

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) (influxdb.AuthorizationService, string, func()),
	t *testing.T,
	opts ...AuthTestOpts)

AuthorizationService tests all the service functions.

func BenchmarkIndexWalk 

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

func BucketService 

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

BucketService tests all the service functions.

func CleanupDBRPMappings 

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

CleanupDBRPMappings finds and removes all dbrp mappings

func CleanupDBRPMappingsV2 

func CleanupDBRPMappingsV2(ctx context.Context, s influxdb.DBRPMappingServiceV2) error

CleanupDBRPMappingsV2 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) (influxdb.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 CreateDBRPMapping 

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

CreateDBRPMapping testing

func CreateDBRPMappingV2 

func CreateDBRPMappingV2(
	init func(DBRPMappingFieldsV2, *testing.T) (influxdb.DBRPMappingServiceV2, func()),
	t *testing.T,
)

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 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) (influxdb.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 CreateUser 

func CreateUser(
	init func(UserFields, *testing.T) (influxdb.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) (influxdb.VariableService, string, func()), t *testing.T)

CreateVariable tests influxdb.VariableService CreateVariable interface method

func DBRPMappingServiceV2 

func DBRPMappingServiceV2(
	init func(DBRPMappingFieldsV2, *testing.T) (influxdb.DBRPMappingServiceV2, func()),
	t *testing.T,
)

DBRPMappingServiceV2 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) (influxdb.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 DeleteDBRPMapping 

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

DeleteDBRPMapping testing

func DeleteDBRPMappingV2 

func DeleteDBRPMappingV2(
	init func(DBRPMappingFieldsV2, *testing.T) (influxdb.DBRPMappingServiceV2, func()),
	t *testing.T,
)

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 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 DeleteUser 

func DeleteUser(
	init func(UserFields, *testing.T) (influxdb.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) (influxdb.VariableService, string, func()), t *testing.T)

DeleteVariable tests influxdb.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) (influxdb.SessionService, string, func()),
	t *testing.T,
)

ExpireSession testing

func FindAuthorizationByID 

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

FindAuthorizationByID testing

func FindAuthorizationByToken 

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

FindAuthorizationByToken testing

func FindAuthorizations 

func FindAuthorizations(
	init func(AuthorizationFields, *testing.T) (influxdb.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 FindDBRPMapping 

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

FindDBRPMapping testing

func FindDBRPMappingByIDV2 

func FindDBRPMappingByIDV2(
	init func(DBRPMappingFieldsV2, *testing.T) (influxdb.DBRPMappingServiceV2, func()),
	t *testing.T,
)

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 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 FindManyDBRPMappingsV2 

func FindManyDBRPMappingsV2(
	init func(DBRPMappingFieldsV2, *testing.T) (influxdb.DBRPMappingServiceV2, func()),
	t *testing.T,
)

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) (influxdb.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 FindUser 

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

FindUser testing

func FindUserByID 

func FindUserByID(
	init func(UserFields, *testing.T) (influxdb.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) (influxdb.UserService, string, func()),
	t *testing.T,
)

FindUsers testing

func FindVariableByID 

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

FindVariableByID tests influxdb.VariableService FindVariableByID interface method

func FindVariables 

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

FindVariables tests influxdb.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 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 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.SchemaStore, newMigrator func(*testing.T, *zap.Logger, kv.SchemaStore, NowFunc) *migration.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 MiscDBRPMappingV2 

func MiscDBRPMappingV2(
	init func(DBRPMappingFieldsV2, *testing.T) (influxdb.DBRPMappingServiceV2, func()),
	t *testing.T,
)

func MustCreateLabels 

func MustCreateLabels(ctx context.Context, svc influxdb.LabelService, labels ...*influxdb.Label)

func MustCreateMappings 

func MustCreateMappings(ctx context.Context, svc influxdb.UserResourceMappingService, ms ...*influxdb.UserResourceMapping)

func MustCreateOrgs 

func MustCreateOrgs(ctx context.Context, svc influxdb.OrganizationService, os ...*influxdb.Organization)

func MustCreateUsers 

func MustCreateUsers(ctx context.Context, svc influxdb.UserService, us ...*influxdb.User)

func MustIDBase16 

func MustIDBase16(s string) influxdb.ID

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

func MustIDBase16Ptr 

func MustIDBase16Ptr(s string) *influxdb.ID

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

func MustMakeUsersOrgMember 

func MustMakeUsersOrgMember(ctx context.Context, svc influxdb.UserResourceMappingService, oid influxdb.ID, uids ...influxdb.ID)

func MustMakeUsersOrgOwner 

func MustMakeUsersOrgOwner(ctx context.Context, svc influxdb.UserResourceMappingService, oid influxdb.ID, uids ...influxdb.ID)

func MustNewPermissionAtID 

func MustNewPermissionAtID(id influxdb.ID, a influxdb.Action, rt influxdb.ResourceType, orgID influxdb.ID) *influxdb.Permission

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 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 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) (influxdb.SessionService, string, func()),
	t *testing.T,
)

RenewSession testing

func ReplaceVariable 

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

ReplaceVariable tests influxdb.VariableService ReplaceVariable interface method

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) (influxdb.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 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.SchemaStore)

func TrimWhitespace 

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

func UpdateAuthorization 

func UpdateAuthorization(
	init func(AuthorizationFields, *testing.T) (influxdb.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 UpdateDBRPMappingV2 

func UpdateDBRPMappingV2(
	init func(DBRPMappingFieldsV2, *testing.T) (influxdb.DBRPMappingServiceV2, func()),
	t *testing.T,
)

func UpdateLabel 

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

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 UpdateUser 

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

UpdateUser testing

func UpdateUser_IndexHygiene 

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

func UpdateVariable 

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

UpdateVariable tests influxdb.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) (influxdb.UserService, string, func()), t *testing.T,
)

UserService tests all the service functions.

func VariableService 

func VariableService(
	init func(VariableFields, *testing.T) (influxdb.VariableService, string, func()), t *testing.T, opts ...VariableSvcOpts,
)

VariableService tests all the service functions.

Types

type AuthTestOpts 

type AuthTestOpts struct {
	WithoutFindByToken bool
}

func WithoutFindByToken 

func WithoutFindByToken() AuthTestOpts

WithoutFindByToken allows the Find By Token test case to be skipped when we are testing the http server, since finding by token is not supported by the HTTP API

type AuthorizationFields 

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

AuthorizationFields will include the IDGenerator, and authorizations

type BucketFields 

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

BucketFields will include the IDGenerator, and buckets

type DBRPMappingFields 

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

DBRPMappingFields will include the dbrpMappings

func (DBRPMappingFields) Populate 

func (f DBRPMappingFields) Populate(ctx context.Context, s platform.DBRPMappingService) error

Populate creates all entities in DBRPMappingFields

type DBRPMappingFieldsV2 

type DBRPMappingFieldsV2 struct {
	BucketSvc      influxdb.BucketService
	DBRPMappingsV2 []*influxdb.DBRPMappingV2
}

func (DBRPMappingFieldsV2) Populate 

func (f DBRPMappingFieldsV2) Populate(ctx context.Context, s influxdb.DBRPMappingServiceV2) error

Populate creates all entities in DBRPMappingFieldsV2.

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 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   influxdb.IDGenerator
	OrgBucketIDs  influxdb.IDGenerator
	Organizations []*influxdb.Organization
	TimeGenerator influxdb.TimeGenerator
}

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    influxdb.IDGenerator
	TokenGenerator influxdb.TokenGenerator
	Sessions       []*influxdb.Session
	Users          []*influxdb.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
	Organizations []*influxdb.Organization
}

TargetFields will include the IDGenerator, and targets

type TenantFields 

type TenantFields struct {
	OrgIDGenerator       influxdb.IDGenerator
	BucketIDGenerator    influxdb.IDGenerator
	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 influxdb.IDGenerator
	Users       []*influxdb.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     []*influxdb.Variable
	IDGenerator   influxdb.IDGenerator
	TimeGenerator influxdb.TimeGenerator
}

VariableFields defines fields for a variable test

type VariableSvcOpts 

type VariableSvcOpts struct {
	HTTPValidation bool
}

func WithHTTPValidation 

func WithHTTPValidation() VariableSvcOpts

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.