test

package
v0.0.0-...-d18f1db Latest Latest
Warning

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

 Go to latest Published: Apr 19, 2024 License: Apache-2.0 Imports: 43 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Helper 

type Helper struct {
	Ctx               context.Context
	ContextCancelFunc context.CancelFunc

	EventBroadcaster  *event.EventBroadcaster
	Store             *MemoryStore
	GRPCSourceClient  *generic.CloudEventSourceClient[*api.Resource]
	DBFactory         db.SessionFactory
	AppConfig         *config.ApplicationConfig
	APIServer         server.Server
	MetricsServer     server.Server
	HealthCheckServer server.Server
	PulseServer       *server.PulseServer
	ControllerManager *server.ControllersServer
	WorkAgentHolder   *work.ClientHolder
	TimeFunc          TimeFunc
	JWTPrivateKey     *rsa.PrivateKey
	JWTCA             *rsa.PublicKey
	T                 *testing.T
	// contains filtered or unexported fields
}

func NewHelper 

func NewHelper(t *testing.T) *Helper

func RegisterIntegration 

func RegisterIntegration(t *testing.T) (*Helper, *openapi.APIClient)

Register a test This should be run before every integration test

func (*Helper) CleanDB 

func (helper *Helper) CleanDB() error

func (*Helper) ClearAllTables 

func (helper *Helper) ClearAllTables()

func (*Helper) Count 

func (helper *Helper) Count(table string) int64

func (*Helper) CreateConsumer 

func (helper *Helper) CreateConsumer(name string) *api.Consumer

func (*Helper) CreateConsumerList 

func (helper *Helper) CreateConsumerList(count int) (consumers []*api.Consumer)

func (*Helper) CreateConsumerWithLabels 

func (helper *Helper) CreateConsumerWithLabels(name string, labels map[string]string) *api.Consumer

func (*Helper) CreateJWTString 

func (helper *Helper) CreateJWTString(account *amv1.Account) string

func (*Helper) CreateJWTToken 

func (helper *Helper) CreateJWTToken(account *amv1.Account) *jwt.Token

func (*Helper) CreateResource 

func (helper *Helper) CreateResource(consumerName string, replicas int) *api.Resource

func (*Helper) CreateResourceList 

func (helper *Helper) CreateResourceList(consumerName string, count int) (resources []*api.Resource)

func (*Helper) Delete 

func (helper *Helper) Delete(obj interface{})

func (*Helper) DeleteAll 

func (helper *Helper) DeleteAll(table interface{})

func (*Helper) Env 

func (helper *Helper) Env() *environments.Env

func (*Helper) HealthCheckURL 

func (helper *Helper) HealthCheckURL(path string) string

func (*Helper) MetricsURL 

func (helper *Helper) MetricsURL(path string) string

func (*Helper) MigrateDB 

func (helper *Helper) MigrateDB() error

func (*Helper) MigrateDBTo 

func (helper *Helper) MigrateDBTo(migrationID string)

func (*Helper) NewAPIResource 

func (helper *Helper) NewAPIResource(consumerName string, replicas int) openapi.Resource

func (*Helper) NewAccount 

func (helper *Helper) NewAccount(username, name, email string) *amv1.Account

func (*Helper) NewApiClient 

func (helper *Helper) NewApiClient() *openapi.APIClient

func (*Helper) NewAuthenticatedContext 

func (helper *Helper) NewAuthenticatedContext(account *amv1.Account) context.Context

func (*Helper) NewID 

func (helper *Helper) NewID() string

NewID creates a new unique ID used internally to CS

func (*Helper) NewRandAccount 

func (helper *Helper) NewRandAccount() *amv1.Account

func (*Helper) NewResource 

func (helper *Helper) NewResource(consumerName string, replicas int) *api.Resource

func (*Helper) NewUUID 

func (helper *Helper) NewUUID() string

NewUUID creates a new unique UUID, which has different formatting than ksuid UUID is used by telemeter and we validate the format.

func (*Helper) OpenapiError 

func (helper *Helper) OpenapiError(err error) openapi.Error

Convert an error response from the openapi client to an openapi error struct

func (*Helper) Reset 

func (helper *Helper) Reset()

func (*Helper) ResetDB 

func (helper *Helper) ResetDB() error

func (*Helper) RestURL 

func (helper *Helper) RestURL(path string) string

func (*Helper) RestartMetricsServer 

func (helper *Helper) RestartMetricsServer()

func (*Helper) RestartServer 

func (helper *Helper) RestartServer()

func (*Helper) SkipIfShort 

func (helper *Helper) SkipIfShort()

func (*Helper) StartControllerManager 

func (helper *Helper) StartControllerManager(ctx context.Context)

func (*Helper) StartGRPCResourceSourceClient 

func (helper *Helper) StartGRPCResourceSourceClient()

func (*Helper) StartJWKCertServerMock 

func (helper *Helper) StartJWKCertServerMock() (teardown func() error)

func (*Helper) StartWorkAgent 

func (helper *Helper) StartWorkAgent(ctx context.Context, clusterName string, mqttOptions *mqttoptions.MQTTOptions, bundle bool)

func (*Helper) Teardown 

func (helper *Helper) Teardown()

type MemoryStore 

type MemoryStore struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewStore 

func NewStore() *MemoryStore

func (*MemoryStore) Add 

func (s *MemoryStore) Add(resource *api.Resource)

func (*MemoryStore) Delete 

func (s *MemoryStore) Delete(resourceID string)

func (*MemoryStore) Get 

func (s *MemoryStore) Get(resourceID string) (*api.Resource, error)

func (*MemoryStore) List 

func (s *MemoryStore) List(listOpts types.ListOptions) ([]*api.Resource, error)

func (*MemoryStore) ListByNamespace 

func (s *MemoryStore) ListByNamespace(namespace string) []*api.Resource

func (*MemoryStore) UpSert 

func (s *MemoryStore) UpSert(resource *api.Resource)

func (*MemoryStore) Update 

func (s *MemoryStore) Update(resource *api.Resource) error

func (*MemoryStore) UpdateStatus 

func (s *MemoryStore) UpdateStatus(resource *api.Resource) error

type ResourceBundleCodec 

type ResourceBundleCodec struct{}

func (*ResourceBundleCodec) Decode 

func (c *ResourceBundleCodec) Decode(evt *cloudevents.Event) (*api.Resource, error)

func (*ResourceBundleCodec) Encode 

func (c *ResourceBundleCodec) Encode(source string, eventType types.CloudEventsType, resource *api.Resource) (*cloudevents.Event, error)

encode the kubernetes resource to a cloudevent format

func (*ResourceBundleCodec) EventDataType 

func (c *ResourceBundleCodec) EventDataType() types.CloudEventsDataType

type ResourceCodec 

type ResourceCodec struct{}

func (*ResourceCodec) Decode 

func (c *ResourceCodec) Decode(evt *cloudevents.Event) (*api.Resource, error)

func (*ResourceCodec) Encode 

func (c *ResourceCodec) Encode(source string, eventType types.CloudEventsType, resource *api.Resource) (*cloudevents.Event, error)

encode the kubernetes resource to a cloudevent format

func (*ResourceCodec) EventDataType 

func (c *ResourceCodec) EventDataType() types.CloudEventsDataType

type TimeFunc 

type TimeFunc func() time.Time

TimeFunc defines a way to get a new Time instance common to the entire test suite. Aria's environment has Virtual Time that may not be actual time. We compensate by synchronizing on a common time func attached to the test harness.

Source Files

View all Source files

Directories

Path Synopsis

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.