v2alpha1

package
v0.24.7 Latest Latest
Warning

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

Go to latest
Published: Jul 11, 2022 License: Apache-2.0 Imports: 45 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

View Source
var File_github_com_solo_io_solo_kit_test_mocks_api_v2alpha1_mock_resources_proto protoreflect.FileDescriptor
View Source
var (
	FrequentlyChangingAnnotationsResourceGVK = schema.GroupVersionKind{
		Version: "v2alpha1",
		Group:   "testing.solo.io",
		Kind:    "FrequentlyChangingAnnotationsResource",
	}
)
View Source
var (
	MockResourceCrd = crd.NewCrd(
		"mocks",
		MockResourceGVK.Group,
		MockResourceGVK.Version,
		MockResourceGVK.Kind,
		"mk",
		false,
		&MockResource{})
)
View Source
var (
	MockResourceGVK = schema.GroupVersionKind{
		Version: "v2alpha1",
		Group:   "testing.solo.io",
		Kind:    "MockResource",
	}
)

Functions

func NewTestingEventLoop

func NewTestingEventLoop(emitter TestingSnapshotEmitter, syncer TestingSyncer) eventloop.EventLoop

func NewTestingSimpleEventLoop

func NewTestingSimpleEventLoop(emitter TestingSimpleEmitter, syncers ...TestingSyncer) eventloop.SimpleEventLoop

Types

type FrequentlyChangingAnnotationsResource added in v0.10.18

type FrequentlyChangingAnnotationsResource struct {
	Metadata *core.Metadata `protobuf:"bytes,7,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Blah     string         `protobuf:"bytes,1,opt,name=blah,proto3" json:"blah,omitempty"`
	// contains filtered or unexported fields
}

func NewFrequentlyChangingAnnotationsResource added in v0.10.18

func NewFrequentlyChangingAnnotationsResource(namespace, name string) *FrequentlyChangingAnnotationsResource

func (*FrequentlyChangingAnnotationsResource) Clone added in v0.20.5

Clone function

func (*FrequentlyChangingAnnotationsResource) DeepCopyInto added in v0.11.3

func (*FrequentlyChangingAnnotationsResource) DeepCopyObject added in v0.10.18

func (*FrequentlyChangingAnnotationsResource) Descriptor deprecated added in v0.10.18

func (*FrequentlyChangingAnnotationsResource) Descriptor() ([]byte, []int)

Deprecated: Use FrequentlyChangingAnnotationsResource.ProtoReflect.Descriptor instead.

func (*FrequentlyChangingAnnotationsResource) Equal added in v0.10.18

func (m *FrequentlyChangingAnnotationsResource) Equal(that interface{}) bool

Equal function

func (*FrequentlyChangingAnnotationsResource) GetBlah added in v0.10.18

func (*FrequentlyChangingAnnotationsResource) GetMetadata added in v0.10.18

func (*FrequentlyChangingAnnotationsResource) GetObjectKind added in v0.10.18

func (*FrequentlyChangingAnnotationsResource) GroupVersionKind added in v0.10.18

func (*FrequentlyChangingAnnotationsResource) Hash added in v0.10.18

Hash function

func (*FrequentlyChangingAnnotationsResource) MustHash added in v0.11.16

func (*FrequentlyChangingAnnotationsResource) ProtoMessage added in v0.10.18

func (*FrequentlyChangingAnnotationsResource) ProtoMessage()

func (*FrequentlyChangingAnnotationsResource) ProtoReflect added in v0.16.0

func (*FrequentlyChangingAnnotationsResource) Reset added in v0.10.18

func (*FrequentlyChangingAnnotationsResource) SetMetadata added in v0.10.18

func (r *FrequentlyChangingAnnotationsResource) SetMetadata(meta *core.Metadata)

func (*FrequentlyChangingAnnotationsResource) String added in v0.10.18

type FrequentlyChangingAnnotationsResourceClient added in v0.10.18

type FrequentlyChangingAnnotationsResourceClient interface {
	BaseClient() clients.ResourceClient
	Register() error
	Read(namespace, name string, opts clients.ReadOpts) (*FrequentlyChangingAnnotationsResource, error)
	Write(resource *FrequentlyChangingAnnotationsResource, opts clients.WriteOpts) (*FrequentlyChangingAnnotationsResource, error)
	Delete(namespace, name string, opts clients.DeleteOpts) error
	List(namespace string, opts clients.ListOpts) (FrequentlyChangingAnnotationsResourceList, error)
	FrequentlyChangingAnnotationsResourceWatcher
}

func NewFrequentlyChangingAnnotationsResourceClient added in v0.10.18

func NewFrequentlyChangingAnnotationsResourceClient(ctx context.Context, rcFactory factory.ResourceClientFactory) (FrequentlyChangingAnnotationsResourceClient, error)

func NewFrequentlyChangingAnnotationsResourceClientWithBase added in v0.10.18

func NewFrequentlyChangingAnnotationsResourceClientWithBase(rc clients.ResourceClient) FrequentlyChangingAnnotationsResourceClient

func NewFrequentlyChangingAnnotationsResourceClientWithToken added in v0.10.18

func NewFrequentlyChangingAnnotationsResourceClientWithToken(ctx context.Context, rcFactory factory.ResourceClientFactory, token string) (FrequentlyChangingAnnotationsResourceClient, error)

type FrequentlyChangingAnnotationsResourceList added in v0.10.18

type FrequentlyChangingAnnotationsResourceList []*FrequentlyChangingAnnotationsResource

func (FrequentlyChangingAnnotationsResourceList) AsInterfaces added in v0.10.18

func (list FrequentlyChangingAnnotationsResourceList) AsInterfaces() []interface{}

func (FrequentlyChangingAnnotationsResourceList) AsResources added in v0.10.18

func (FrequentlyChangingAnnotationsResourceList) Clone added in v0.10.18

func (FrequentlyChangingAnnotationsResourceList) Each added in v0.10.18

func (FrequentlyChangingAnnotationsResourceList) EachResource added in v0.10.18

func (list FrequentlyChangingAnnotationsResourceList) EachResource(f func(element resources.Resource))

func (FrequentlyChangingAnnotationsResourceList) Find added in v0.10.18

func (FrequentlyChangingAnnotationsResourceList) Names added in v0.10.18

func (FrequentlyChangingAnnotationsResourceList) NamespacesDotNames added in v0.10.18

func (list FrequentlyChangingAnnotationsResourceList) NamespacesDotNames() []string

func (FrequentlyChangingAnnotationsResourceList) Sort added in v0.10.18

type FrequentlyChangingAnnotationsResourceReconciler added in v0.10.18

type FrequentlyChangingAnnotationsResourceReconciler interface {
	Reconcile(namespace string, desiredResources FrequentlyChangingAnnotationsResourceList, transition TransitionFrequentlyChangingAnnotationsResourceFunc, opts clients.ListOpts) error
}

type FrequentlyChangingAnnotationsResourceWatcher added in v0.10.18

type FrequentlyChangingAnnotationsResourceWatcher interface {
	// watch namespace-scoped Fcars
	Watch(namespace string, opts clients.WatchOpts) (<-chan FrequentlyChangingAnnotationsResourceList, <-chan error, error)
}

type MockResource

type MockResource struct {
	NamespacedStatuses *core.NamespacedStatuses `protobuf:"bytes,16,opt,name=namespaced_statuses,json=namespacedStatuses,proto3" json:"namespaced_statuses,omitempty"`
	Metadata           *core.Metadata           `protobuf:"bytes,7,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// Types that are assignable to WeStuckItInAOneof:
	//	*MockResource_SomeDumbField
	//	*MockResource_Data
	WeStuckItInAOneof isMockResource_WeStuckItInAOneof `protobuf_oneof:"we_stuck_it_in_a_oneof"`
	// Types that are assignable to TestOneofFields:
	//	*MockResource_OneofOne
	//	*MockResource_OneofTwo
	TestOneofFields isMockResource_TestOneofFields `protobuf_oneof:"test_oneof_fields"`
	// contains filtered or unexported fields
}

The best mock resource you ever done seen

func NewMockResource

func NewMockResource(namespace, name string) *MockResource

func (*MockResource) Clone added in v0.20.5

func (m *MockResource) Clone() proto.Message

Clone function

func (*MockResource) DeepCopyInto added in v0.11.3

func (o *MockResource) DeepCopyInto(out *MockResource)

func (*MockResource) DeepCopyObject

func (o *MockResource) DeepCopyObject() runtime.Object

func (*MockResource) Descriptor deprecated

func (*MockResource) Descriptor() ([]byte, []int)

Deprecated: Use MockResource.ProtoReflect.Descriptor instead.

func (*MockResource) Equal

func (m *MockResource) Equal(that interface{}) bool

Equal function

func (*MockResource) GetData

func (x *MockResource) GetData() string

func (*MockResource) GetMetadata

func (x *MockResource) GetMetadata() *core.Metadata

func (*MockResource) GetNamespacedStatuses added in v0.23.0

func (x *MockResource) GetNamespacedStatuses() *core.NamespacedStatuses

func (*MockResource) GetObjectKind

func (o *MockResource) GetObjectKind() schema.ObjectKind

func (*MockResource) GetOneofOne

func (x *MockResource) GetOneofOne() string

func (*MockResource) GetOneofTwo

func (x *MockResource) GetOneofTwo() bool

func (*MockResource) GetSomeDumbField

func (x *MockResource) GetSomeDumbField() string

func (*MockResource) GetStatus

func (r *MockResource) GetStatus() *core.Status

Deprecated

func (*MockResource) GetTestOneofFields

func (m *MockResource) GetTestOneofFields() isMockResource_TestOneofFields

func (*MockResource) GetWeStuckItInAOneof

func (m *MockResource) GetWeStuckItInAOneof() isMockResource_WeStuckItInAOneof

func (*MockResource) GroupVersionKind added in v0.10.4

func (r *MockResource) GroupVersionKind() schema.GroupVersionKind

func (*MockResource) Hash

func (m *MockResource) Hash(hasher hash.Hash64) (uint64, error)

Hash function

func (*MockResource) MustHash added in v0.11.16

func (r *MockResource) MustHash() uint64

func (*MockResource) ProtoMessage

func (*MockResource) ProtoMessage()

func (*MockResource) ProtoReflect added in v0.16.0

func (x *MockResource) ProtoReflect() protoreflect.Message

func (*MockResource) Reset

func (x *MockResource) Reset()

func (*MockResource) SetMetadata

func (r *MockResource) SetMetadata(meta *core.Metadata)

func (*MockResource) SetNamespacedStatuses added in v0.23.0

func (r *MockResource) SetNamespacedStatuses(namespacedStatuses *core.NamespacedStatuses)

func (*MockResource) SetStatus

func (r *MockResource) SetStatus(status *core.Status)

Deprecated

func (*MockResource) String

func (x *MockResource) String() string

type MockResourceClient

type MockResourceClient interface {
	BaseClient() clients.ResourceClient
	Register() error
	Read(namespace, name string, opts clients.ReadOpts) (*MockResource, error)
	Write(resource *MockResource, opts clients.WriteOpts) (*MockResource, error)
	Delete(namespace, name string, opts clients.DeleteOpts) error
	List(namespace string, opts clients.ListOpts) (MockResourceList, error)
	MockResourceWatcher
}

func NewMockResourceClient

func NewMockResourceClient(ctx context.Context, rcFactory factory.ResourceClientFactory) (MockResourceClient, error)

func NewMockResourceClientWithBase

func NewMockResourceClientWithBase(rc clients.ResourceClient) MockResourceClient

func NewMockResourceClientWithToken

func NewMockResourceClientWithToken(ctx context.Context, rcFactory factory.ResourceClientFactory, token string) (MockResourceClient, error)

type MockResourceList

type MockResourceList []*MockResource

func (MockResourceList) AsInputResources

func (list MockResourceList) AsInputResources() resources.InputResourceList

func (MockResourceList) AsInterfaces

func (list MockResourceList) AsInterfaces() []interface{}

func (MockResourceList) AsResources

func (list MockResourceList) AsResources() resources.ResourceList

func (MockResourceList) Clone

func (list MockResourceList) Clone() MockResourceList

func (MockResourceList) Each

func (list MockResourceList) Each(f func(element *MockResource))

func (MockResourceList) EachResource

func (list MockResourceList) EachResource(f func(element resources.Resource))

func (MockResourceList) Find

func (list MockResourceList) Find(namespace, name string) (*MockResource, error)

func (MockResourceList) Names

func (list MockResourceList) Names() []string

func (MockResourceList) NamespacesDotNames

func (list MockResourceList) NamespacesDotNames() []string

func (MockResourceList) Sort

func (list MockResourceList) Sort() MockResourceList

type MockResourceReconciler

type MockResourceReconciler interface {
	Reconcile(namespace string, desiredResources MockResourceList, transition TransitionMockResourceFunc, opts clients.ListOpts) error
}

func NewMockResourceReconciler

func NewMockResourceReconciler(client MockResourceClient, statusSetter resources.StatusSetter) MockResourceReconciler

type MockResourceWatcher

type MockResourceWatcher interface {
	// watch namespace-scoped Mocks
	Watch(namespace string, opts clients.WatchOpts) (<-chan MockResourceList, <-chan error, error)
}

type MockResource_Data

type MockResource_Data struct {
	Data string `protobuf:"bytes,1,opt,name=data,json=data.json,proto3,oneof"`
}

type MockResource_OneofOne

type MockResource_OneofOne struct {
	OneofOne string `protobuf:"bytes,3,opt,name=oneof_one,json=oneofOne,proto3,oneof"`
}

type MockResource_OneofTwo

type MockResource_OneofTwo struct {
	OneofTwo bool `protobuf:"varint,2,opt,name=oneof_two,json=oneofTwo,proto3,oneof"`
}

type MockResource_SomeDumbField

type MockResource_SomeDumbField struct {
	SomeDumbField string `protobuf:"bytes,100,opt,name=some_dumb_field,json=someDumbField,proto3,oneof"`
}

type TestingEmitter

type TestingEmitter interface {
	TestingSnapshotEmitter
	Register() error
	MockResource() MockResourceClient
	FrequentlyChangingAnnotationsResource() FrequentlyChangingAnnotationsResourceClient
	FakeResource() testing_solo_io.FakeResourceClient
}

func NewTestingEmitter

func NewTestingEmitter(mockResourceClient MockResourceClient, frequentlyChangingAnnotationsResourceClient FrequentlyChangingAnnotationsResourceClient, fakeResourceClient testing_solo_io.FakeResourceClient) TestingEmitter

func NewTestingEmitterWithEmit

func NewTestingEmitterWithEmit(mockResourceClient MockResourceClient, frequentlyChangingAnnotationsResourceClient FrequentlyChangingAnnotationsResourceClient, fakeResourceClient testing_solo_io.FakeResourceClient, emit <-chan struct{}) TestingEmitter

type TestingSimpleEmitter

type TestingSimpleEmitter interface {
	Snapshots(ctx context.Context) (<-chan *TestingSnapshot, <-chan error, error)
}

func NewTestingSimpleEmitter

func NewTestingSimpleEmitter(aggregatedWatch clients.ResourceWatch) TestingSimpleEmitter

func NewTestingSimpleEmitterWithEmit

func NewTestingSimpleEmitterWithEmit(aggregatedWatch clients.ResourceWatch, emit <-chan struct{}) TestingSimpleEmitter

type TestingSnapshot

func (TestingSnapshot) Clone

func (s TestingSnapshot) Clone() TestingSnapshot

func (TestingSnapshot) Hash

func (s TestingSnapshot) Hash(hasher hash.Hash64) (uint64, error)

func (TestingSnapshot) HashFields

func (s TestingSnapshot) HashFields() []zap.Field

func (TestingSnapshot) Stringer

type TestingSnapshotEmitter added in v0.10.18

type TestingSnapshotEmitter interface {
	Snapshots(watchNamespaces []string, opts clients.WatchOpts) (<-chan *TestingSnapshot, <-chan error, error)
}

type TestingSnapshotStringer

type TestingSnapshotStringer struct {
	Version uint64
	Mocks   []string
	Fcars   []string
	Fakes   []string
}

func (TestingSnapshotStringer) String

func (ss TestingSnapshotStringer) String() string

type TestingSyncDecider deprecated

type TestingSyncDecider interface {
	TestingSyncer
	ShouldSync(old, new *TestingSnapshot) bool
}

Deprecated: use TestingSyncDeciderWithContext

type TestingSyncDeciderWithContext

type TestingSyncDeciderWithContext interface {
	TestingSyncer
	ShouldSync(ctx context.Context, old, new *TestingSnapshot) bool
}

type TestingSyncer

type TestingSyncer interface {
	Sync(context.Context, *TestingSnapshot) error
}

type TestingSyncers

type TestingSyncers []TestingSyncer

func (TestingSyncers) Sync

func (s TestingSyncers) Sync(ctx context.Context, snapshot *TestingSnapshot) error

type TransitionFrequentlyChangingAnnotationsResourceFunc added in v0.10.18

type TransitionFrequentlyChangingAnnotationsResourceFunc func(original, desired *FrequentlyChangingAnnotationsResource) (bool, error)

Option to copy anything from the original to the desired before writing. Return value of false means don't update

type TransitionMockResourceFunc

type TransitionMockResourceFunc func(original, desired *MockResource) (bool, error)

Option to copy anything from the original to the desired before writing. Return value of false means don't update

Directories

Path Synopsis
kube
apis/testing.solo.io/v2alpha1
Package v2alpha1 is the v2alpha1 version of the API.
Package v2alpha1 is the v2alpha1 version of the API.
client/clientset/versioned
This package has the automatically generated clientset.
This package has the automatically generated clientset.
client/clientset/versioned/fake
This package has the automatically generated fake clientset.
This package has the automatically generated fake clientset.
client/clientset/versioned/scheme
This package contains the scheme of the automatically generated clientset.
This package contains the scheme of the automatically generated clientset.
client/clientset/versioned/typed/testing.solo.io/v2alpha1
This package has the automatically generated typed clients.
This package has the automatically generated typed clients.
client/clientset/versioned/typed/testing.solo.io/v2alpha1/fake
Package fake has the automatically generated clients.
Package fake has the automatically generated clients.

Jump to

Keyboard shortcuts

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