v1alpha1

package
v0.14.1 Latest Latest
Warning

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

 Go to latest Published: Oct 29, 2020 License: Apache-2.0 Imports: 40 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	FakeResourceCrd = crd.NewCrd(
		"fakes",
		FakeResourceGVK.Group,
		FakeResourceGVK.Version,
		FakeResourceGVK.Kind,
		"fk",
		false,
		&FakeResource{})
)
View Source 
var (
	FakeResourceGVK = schema.GroupVersionKind{
		Version: "v1alpha1",
		Group:   "crds.testing.solo.io",
		Kind:    "FakeResource",
	}
)
View Source 
var (
	MockResourceCrd = crd.NewCrd(
		"mocks",
		MockResourceGVK.Group,
		MockResourceGVK.Version,
		MockResourceGVK.Kind,
		"mk",
		false,
		&MockResource{})
)
View Source 
var (
	MockResourceGVK = schema.GroupVersionKind{
		Version: "v1alpha1",
		Group:   "crds.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 FakeResource 

type FakeResource struct {
	Count                uint32        `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	Metadata             core.Metadata `protobuf:"bytes,7,opt,name=metadata,proto3" json:"metadata"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func NewFakeResource 

func NewFakeResource(namespace, name string) *FakeResource

func (*FakeResource) DeepCopyInto added in v0.11.3 

func (o *FakeResource) DeepCopyInto(out *FakeResource)

func (*FakeResource) DeepCopyObject 

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

func (*FakeResource) Descriptor 

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

func (*FakeResource) Equal 

func (this *FakeResource) Equal(that interface{}) bool

func (*FakeResource) GetCount 

func (m *FakeResource) GetCount() uint32

func (*FakeResource) GetMetadata 

func (m *FakeResource) GetMetadata() core.Metadata

func (*FakeResource) GetObjectKind 

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

func (*FakeResource) GroupVersionKind added in v0.10.4 

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

func (*FakeResource) Hash 

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

Hash function

func (*FakeResource) MustHash added in v0.11.16 

func (r *FakeResource) MustHash() uint64

func (*FakeResource) ProtoMessage 

func (*FakeResource) ProtoMessage()

func (*FakeResource) Reset 

func (m *FakeResource) Reset()

func (*FakeResource) SetMetadata 

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

func (*FakeResource) String 

func (m *FakeResource) String() string

func (*FakeResource) XXX_DiscardUnknown 

func (m *FakeResource) XXX_DiscardUnknown()

func (*FakeResource) XXX_Marshal 

func (m *FakeResource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FakeResource) XXX_Merge 

func (m *FakeResource) XXX_Merge(src proto.Message)

func (*FakeResource) XXX_Size 

func (m *FakeResource) XXX_Size() int

func (*FakeResource) XXX_Unmarshal 

func (m *FakeResource) XXX_Unmarshal(b []byte) error

type FakeResourceClient 

type FakeResourceClient interface {
	BaseClient() clients.ResourceClient
	Register() error
	Read(namespace, name string, opts clients.ReadOpts) (*FakeResource, error)
	Write(resource *FakeResource, opts clients.WriteOpts) (*FakeResource, error)
	Delete(namespace, name string, opts clients.DeleteOpts) error
	List(namespace string, opts clients.ListOpts) (FakeResourceList, error)
	FakeResourceWatcher
}

func NewFakeResourceClient 

func NewFakeResourceClient(ctx context.Context, rcFactory factory.ResourceClientFactory) (FakeResourceClient, error)

func NewFakeResourceClientWithBase 

func NewFakeResourceClientWithBase(rc clients.ResourceClient) FakeResourceClient

func NewFakeResourceClientWithToken 

func NewFakeResourceClientWithToken(ctx context.Context, rcFactory factory.ResourceClientFactory, token string) (FakeResourceClient, error)

type FakeResourceList 

type FakeResourceList []*FakeResource

func (FakeResourceList) AsInterfaces 

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

func (FakeResourceList) AsResources 

func (list FakeResourceList) AsResources() resources.ResourceList

func (FakeResourceList) Clone 

func (list FakeResourceList) Clone() FakeResourceList

func (FakeResourceList) Each 

func (list FakeResourceList) Each(f func(element *FakeResource))

func (FakeResourceList) EachResource 

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

func (FakeResourceList) Find 

func (list FakeResourceList) Find(namespace, name string) (*FakeResource, error)

func (FakeResourceList) Names 

func (list FakeResourceList) Names() []string

func (FakeResourceList) NamespacesDotNames 

func (list FakeResourceList) NamespacesDotNames() []string

func (FakeResourceList) Sort 

func (list FakeResourceList) Sort() FakeResourceList

type FakeResourceReconciler 

type FakeResourceReconciler interface {
	Reconcile(namespace string, desiredResources FakeResourceList, transition TransitionFakeResourceFunc, opts clients.ListOpts) error
}

func NewFakeResourceReconciler 

func NewFakeResourceReconciler(client FakeResourceClient) FakeResourceReconciler

type FakeResourceWatcher 

type FakeResourceWatcher interface {
	// watch namespace-scoped Fakes
	Watch(namespace string, opts clients.WatchOpts) (<-chan FakeResourceList, <-chan error, error)
}

type MockResource 

type MockResource struct {
	Status        core.Status   `protobuf:"bytes,6,opt,name=status,proto3" json:"status"`
	Metadata      core.Metadata `protobuf:"bytes,7,opt,name=metadata,proto3" json:"metadata"`
	Data          string        `protobuf:"bytes,1,opt,name=data,json=data.json,proto3" json:"data.json"`
	SomeDumbField string        `protobuf:"bytes,100,opt,name=some_dumb_field,json=someDumbField,proto3" json:"some_dumb_field,omitempty"`
	// Types that are valid to be assigned to TestOneofFields:
	//	*MockResource_OneofOne
	//	*MockResource_OneofTwo
	TestOneofFields      isMockResource_TestOneofFields `protobuf_oneof:"test_oneof_fields"`
	XXX_NoUnkeyedLiteral struct{}                       `json:"-"`
	XXX_unrecognized     []byte                         `json:"-"`
	XXX_sizecache        int32                          `json:"-"`
}

Mock resources for goofin off

func NewMockResource 

func NewMockResource(namespace, name string) *MockResource

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 

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

func (*MockResource) Equal 

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

func (*MockResource) GetData 

func (m *MockResource) GetData() string

func (*MockResource) GetMetadata 

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

func (*MockResource) GetObjectKind 

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

func (*MockResource) GetOneofOne 

func (m *MockResource) GetOneofOne() string

func (*MockResource) GetOneofTwo 

func (m *MockResource) GetOneofTwo() bool

func (*MockResource) GetSomeDumbField 

func (m *MockResource) GetSomeDumbField() string

func (*MockResource) GetStatus 

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

func (*MockResource) GetTestOneofFields 

func (m *MockResource) GetTestOneofFields() isMockResource_TestOneofFields

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) Reset 

func (m *MockResource) Reset()

func (*MockResource) SetMetadata 

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

func (*MockResource) SetStatus 

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

func (*MockResource) String 

func (m *MockResource) String() string

func (*MockResource) XXX_DiscardUnknown 

func (m *MockResource) XXX_DiscardUnknown()

func (*MockResource) XXX_Marshal 

func (m *MockResource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MockResource) XXX_Merge 

func (m *MockResource) XXX_Merge(src proto.Message)

func (*MockResource) XXX_OneofWrappers added in v0.10.14 

func (*MockResource) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*MockResource) XXX_Size 

func (m *MockResource) XXX_Size() int

func (*MockResource) XXX_Unmarshal 

func (m *MockResource) XXX_Unmarshal(b []byte) error

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) MockResourceReconciler

type MockResourceWatcher 

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

type MockResource_OneofOne 

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

func (*MockResource_OneofOne) Equal 

func (this *MockResource_OneofOne) Equal(that interface{}) bool

type MockResource_OneofTwo 

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

func (*MockResource_OneofTwo) Equal 

func (this *MockResource_OneofTwo) Equal(that interface{}) bool

type TestingEmitter 

type TestingEmitter interface {
	TestingSnapshotEmitter
	Register() error
	MockResource() MockResourceClient
}

func NewTestingEmitter 

func NewTestingEmitter(mockResourceClient MockResourceClient) TestingEmitter

func NewTestingEmitterWithEmit 

func NewTestingEmitterWithEmit(mockResourceClient MockResourceClient, 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 

type TestingSnapshot struct {
	Mocks MockResourceList
}

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 

func (s TestingSnapshot) Stringer() TestingSnapshotStringer

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
}

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 TransitionFakeResourceFunc 

type TransitionFakeResourceFunc func(original, desired *FakeResource) (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

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.