v1

package
v0.33.1 Latest Latest
Warning

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

Go to latest
Published: Aug 9, 2023 License: Apache-2.0 Imports: 60 Imported by: 3

Documentation

Index

Constants

View Source
const MockXdsResourceConfigType = types.TypePrefix + "/testing.solo.io.MockXdsResourceConfig"

Variables

View Source
var (
	SimpleMockResource_EnumOptions_name = map[int32]string{
		0: "OPTION_A",
		1: "OPTION_B",
		2: "OPTION_C",
	}
	SimpleMockResource_EnumOptions_value = map[string]int32{
		"OPTION_A": 0,
		"OPTION_B": 1,
		"OPTION_C": 2,
	}
)

Enum value maps for SimpleMockResource_EnumOptions.

View Source
var (
	AnotherMockResourceCrd = crd.NewCrd(
		"anothermockresources",
		AnotherMockResourceGVK.Group,
		AnotherMockResourceGVK.Version,
		AnotherMockResourceGVK.Kind,
		"amr",
		false,
		&AnotherMockResource{})
)
View Source
var (
	AnotherMockResourceGVK = schema.GroupVersionKind{
		Version: "v1",
		Group:   "testing.solo.io",
		Kind:    "AnotherMockResource",
	}
)
View Source
var (
	ClusterResourceCrd = crd.NewCrd(
		"clusterresources",
		ClusterResourceGVK.Group,
		ClusterResourceGVK.Version,
		ClusterResourceGVK.Kind,
		"clr",
		true,
		&ClusterResource{})
)
View Source
var (
	ClusterResourceGVK = schema.GroupVersionKind{
		Version: "v1",
		Group:   "testing.solo.io",
		Kind:    "ClusterResource",
	}
)
View Source
var (
	FakeResourceCrd = crd.NewCrd(
		"fakes",
		FakeResourceGVK.Group,
		FakeResourceGVK.Version,
		FakeResourceGVK.Kind,
		"fk",
		false,
		&FakeResource{})
)
View Source
var (
	FakeResourceGVK = schema.GroupVersionKind{
		Version: "v1",
		Group:   "testing.solo.io",
		Kind:    "FakeResource",
	}
)
View Source
var File_github_com_solo_io_solo_kit_test_mocks_api_v1_mock_resources_proto protoreflect.FileDescriptor
View Source
var File_github_com_solo_io_solo_kit_test_mocks_api_v1_more_mock_resources_proto protoreflect.FileDescriptor
View Source
var File_github_com_solo_io_solo_kit_test_mocks_api_v1_simple_mock_resources_proto protoreflect.FileDescriptor
View Source
var (
	MockCustomSpecHashTypeGVK = schema.GroupVersionKind{
		Version: "v1",
		Group:   "testing.solo.io",
		Kind:    "MockCustomSpecHashType",
	}
)
View Source
var (
	MockCustomTypeGVK = schema.GroupVersionKind{
		Version: "v1",
		Group:   "testing.solo.io",
		Kind:    "MockCustomType",
	}
)
View Source
var (
	MockResourceCrd = crd.NewCrd(
		"mocks",
		MockResourceGVK.Group,
		MockResourceGVK.Version,
		MockResourceGVK.Kind,
		"mk",
		false,
		&MockResource{})
)
View Source
var (
	MockResourceGVK = schema.GroupVersionKind{
		Version: "v1",
		Group:   "testing.solo.io",
		Kind:    "MockResource",
	}
)

Define a type record. This is used by the generic client library.

View Source
var (
	SimpleMockResourceCrd = crd.NewCrd(
		"simplemocks",
		SimpleMockResourceGVK.Group,
		SimpleMockResourceGVK.Version,
		SimpleMockResourceGVK.Kind,
		"smk",
		false,
		&SimpleMockResource{})
)
View Source
var (
	SimpleMockResourceGVK = schema.GroupVersionKind{
		Version: "v1",
		Group:   "testing.solo.io",
		Kind:    "SimpleMockResource",
	}
)

Functions

func NewAnotherMockResourceHashableResource added in v0.30.8

func NewAnotherMockResourceHashableResource() resources.HashableResource

func NewClusterResourceHashableResource added in v0.30.8

func NewClusterResourceHashableResource() resources.HashableResource

func NewFakeResourceHashableResource added in v0.30.8

func NewFakeResourceHashableResource() resources.HashableResource

func NewMockCustomSpecHashTypeHashableResource added in v0.30.8

func NewMockCustomSpecHashTypeHashableResource() resources.HashableResource

func NewMockCustomTypeHashableResource added in v0.30.8

func NewMockCustomTypeHashableResource() resources.HashableResource

func NewMockResourceHashableResource added in v0.30.8

func NewMockResourceHashableResource() resources.HashableResource

func NewMockXdsResourceConfigClient

func NewMockXdsResourceConfigClient(nodeinfo *core.Node, typedApply ApplyMockXdsResourceConfig) client.Client

func NewSimpleMockResourceHashableResource added in v0.30.8

func NewSimpleMockResourceHashableResource() resources.HashableResource

func NewTestingEventLoop

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

func NewTestingSimpleEventLoop

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

func RegisterMockXdsResourceDiscoveryServiceServer

func RegisterMockXdsResourceDiscoveryServiceServer(s *grpc.Server, srv MockXdsResourceDiscoveryServiceServer)

Types

type AnotherMockResource

type AnotherMockResource struct {
	Metadata           *core.Metadata           `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	NamespacedStatuses *core.NamespacedStatuses `protobuf:"bytes,7,opt,name=namespaced_statuses,json=namespacedStatuses,proto3" json:"namespaced_statuses,omitempty"`
	// comments that go above the basic field in our docs
	BasicField string `protobuf:"bytes,2,opt,name=basic_field,json=basicField,proto3" json:"basic_field,omitempty"`
	// contains filtered or unexported fields
}

Description of the AnotherMockResource

func NewAnotherMockResource

func NewAnotherMockResource(namespace, name string) *AnotherMockResource

func (*AnotherMockResource) DeepCopyInto added in v0.11.3

func (o *AnotherMockResource) DeepCopyInto(out *AnotherMockResource)

func (*AnotherMockResource) DeepCopyObject

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

func (*AnotherMockResource) Descriptor deprecated

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

Deprecated: Use AnotherMockResource.ProtoReflect.Descriptor instead.

func (*AnotherMockResource) Equal

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

Equal function

func (*AnotherMockResource) GetBasicField

func (x *AnotherMockResource) GetBasicField() string

func (*AnotherMockResource) GetMetadata

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

func (*AnotherMockResource) GetNamespacedStatuses added in v0.23.0

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

func (*AnotherMockResource) GetObjectKind

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

func (*AnotherMockResource) GetStatus

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

Deprecated

func (*AnotherMockResource) GroupVersionKind added in v0.10.4

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

func (*AnotherMockResource) Hash

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

Hash function

func (*AnotherMockResource) MustHash added in v0.11.16

func (r *AnotherMockResource) MustHash() uint64

func (*AnotherMockResource) ProtoMessage

func (*AnotherMockResource) ProtoMessage()

func (*AnotherMockResource) ProtoReflect added in v0.16.0

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

func (*AnotherMockResource) Reset

func (x *AnotherMockResource) Reset()

func (*AnotherMockResource) SetMetadata

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

func (*AnotherMockResource) SetNamespacedStatuses added in v0.23.0

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

func (*AnotherMockResource) SetStatus

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

Deprecated

func (*AnotherMockResource) String

func (x *AnotherMockResource) String() string

type AnotherMockResourceClient

type AnotherMockResourceClient interface {
	BaseClient() clients.ResourceClient
	Register() error
	Read(namespace, name string, opts clients.ReadOpts) (*AnotherMockResource, error)
	Write(resource *AnotherMockResource, opts clients.WriteOpts) (*AnotherMockResource, error)
	Delete(namespace, name string, opts clients.DeleteOpts) error
	List(namespace string, opts clients.ListOpts) (AnotherMockResourceList, error)
	AnotherMockResourceWatcher
}

func NewAnotherMockResourceClientWithBase

func NewAnotherMockResourceClientWithBase(rc clients.ResourceClient) AnotherMockResourceClient

func NewAnotherMockResourceClientWithToken

func NewAnotherMockResourceClientWithToken(ctx context.Context, rcFactory factory.ResourceClientFactory, token string) (AnotherMockResourceClient, error)

type AnotherMockResourceList

type AnotherMockResourceList []*AnotherMockResource

func (AnotherMockResourceList) AsInputResources

func (list AnotherMockResourceList) AsInputResources() resources.InputResourceList

func (AnotherMockResourceList) AsInterfaces

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

func (AnotherMockResourceList) AsResources

func (list AnotherMockResourceList) AsResources() resources.ResourceList

func (AnotherMockResourceList) Clone

func (AnotherMockResourceList) Each

func (list AnotherMockResourceList) Each(f func(element *AnotherMockResource))

func (AnotherMockResourceList) EachResource

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

func (AnotherMockResourceList) Find

func (list AnotherMockResourceList) Find(namespace, name string) (*AnotherMockResource, error)

func (AnotherMockResourceList) Names

func (list AnotherMockResourceList) Names() []string

func (AnotherMockResourceList) NamespacesDotNames

func (list AnotherMockResourceList) NamespacesDotNames() []string

func (AnotherMockResourceList) Sort

type AnotherMockResourceReconciler

type AnotherMockResourceReconciler interface {
	Reconcile(namespace string, desiredResources AnotherMockResourceList, transition TransitionAnotherMockResourceFunc, opts clients.ListOpts) error
}

type AnotherMockResourceWatcher

type AnotherMockResourceWatcher interface {
	// watch namespace-scoped Anothermockresources
	Watch(namespace string, opts clients.WatchOpts) (<-chan AnotherMockResourceList, <-chan error, error)
}

type ApplyMockXdsResourceConfig

type ApplyMockXdsResourceConfig func(version string, resources []*MockXdsResourceConfig) error

The apply functions receives resources and returns an error if they were applied correctly. In theory the configuration can become valid in the future (i.e. eventually consistent), but I don't think we need to worry about that now As our current use cases only have one configuration resource, so no interactions are expected.

type CloneableMockCustomSpecHashType added in v0.30.4

type CloneableMockCustomSpecHashType interface {
	resources.Resource
	Clone() *github_com_solo_io_solo_kit_test_mocks_api_v1_customtype.MockCustomSpecHashType
}

type ClusterResource

type ClusterResource struct {
	Metadata           *core.Metadata           `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	NamespacedStatuses *core.NamespacedStatuses `protobuf:"bytes,7,opt,name=namespaced_statuses,json=namespacedStatuses,proto3" json:"namespaced_statuses,omitempty"`
	// comments that go above the basic field in our docs
	BasicField string `protobuf:"bytes,2,opt,name=basic_field,json=basicField,proto3" json:"basic_field,omitempty"`
	// contains filtered or unexported fields
}

func NewClusterResource

func NewClusterResource(namespace, name string) *ClusterResource

func (*ClusterResource) DeepCopyInto added in v0.11.3

func (o *ClusterResource) DeepCopyInto(out *ClusterResource)

func (*ClusterResource) DeepCopyObject

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

func (*ClusterResource) Descriptor deprecated

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

Deprecated: Use ClusterResource.ProtoReflect.Descriptor instead.

func (*ClusterResource) Equal

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

Equal function

func (*ClusterResource) GetBasicField

func (x *ClusterResource) GetBasicField() string

func (*ClusterResource) GetMetadata

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

func (*ClusterResource) GetNamespacedStatuses added in v0.23.0

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

func (*ClusterResource) GetObjectKind

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

func (*ClusterResource) GetStatus

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

Deprecated

func (*ClusterResource) GroupVersionKind added in v0.10.4

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

func (*ClusterResource) Hash

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

Hash function

func (*ClusterResource) MustHash added in v0.11.16

func (r *ClusterResource) MustHash() uint64

func (*ClusterResource) ProtoMessage

func (*ClusterResource) ProtoMessage()

func (*ClusterResource) ProtoReflect added in v0.16.0

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

func (*ClusterResource) Reset

func (x *ClusterResource) Reset()

func (*ClusterResource) SetMetadata

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

func (*ClusterResource) SetNamespacedStatuses added in v0.23.0

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

func (*ClusterResource) SetStatus

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

Deprecated

func (*ClusterResource) String

func (x *ClusterResource) String() string

type ClusterResourceClient

type ClusterResourceClient interface {
	BaseClient() clients.ResourceClient
	Register() error
	Read(name string, opts clients.ReadOpts) (*ClusterResource, error)
	Write(resource *ClusterResource, opts clients.WriteOpts) (*ClusterResource, error)
	Delete(name string, opts clients.DeleteOpts) error
	List(opts clients.ListOpts) (ClusterResourceList, error)
	ClusterResourceWatcher
}

func NewClusterResourceClient

func NewClusterResourceClient(ctx context.Context, rcFactory factory.ResourceClientFactory) (ClusterResourceClient, error)

func NewClusterResourceClientWithBase

func NewClusterResourceClientWithBase(rc clients.ResourceClient) ClusterResourceClient

func NewClusterResourceClientWithToken

func NewClusterResourceClientWithToken(ctx context.Context, rcFactory factory.ResourceClientFactory, token string) (ClusterResourceClient, error)

type ClusterResourceList

type ClusterResourceList []*ClusterResource

func (ClusterResourceList) AsInputResources

func (list ClusterResourceList) AsInputResources() resources.InputResourceList

func (ClusterResourceList) AsInterfaces

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

func (ClusterResourceList) AsResources

func (list ClusterResourceList) AsResources() resources.ResourceList

func (ClusterResourceList) Clone

func (ClusterResourceList) Each

func (list ClusterResourceList) Each(f func(element *ClusterResource))

func (ClusterResourceList) EachResource

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

func (ClusterResourceList) Find

func (list ClusterResourceList) Find(namespace, name string) (*ClusterResource, error)

func (ClusterResourceList) Names

func (list ClusterResourceList) Names() []string

func (ClusterResourceList) NamespacesDotNames

func (list ClusterResourceList) NamespacesDotNames() []string

func (ClusterResourceList) Sort

type ClusterResourceReconciler

type ClusterResourceReconciler interface {
	Reconcile(namespace string, desiredResources ClusterResourceList, transition TransitionClusterResourceFunc, opts clients.ListOpts) error
}

func NewClusterResourceReconciler

func NewClusterResourceReconciler(client ClusterResourceClient, statusSetter resources.StatusSetter) ClusterResourceReconciler

type ClusterResourceWatcher

type ClusterResourceWatcher interface {
	// watch cluster-scoped Clusterresources
	Watch(opts clients.WatchOpts) (<-chan ClusterResourceList, <-chan error, error)
}

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,omitempty"`
	// contains filtered or unexported fields
}

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 deprecated

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

Deprecated: Use FakeResource.ProtoReflect.Descriptor instead.

func (*FakeResource) Equal

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

Equal function

func (*FakeResource) GetCount

func (x *FakeResource) GetCount() uint32

func (*FakeResource) GetMetadata

func (x *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) ProtoReflect added in v0.16.0

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

func (*FakeResource) Reset

func (x *FakeResource) Reset()

func (*FakeResource) SetMetadata

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

func (*FakeResource) String

func (x *FakeResource) String() string

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, statusSetter resources.StatusSetter) FakeResourceReconciler

type FakeResourceWatcher

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

type InternalOneOf added in v0.19.0

type InternalOneOf struct {

	// Types that are assignable to Option:
	//
	//	*InternalOneOf_OptionA
	//	*InternalOneOf_OptionB
	Option isInternalOneOf_Option `protobuf_oneof:"option"`
	// contains filtered or unexported fields
}

AnotherNestedOneOf comment

func (*InternalOneOf) Descriptor deprecated added in v0.19.0

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

Deprecated: Use InternalOneOf.ProtoReflect.Descriptor instead.

func (*InternalOneOf) Equal added in v0.19.0

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

Equal function

func (*InternalOneOf) GetOption added in v0.19.0

func (m *InternalOneOf) GetOption() isInternalOneOf_Option

func (*InternalOneOf) GetOptionA added in v0.19.0

func (x *InternalOneOf) GetOptionA() string

func (*InternalOneOf) GetOptionB added in v0.19.0

func (x *InternalOneOf) GetOptionB() string

func (*InternalOneOf) Hash added in v0.19.0

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

Hash function

func (*InternalOneOf) ProtoMessage added in v0.19.0

func (*InternalOneOf) ProtoMessage()

func (*InternalOneOf) ProtoReflect added in v0.19.0

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

func (*InternalOneOf) Reset added in v0.19.0

func (x *InternalOneOf) Reset()

func (*InternalOneOf) String added in v0.19.0

func (x *InternalOneOf) String() string

type InternalOneOf_OptionA added in v0.19.0

type InternalOneOf_OptionA struct {
	OptionA string `protobuf:"bytes,1,opt,name=option_a,json=optionA,proto3,oneof"`
}

type InternalOneOf_OptionB added in v0.19.0

type InternalOneOf_OptionB struct {
	OptionB string `protobuf:"bytes,2,opt,name=option_b,json=optionB,proto3,oneof"`
}

type MockCustomSpecHashType added in v0.30.4

func NewMockCustomSpecHashType added in v0.30.4

func NewMockCustomSpecHashType(namespace, name string) *MockCustomSpecHashType

func (*MockCustomSpecHashType) Clone added in v0.30.4

func (*MockCustomSpecHashType) GroupVersionKind added in v0.30.4

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

func (*MockCustomSpecHashType) Hash added in v0.30.4

func (r *MockCustomSpecHashType) Hash(hasher hash.Hash64) (uint64, error)

func (*MockCustomSpecHashType) MustHash added in v0.30.4

func (r *MockCustomSpecHashType) MustHash() uint64

type MockCustomSpecHashTypeClient added in v0.30.4

type MockCustomSpecHashTypeClient interface {
	BaseClient() clients.ResourceClient
	Register() error
	Read(namespace, name string, opts clients.ReadOpts) (*MockCustomSpecHashType, error)
	Write(resource *MockCustomSpecHashType, opts clients.WriteOpts) (*MockCustomSpecHashType, error)
	Delete(namespace, name string, opts clients.DeleteOpts) error
	List(namespace string, opts clients.ListOpts) (MockCustomSpecHashTypeList, error)
	MockCustomSpecHashTypeWatcher
}

func NewMockCustomSpecHashTypeClient added in v0.30.4

func NewMockCustomSpecHashTypeClient(ctx context.Context, rcFactory factory.ResourceClientFactory) (MockCustomSpecHashTypeClient, error)

func NewMockCustomSpecHashTypeClientWithBase added in v0.30.4

func NewMockCustomSpecHashTypeClientWithBase(rc clients.ResourceClient) MockCustomSpecHashTypeClient

func NewMockCustomSpecHashTypeClientWithToken added in v0.30.4

func NewMockCustomSpecHashTypeClientWithToken(ctx context.Context, rcFactory factory.ResourceClientFactory, token string) (MockCustomSpecHashTypeClient, error)

type MockCustomSpecHashTypeList added in v0.30.4

type MockCustomSpecHashTypeList []*MockCustomSpecHashType

func (MockCustomSpecHashTypeList) AsInterfaces added in v0.30.4

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

func (MockCustomSpecHashTypeList) AsResources added in v0.30.4

func (MockCustomSpecHashTypeList) Clone added in v0.30.4

func (MockCustomSpecHashTypeList) Each added in v0.30.4

func (list MockCustomSpecHashTypeList) Each(f func(element *MockCustomSpecHashType))

func (MockCustomSpecHashTypeList) EachResource added in v0.30.4

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

func (MockCustomSpecHashTypeList) Find added in v0.30.4

func (list MockCustomSpecHashTypeList) Find(namespace, name string) (*MockCustomSpecHashType, error)

func (MockCustomSpecHashTypeList) Names added in v0.30.4

func (list MockCustomSpecHashTypeList) Names() []string

func (MockCustomSpecHashTypeList) NamespacesDotNames added in v0.30.4

func (list MockCustomSpecHashTypeList) NamespacesDotNames() []string

func (MockCustomSpecHashTypeList) Sort added in v0.30.4

type MockCustomSpecHashTypeReconciler added in v0.30.4

type MockCustomSpecHashTypeReconciler interface {
	Reconcile(namespace string, desiredResources MockCustomSpecHashTypeList, transition TransitionMockCustomSpecHashTypeFunc, opts clients.ListOpts) error
}

func NewMockCustomSpecHashTypeReconciler added in v0.30.4

func NewMockCustomSpecHashTypeReconciler(client MockCustomSpecHashTypeClient, statusSetter resources.StatusSetter) MockCustomSpecHashTypeReconciler

type MockCustomSpecHashTypeWatcher added in v0.30.4

type MockCustomSpecHashTypeWatcher interface {
	// watch namespace-scoped mcshts
	Watch(namespace string, opts clients.WatchOpts) (<-chan MockCustomSpecHashTypeList, <-chan error, error)
}

type MockCustomType

func NewMockCustomType

func NewMockCustomType(namespace, name string) *MockCustomType

func (*MockCustomType) Clone

func (r *MockCustomType) Clone() resources.Resource

func (*MockCustomType) GroupVersionKind added in v0.10.4

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

func (*MockCustomType) Hash

func (r *MockCustomType) Hash(hasher hash.Hash64) (uint64, error)

func (*MockCustomType) MustHash added in v0.11.16

func (r *MockCustomType) MustHash() uint64

type MockCustomTypeClient

type MockCustomTypeClient interface {
	BaseClient() clients.ResourceClient
	Register() error
	Read(namespace, name string, opts clients.ReadOpts) (*MockCustomType, error)
	Write(resource *MockCustomType, opts clients.WriteOpts) (*MockCustomType, error)
	Delete(namespace, name string, opts clients.DeleteOpts) error
	List(namespace string, opts clients.ListOpts) (MockCustomTypeList, error)
	MockCustomTypeWatcher
}

func NewMockCustomTypeClient

func NewMockCustomTypeClient(ctx context.Context, rcFactory factory.ResourceClientFactory) (MockCustomTypeClient, error)

func NewMockCustomTypeClientWithBase

func NewMockCustomTypeClientWithBase(rc clients.ResourceClient) MockCustomTypeClient

func NewMockCustomTypeClientWithToken

func NewMockCustomTypeClientWithToken(ctx context.Context, rcFactory factory.ResourceClientFactory, token string) (MockCustomTypeClient, error)

type MockCustomTypeList

type MockCustomTypeList []*MockCustomType

func (MockCustomTypeList) AsInterfaces

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

func (MockCustomTypeList) AsResources

func (list MockCustomTypeList) AsResources() resources.ResourceList

func (MockCustomTypeList) Clone

func (MockCustomTypeList) Each

func (list MockCustomTypeList) Each(f func(element *MockCustomType))

func (MockCustomTypeList) EachResource

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

func (MockCustomTypeList) Find

func (list MockCustomTypeList) Find(namespace, name string) (*MockCustomType, error)

func (MockCustomTypeList) Names

func (list MockCustomTypeList) Names() []string

func (MockCustomTypeList) NamespacesDotNames

func (list MockCustomTypeList) NamespacesDotNames() []string

func (MockCustomTypeList) Sort

type MockCustomTypeReconciler

type MockCustomTypeReconciler interface {
	Reconcile(namespace string, desiredResources MockCustomTypeList, transition TransitionMockCustomTypeFunc, opts clients.ListOpts) error
}

func NewMockCustomTypeReconciler

func NewMockCustomTypeReconciler(client MockCustomTypeClient, statusSetter resources.StatusSetter) MockCustomTypeReconciler

type MockCustomTypeWatcher

type MockCustomTypeWatcher interface {
	// watch namespace-scoped mcts
	Watch(namespace string, opts clients.WatchOpts) (<-chan MockCustomTypeList, <-chan error, error)
}

type MockResource

type MockResource struct {

	// The NamespacedStatuses field comment
	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"`
	Data               string                   `protobuf:"bytes,1,opt,name=data,json=data.json,proto3" json:"data,omitempty"`
	SomeDumbField      string                   `protobuf:"bytes,100,opt,name=some_dumb_field,json=someDumbField,proto3" json:"some_dumb_field,omitempty"`
	// Types that are assignable to TestOneofFields:
	//
	//	*MockResource_OneofOne
	//	*MockResource_OneofTwo
	TestOneofFields isMockResource_TestOneofFields `protobuf_oneof:"test_oneof_fields"`
	// test one of fields comment
	//
	// Types that are assignable to NestedOneofOptions:
	//
	//	*MockResource_OneofNestedoneof
	NestedOneofOptions isMockResource_NestedOneofOptions `protobuf_oneof:"nested_oneof_options"`
	// contains filtered or unexported fields
}

Mock resources for goofin off This includes oneof, nested resources, and any other special cases that may cause issues during schemagen

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 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) GetNestedOneofOptions added in v0.19.0

func (m *MockResource) GetNestedOneofOptions() isMockResource_NestedOneofOptions

func (*MockResource) GetObjectKind

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

func (*MockResource) GetOneofNestedoneof added in v0.19.0

func (x *MockResource) GetOneofNestedoneof() *NestedOneOf

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) 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_OneofNestedoneof added in v0.19.0

type MockResource_OneofNestedoneof struct {
	// oneof comment
	OneofNestedoneof *NestedOneOf `protobuf:"bytes,12,opt,name=oneof_nestedoneof,json=oneofNestedoneof,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 MockXdsResourceConfig

type MockXdsResourceConfig struct {

	// @solo-kit:resource.name
	Domain string `protobuf:"bytes,1,opt,name=domain,proto3" json:"domain,omitempty"`
	// contains filtered or unexported fields
}

@solo-kit:xds-service=MockXdsResourceDiscoveryService @solo-kit:resource.no_references

func (*MockXdsResourceConfig) Descriptor deprecated

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

Deprecated: Use MockXdsResourceConfig.ProtoReflect.Descriptor instead.

func (*MockXdsResourceConfig) Equal

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

Equal function

func (*MockXdsResourceConfig) GetDomain

func (x *MockXdsResourceConfig) GetDomain() string

func (*MockXdsResourceConfig) Hash added in v0.11.14

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

Hash function

func (*MockXdsResourceConfig) ProtoMessage

func (*MockXdsResourceConfig) ProtoMessage()

func (*MockXdsResourceConfig) ProtoReflect added in v0.16.0

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

func (*MockXdsResourceConfig) Reset

func (x *MockXdsResourceConfig) Reset()

func (*MockXdsResourceConfig) String

func (x *MockXdsResourceConfig) String() string

type MockXdsResourceConfigXdsResourceWrapper

type MockXdsResourceConfigXdsResourceWrapper struct {
	// TODO(yuval-k): This is public for mitchellh hashstructure to work properly. consider better alternatives.
	Resource *MockXdsResourceConfig
}

Defined a resource - to be used by snapshot

func NewMockXdsResourceConfigXdsResourceWrapper

func NewMockXdsResourceConfigXdsResourceWrapper(resourceProto *MockXdsResourceConfig) *MockXdsResourceConfigXdsResourceWrapper

func (*MockXdsResourceConfigXdsResourceWrapper) References

func (*MockXdsResourceConfigXdsResourceWrapper) ResourceProto

func (*MockXdsResourceConfigXdsResourceWrapper) Self

type MockXdsResourceDiscoveryServiceClient

type MockXdsResourceDiscoveryServiceClient interface {
	StreamMockXdsResourceConfig(ctx context.Context, opts ...grpc.CallOption) (MockXdsResourceDiscoveryService_StreamMockXdsResourceConfigClient, error)
	DeltaMockXdsResourceConfig(ctx context.Context, opts ...grpc.CallOption) (MockXdsResourceDiscoveryService_DeltaMockXdsResourceConfigClient, error)
	FetchMockXdsResourceConfig(ctx context.Context, in *v2.DiscoveryRequest, opts ...grpc.CallOption) (*v2.DiscoveryResponse, error)
}

MockXdsResourceDiscoveryServiceClient is the client API for MockXdsResourceDiscoveryService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

type MockXdsResourceDiscoveryServiceServer

type MockXdsResourceDiscoveryServiceServer interface {
	StreamMockXdsResourceConfig(MockXdsResourceDiscoveryService_StreamMockXdsResourceConfigServer) error
	DeltaMockXdsResourceConfig(MockXdsResourceDiscoveryService_DeltaMockXdsResourceConfigServer) error
	FetchMockXdsResourceConfig(context.Context, *v2.DiscoveryRequest) (*v2.DiscoveryResponse, error)
}

MockXdsResourceDiscoveryServiceServer is the server API for MockXdsResourceDiscoveryService service.

func NewMockXdsResourceDiscoveryServiceServer

func NewMockXdsResourceDiscoveryServiceServer(genericServer server.Server) MockXdsResourceDiscoveryServiceServer

type MockXdsResourceDiscoveryService_DeltaMockXdsResourceConfigClient

type MockXdsResourceDiscoveryService_DeltaMockXdsResourceConfigClient interface {
	Send(*v2.DeltaDiscoveryRequest) error
	Recv() (*v2.DeltaDiscoveryResponse, error)
	grpc.ClientStream
}

type MockXdsResourceDiscoveryService_DeltaMockXdsResourceConfigServer

type MockXdsResourceDiscoveryService_DeltaMockXdsResourceConfigServer interface {
	Send(*v2.DeltaDiscoveryResponse) error
	Recv() (*v2.DeltaDiscoveryRequest, error)
	grpc.ServerStream
}

type MockXdsResourceDiscoveryService_StreamMockXdsResourceConfigClient

type MockXdsResourceDiscoveryService_StreamMockXdsResourceConfigClient interface {
	Send(*v2.DiscoveryRequest) error
	Recv() (*v2.DiscoveryResponse, error)
	grpc.ClientStream
}

type MockXdsResourceDiscoveryService_StreamMockXdsResourceConfigServer

type MockXdsResourceDiscoveryService_StreamMockXdsResourceConfigServer interface {
	Send(*v2.DiscoveryResponse) error
	Recv() (*v2.DiscoveryRequest, error)
	grpc.ServerStream
}

type NestedOneOf added in v0.19.0

type NestedOneOf struct {

	// oneof comment
	//
	// Types that are assignable to Option:
	//
	//	*NestedOneOf_OptionA
	//	*NestedOneOf_OptionB
	Option isNestedOneOf_Option `protobuf_oneof:"option"`
	// Types that are assignable to AnotherOption:
	//
	//	*NestedOneOf_AnotherOptionA
	//	*NestedOneOf_AnotherOptionB
	AnotherOption isNestedOneOf_AnotherOption `protobuf_oneof:"another_option"`
	// Types that are assignable to NestedOneof:
	//
	//	*NestedOneOf_AnotherNestedOneofOne
	//	*NestedOneOf_AnotherNestedOneofTwo
	NestedOneof isNestedOneOf_NestedOneof `protobuf_oneof:"nested_oneof"`
	// contains filtered or unexported fields
}

A NestedOneOf message

func (*NestedOneOf) Descriptor deprecated added in v0.19.0

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

Deprecated: Use NestedOneOf.ProtoReflect.Descriptor instead.

func (*NestedOneOf) Equal added in v0.19.0

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

Equal function

func (*NestedOneOf) GetAnotherNestedOneofOne added in v0.19.0

func (x *NestedOneOf) GetAnotherNestedOneofOne() *InternalOneOf

func (*NestedOneOf) GetAnotherNestedOneofTwo added in v0.19.0

func (x *NestedOneOf) GetAnotherNestedOneofTwo() *InternalOneOf

func (*NestedOneOf) GetAnotherOption added in v0.19.0

func (m *NestedOneOf) GetAnotherOption() isNestedOneOf_AnotherOption

func (*NestedOneOf) GetAnotherOptionA added in v0.19.0

func (x *NestedOneOf) GetAnotherOptionA() string

func (*NestedOneOf) GetAnotherOptionB added in v0.19.0

func (x *NestedOneOf) GetAnotherOptionB() string

func (*NestedOneOf) GetNestedOneof added in v0.19.0

func (m *NestedOneOf) GetNestedOneof() isNestedOneOf_NestedOneof

func (*NestedOneOf) GetOption added in v0.19.0

func (m *NestedOneOf) GetOption() isNestedOneOf_Option

func (*NestedOneOf) GetOptionA added in v0.19.0

func (x *NestedOneOf) GetOptionA() string

func (*NestedOneOf) GetOptionB added in v0.19.0

func (x *NestedOneOf) GetOptionB() string

func (*NestedOneOf) Hash added in v0.19.0

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

Hash function

func (*NestedOneOf) ProtoMessage added in v0.19.0

func (*NestedOneOf) ProtoMessage()

func (*NestedOneOf) ProtoReflect added in v0.19.0

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

func (*NestedOneOf) Reset added in v0.19.0

func (x *NestedOneOf) Reset()

func (*NestedOneOf) String added in v0.19.0

func (x *NestedOneOf) String() string

type NestedOneOf_AnotherNestedOneofOne added in v0.19.0

type NestedOneOf_AnotherNestedOneofOne struct {
	AnotherNestedOneofOne *InternalOneOf `protobuf:"bytes,21,opt,name=another_nested_oneof_one,json=anotherNestedOneofOne,proto3,oneof"`
}

type NestedOneOf_AnotherNestedOneofTwo added in v0.19.0

type NestedOneOf_AnotherNestedOneofTwo struct {
	AnotherNestedOneofTwo *InternalOneOf `protobuf:"bytes,22,opt,name=another_nested_oneof_two,json=anotherNestedOneofTwo,proto3,oneof"`
}

type NestedOneOf_AnotherOptionA added in v0.19.0

type NestedOneOf_AnotherOptionA struct {
	AnotherOptionA string `protobuf:"bytes,11,opt,name=another_option_a,json=anotherOptionA,proto3,oneof"`
}

type NestedOneOf_AnotherOptionB added in v0.19.0

type NestedOneOf_AnotherOptionB struct {
	AnotherOptionB string `protobuf:"bytes,12,opt,name=another_option_b,json=anotherOptionB,proto3,oneof"`
}

type NestedOneOf_OptionA added in v0.19.0

type NestedOneOf_OptionA struct {
	OptionA string `protobuf:"bytes,1,opt,name=option_a,json=optionA,proto3,oneof"`
}

type NestedOneOf_OptionB added in v0.19.0

type NestedOneOf_OptionB struct {
	OptionB string `protobuf:"bytes,2,opt,name=option_b,json=optionB,proto3,oneof"`
}

type SimpleMockResource added in v0.19.0

type SimpleMockResource struct {

	// metadata comment
	Metadata *core.Metadata `protobuf:"bytes,100,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// data comment
	Data string `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// mapped_data comment
	MappedData map[string]string `` /* 179-byte string literal not displayed */
	// list comment
	List []bool `protobuf:"varint,3,rep,packed,name=list,proto3" json:"list,omitempty"`
	// int64 comment
	Int64Data int64 `protobuf:"varint,6,opt,name=int64_data,json=int64Data,proto3" json:"int64_data,omitempty"`
	// this comment is very long. It should be truncated by the schema generator to avoid
	// generating absurdly large CRDs
	DataWithLongComment string `protobuf:"bytes,7,opt,name=data_with_long_comment,json=dataWithLongComment,proto3" json:"data_with_long_comment,omitempty"`
	// nested_message comment
	NestedMessage *SimpleMockResource_NestedMessage `protobuf:"bytes,4,opt,name=nested_message,json=nestedMessage,proto3" json:"nested_message,omitempty"`
	// nested_message_list comment
	NestedMessageList []*SimpleMockResource_NestedMessage `protobuf:"bytes,5,rep,name=nested_message_list,json=nestedMessageList,proto3" json:"nested_message_list,omitempty"`
	// any comment
	Any *any1.Any `protobuf:"bytes,11,opt,name=any,proto3" json:"any,omitempty"`
	// struct comment
	Struct *_struct.Struct `protobuf:"bytes,12,opt,name=struct,proto3" json:"struct,omitempty"`
	// mapped_struct comment
	MappedStruct map[string]*_struct.Struct `` /* 186-byte string literal not displayed */
	// bool_value comment
	BoolValue *wrappers.BoolValue `protobuf:"bytes,14,opt,name=bool_value,json=boolValue,proto3" json:"bool_value,omitempty"`
	// int32_value comment
	Int32Value *wrappers.Int32Value `protobuf:"bytes,15,opt,name=int32_value,json=int32Value,proto3" json:"int32_value,omitempty"`
	// uint32_value comment
	Uint32Value *wrappers.UInt32Value `protobuf:"bytes,16,opt,name=uint32_value,json=uint32Value,proto3" json:"uint32_value,omitempty"`
	// float_value comment
	FloatValue *wrappers.FloatValue `protobuf:"bytes,17,opt,name=float_value,json=floatValue,proto3" json:"float_value,omitempty"`
	// duration comment
	Duration *duration.Duration `protobuf:"bytes,18,opt,name=duration,proto3" json:"duration,omitempty"`
	// empty comment
	Empty *empty.Empty `protobuf:"bytes,19,opt,name=empty,proto3" json:"empty,omitempty"`
	// string_value comment
	StringValue *wrappers.StringValue `protobuf:"bytes,20,opt,name=string_value,json=stringValue,proto3" json:"string_value,omitempty"`
	// double_value comment
	DoubleValue *wrappers.DoubleValue `protobuf:"bytes,21,opt,name=double_value,json=doubleValue,proto3" json:"double_value,omitempty"`
	// timestamp comment
	Timestamp *timestamp.Timestamp `protobuf:"bytes,22,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// enum_options comment
	EnumOptions SimpleMockResource_EnumOptions `` /* 148-byte string literal not displayed */
	// int64_value comment
	Int64Value *wrappers.Int64Value `protobuf:"bytes,31,opt,name=int64_value,json=int64Value,proto3" json:"int64_value,omitempty"`
	// uint64_value comment
	Uint64Value *wrappers.UInt64Value `protobuf:"bytes,32,opt,name=uint64_value,json=uint64Value,proto3" json:"uint64_value,omitempty"`
	// contains filtered or unexported fields
}

A SimpleMockResource defines a variety of baseline types to ensure that we can generate open api schemas properly. It intentionally avoids messages that include oneof and recursive schemas (like core.solo.io.Status)

func NewSimpleMockResource added in v0.19.0

func NewSimpleMockResource(namespace, name string) *SimpleMockResource

func (*SimpleMockResource) DeepCopyInto added in v0.19.0

func (o *SimpleMockResource) DeepCopyInto(out *SimpleMockResource)

func (*SimpleMockResource) DeepCopyObject added in v0.19.0

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

func (*SimpleMockResource) Descriptor deprecated added in v0.19.0

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

Deprecated: Use SimpleMockResource.ProtoReflect.Descriptor instead.

func (*SimpleMockResource) Equal added in v0.19.0

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

Equal function

func (*SimpleMockResource) GetAny added in v0.19.0

func (x *SimpleMockResource) GetAny() *any1.Any

func (*SimpleMockResource) GetBoolValue added in v0.19.0

func (x *SimpleMockResource) GetBoolValue() *wrappers.BoolValue

func (*SimpleMockResource) GetData added in v0.19.0

func (x *SimpleMockResource) GetData() string

func (*SimpleMockResource) GetDataWithLongComment added in v0.20.2

func (x *SimpleMockResource) GetDataWithLongComment() string

func (*SimpleMockResource) GetDoubleValue added in v0.19.0

func (x *SimpleMockResource) GetDoubleValue() *wrappers.DoubleValue

func (*SimpleMockResource) GetDuration added in v0.19.0

func (x *SimpleMockResource) GetDuration() *duration.Duration

func (*SimpleMockResource) GetEmpty added in v0.19.0

func (x *SimpleMockResource) GetEmpty() *empty.Empty

func (*SimpleMockResource) GetEnumOptions added in v0.19.0

func (*SimpleMockResource) GetFloatValue added in v0.19.0

func (x *SimpleMockResource) GetFloatValue() *wrappers.FloatValue

func (*SimpleMockResource) GetInt32Value added in v0.19.0

func (x *SimpleMockResource) GetInt32Value() *wrappers.Int32Value

func (*SimpleMockResource) GetInt64Data added in v0.20.2

func (x *SimpleMockResource) GetInt64Data() int64

func (*SimpleMockResource) GetInt64Value added in v0.31.2

func (x *SimpleMockResource) GetInt64Value() *wrappers.Int64Value

func (*SimpleMockResource) GetList added in v0.19.0

func (x *SimpleMockResource) GetList() []bool

func (*SimpleMockResource) GetMappedData added in v0.19.0

func (x *SimpleMockResource) GetMappedData() map[string]string

func (*SimpleMockResource) GetMappedStruct added in v0.19.0

func (x *SimpleMockResource) GetMappedStruct() map[string]*_struct.Struct

func (*SimpleMockResource) GetMetadata added in v0.19.0

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

func (*SimpleMockResource) GetNestedMessage added in v0.19.0

func (*SimpleMockResource) GetNestedMessageList added in v0.19.0

func (x *SimpleMockResource) GetNestedMessageList() []*SimpleMockResource_NestedMessage

func (*SimpleMockResource) GetObjectKind added in v0.19.0

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

func (*SimpleMockResource) GetStringValue added in v0.19.0

func (x *SimpleMockResource) GetStringValue() *wrappers.StringValue

func (*SimpleMockResource) GetStruct added in v0.19.0

func (x *SimpleMockResource) GetStruct() *_struct.Struct

func (*SimpleMockResource) GetTimestamp added in v0.19.0

func (x *SimpleMockResource) GetTimestamp() *timestamp.Timestamp

func (*SimpleMockResource) GetUint32Value added in v0.19.0

func (x *SimpleMockResource) GetUint32Value() *wrappers.UInt32Value

func (*SimpleMockResource) GetUint64Value added in v0.31.2

func (x *SimpleMockResource) GetUint64Value() *wrappers.UInt64Value

func (*SimpleMockResource) GroupVersionKind added in v0.19.0

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

func (*SimpleMockResource) Hash added in v0.19.0

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

Hash function

func (*SimpleMockResource) MustHash added in v0.19.0

func (r *SimpleMockResource) MustHash() uint64

func (*SimpleMockResource) ProtoMessage added in v0.19.0

func (*SimpleMockResource) ProtoMessage()

func (*SimpleMockResource) ProtoReflect added in v0.19.0

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

func (*SimpleMockResource) Reset added in v0.19.0

func (x *SimpleMockResource) Reset()

func (*SimpleMockResource) SetMetadata added in v0.19.0

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

func (*SimpleMockResource) String added in v0.19.0

func (x *SimpleMockResource) String() string

type SimpleMockResourceClient added in v0.19.0

type SimpleMockResourceClient interface {
	BaseClient() clients.ResourceClient
	Register() error
	Read(namespace, name string, opts clients.ReadOpts) (*SimpleMockResource, error)
	Write(resource *SimpleMockResource, opts clients.WriteOpts) (*SimpleMockResource, error)
	Delete(namespace, name string, opts clients.DeleteOpts) error
	List(namespace string, opts clients.ListOpts) (SimpleMockResourceList, error)
	SimpleMockResourceWatcher
}

func NewSimpleMockResourceClient added in v0.19.0

func NewSimpleMockResourceClient(ctx context.Context, rcFactory factory.ResourceClientFactory) (SimpleMockResourceClient, error)

func NewSimpleMockResourceClientWithBase added in v0.19.0

func NewSimpleMockResourceClientWithBase(rc clients.ResourceClient) SimpleMockResourceClient

func NewSimpleMockResourceClientWithToken added in v0.19.0

func NewSimpleMockResourceClientWithToken(ctx context.Context, rcFactory factory.ResourceClientFactory, token string) (SimpleMockResourceClient, error)

type SimpleMockResourceList added in v0.19.0

type SimpleMockResourceList []*SimpleMockResource

func (SimpleMockResourceList) AsInterfaces added in v0.19.0

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

func (SimpleMockResourceList) AsResources added in v0.19.0

func (list SimpleMockResourceList) AsResources() resources.ResourceList

func (SimpleMockResourceList) Clone added in v0.19.0

func (SimpleMockResourceList) Each added in v0.19.0

func (list SimpleMockResourceList) Each(f func(element *SimpleMockResource))

func (SimpleMockResourceList) EachResource added in v0.19.0

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

func (SimpleMockResourceList) Find added in v0.19.0

func (list SimpleMockResourceList) Find(namespace, name string) (*SimpleMockResource, error)

func (SimpleMockResourceList) Names added in v0.19.0

func (list SimpleMockResourceList) Names() []string

func (SimpleMockResourceList) NamespacesDotNames added in v0.19.0

func (list SimpleMockResourceList) NamespacesDotNames() []string

func (SimpleMockResourceList) Sort added in v0.19.0

type SimpleMockResourceReconciler added in v0.19.0

type SimpleMockResourceReconciler interface {
	Reconcile(namespace string, desiredResources SimpleMockResourceList, transition TransitionSimpleMockResourceFunc, opts clients.ListOpts) error
}

func NewSimpleMockResourceReconciler added in v0.19.0

func NewSimpleMockResourceReconciler(client SimpleMockResourceClient, statusSetter resources.StatusSetter) SimpleMockResourceReconciler

type SimpleMockResourceWatcher added in v0.19.0

type SimpleMockResourceWatcher interface {
	// watch namespace-scoped Simplemocks
	Watch(namespace string, opts clients.WatchOpts) (<-chan SimpleMockResourceList, <-chan error, error)
}

type SimpleMockResource_EnumOptions added in v0.19.0

type SimpleMockResource_EnumOptions int32
const (
	// option_a comment
	SimpleMockResource_OPTION_A SimpleMockResource_EnumOptions = 0
	// option_b comment
	SimpleMockResource_OPTION_B SimpleMockResource_EnumOptions = 1
	// option_c comment
	SimpleMockResource_OPTION_C SimpleMockResource_EnumOptions = 2
)

func (SimpleMockResource_EnumOptions) Descriptor added in v0.19.0

func (SimpleMockResource_EnumOptions) Enum added in v0.19.0

func (SimpleMockResource_EnumOptions) EnumDescriptor deprecated added in v0.19.0

func (SimpleMockResource_EnumOptions) EnumDescriptor() ([]byte, []int)

Deprecated: Use SimpleMockResource_EnumOptions.Descriptor instead.

func (SimpleMockResource_EnumOptions) Number added in v0.19.0

func (SimpleMockResource_EnumOptions) String added in v0.19.0

func (SimpleMockResource_EnumOptions) Type added in v0.19.0

type SimpleMockResource_NestedMessage added in v0.19.0

type SimpleMockResource_NestedMessage struct {
	OptionBool   bool   `protobuf:"varint,1,opt,name=option_bool,json=optionBool,proto3" json:"option_bool,omitempty"`
	OptionString string `protobuf:"bytes,2,opt,name=option_string,json=optionString,proto3" json:"option_string,omitempty"`
	// contains filtered or unexported fields
}

NestedMessage type comment

func (*SimpleMockResource_NestedMessage) Descriptor deprecated added in v0.19.0

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

Deprecated: Use SimpleMockResource_NestedMessage.ProtoReflect.Descriptor instead.

func (*SimpleMockResource_NestedMessage) Equal added in v0.19.0

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

Equal function

func (*SimpleMockResource_NestedMessage) GetOptionBool added in v0.19.0

func (x *SimpleMockResource_NestedMessage) GetOptionBool() bool

func (*SimpleMockResource_NestedMessage) GetOptionString added in v0.19.0

func (x *SimpleMockResource_NestedMessage) GetOptionString() string

func (*SimpleMockResource_NestedMessage) Hash added in v0.19.0

Hash function

func (*SimpleMockResource_NestedMessage) ProtoMessage added in v0.19.0

func (*SimpleMockResource_NestedMessage) ProtoMessage()

func (*SimpleMockResource_NestedMessage) ProtoReflect added in v0.19.0

func (*SimpleMockResource_NestedMessage) Reset added in v0.19.0

func (*SimpleMockResource_NestedMessage) String added in v0.19.0

type TestingEmitter

type TestingEmitter interface {
	TestingSnapshotEmitter
	Register() error
	SimpleMockResource() SimpleMockResourceClient
	MockResource() MockResourceClient
	FakeResource() FakeResourceClient
	AnotherMockResource() AnotherMockResourceClient
	ClusterResource() ClusterResourceClient
	MockCustomType() MockCustomTypeClient
	MockCustomSpecHashType() MockCustomSpecHashTypeClient
	Pod() github_com_solo_io_solo_kit_pkg_api_v1_resources_common_kubernetes.PodClient
}

func NewTestingEmitter

func NewTestingEmitter(simpleMockResourceClient SimpleMockResourceClient, mockResourceClient MockResourceClient, fakeResourceClient FakeResourceClient, anotherMockResourceClient AnotherMockResourceClient, clusterResourceClient ClusterResourceClient, mockCustomTypeClient MockCustomTypeClient, mockCustomSpecHashTypeClient MockCustomSpecHashTypeClient, podClient github_com_solo_io_solo_kit_pkg_api_v1_resources_common_kubernetes.PodClient) TestingEmitter

func NewTestingEmitterWithEmit

func NewTestingEmitterWithEmit(simpleMockResourceClient SimpleMockResourceClient, mockResourceClient MockResourceClient, fakeResourceClient FakeResourceClient, anotherMockResourceClient AnotherMockResourceClient, clusterResourceClient ClusterResourceClient, mockCustomTypeClient MockCustomTypeClient, mockCustomSpecHashTypeClient MockCustomSpecHashTypeClient, podClient github_com_solo_io_solo_kit_pkg_api_v1_resources_common_kubernetes.PodClient, 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) GetResourcesList added in v0.30.8

func (s *TestingSnapshot) GetResourcesList(resource resources.Resource) (resources.ResourceList, error)

func (TestingSnapshot) Hash

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

func (TestingSnapshot) HashFields

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

func (*TestingSnapshot) RemoveFromResourceList added in v0.30.8

func (s *TestingSnapshot) RemoveFromResourceList(resource resources.Resource) error

func (TestingSnapshot) Stringer

func (*TestingSnapshot) UpsertToResourceList added in v0.30.8

func (s *TestingSnapshot) UpsertToResourceList(resource resources.Resource) error

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
	Simplemocks          []string
	Mocks                []string
	Fakes                []string
	Anothermockresources []string
	Clusterresources     []string
	Mcts                 []string
	Mcshts               []string
	Pods                 []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 TransitionAnotherMockResourceFunc

type TransitionAnotherMockResourceFunc func(original, desired *AnotherMockResource) (bool, error)

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

type TransitionClusterResourceFunc

type TransitionClusterResourceFunc func(original, desired *ClusterResource) (bool, error)

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

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 TransitionMockCustomSpecHashTypeFunc added in v0.30.4

type TransitionMockCustomSpecHashTypeFunc func(original, desired *MockCustomSpecHashType) (bool, error)

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

type TransitionMockCustomTypeFunc

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

type TransitionSimpleMockResourceFunc added in v0.19.0

type TransitionSimpleMockResourceFunc func(original, desired *SimpleMockResource) (bool, error)

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

type UnimplementedMockXdsResourceDiscoveryServiceServer

type UnimplementedMockXdsResourceDiscoveryServiceServer struct {
}

UnimplementedMockXdsResourceDiscoveryServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedMockXdsResourceDiscoveryServiceServer) DeltaMockXdsResourceConfig

func (*UnimplementedMockXdsResourceDiscoveryServiceServer) FetchMockXdsResourceConfig

func (*UnimplementedMockXdsResourceDiscoveryServiceServer) StreamMockXdsResourceConfig

Directories

Path Synopsis
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.

Jump to

Keyboard shortcuts

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