v1

package
v0.28.2 Latest Latest
Warning

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

 Go to latest Published: Jun 21, 2022 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 (
	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",
	}
)
View Source 
var MockXdsResourceConfigTypeRecord = client.NewTypeRecord(
	MockXdsResourceConfigType,

	func() cache.ResourceProto { return &MockXdsResourceConfig{} },

	func(r cache.ResourceProto) cache.Resource {
		return &MockXdsResourceConfigXdsResourceWrapper{Resource: r.(*MockXdsResourceConfig)}
	},
)

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 NewMockXdsResourceConfigClient 

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

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 NewAnotherMockResourceClient 

func NewAnotherMockResourceClient(ctx context.Context, rcFactory factory.ResourceClientFactory) (AnotherMockResourceClient, error)

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 (list AnotherMockResourceList) Clone() AnotherMockResourceList

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 

func (list AnotherMockResourceList) Sort() AnotherMockResourceList

type AnotherMockResourceReconciler 

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

func NewAnotherMockResourceReconciler 

func NewAnotherMockResourceReconciler(client AnotherMockResourceClient, statusSetter resources.StatusSetter) AnotherMockResourceReconciler

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 CloneableMockCustomType 

type CloneableMockCustomType interface {
	resources.Resource
	Clone() *github_com_solo_io_solo_kit_test_mocks_api_v1_customtype.MockCustomType
}

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 (list ClusterResourceList) Clone() ClusterResourceList

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 

func (list ClusterResourceList) Sort() ClusterResourceList

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 MockCustomType 

type MockCustomType struct {
	github_com_solo_io_solo_kit_test_mocks_api_v1_customtype.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 (list MockCustomTypeList) Clone() MockCustomTypeList

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 

func (list MockCustomTypeList) Sort() MockCustomTypeList

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 (e *MockXdsResourceConfigXdsResourceWrapper) References() []cache.XdsResourceReference

func (*MockXdsResourceConfigXdsResourceWrapper) ResourceProto 

func (e *MockXdsResourceConfigXdsResourceWrapper) ResourceProto() cache.ResourceProto

func (*MockXdsResourceConfigXdsResourceWrapper) Self 

func (e *MockXdsResourceConfigXdsResourceWrapper) Self() cache.XdsResourceReference

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.

func NewMockXdsResourceDiscoveryServiceClient 

func NewMockXdsResourceDiscoveryServiceClient(cc grpc.ClientConnInterface) MockXdsResourceDiscoveryServiceClient

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 *any.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 */
	// 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() *any.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 (x *SimpleMockResource) GetEnumOptions() SimpleMockResource_EnumOptions

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) 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 (x *SimpleMockResource) GetNestedMessage() *SimpleMockResource_NestedMessage

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) 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 (list SimpleMockResourceList) Clone() SimpleMockResourceList

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 

func (list SimpleMockResourceList) Sort() SimpleMockResourceList

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) Descriptor() protoreflect.EnumDescriptor

func (SimpleMockResource_EnumOptions) Enum added in v0.19.0 

func (x SimpleMockResource_EnumOptions) Enum() *SimpleMockResource_EnumOptions

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 (x SimpleMockResource_EnumOptions) Number() protoreflect.EnumNumber

func (SimpleMockResource_EnumOptions) String added in v0.19.0 

func (x SimpleMockResource_EnumOptions) String() string

func (SimpleMockResource_EnumOptions) Type added in v0.19.0 

func (SimpleMockResource_EnumOptions) Type() protoreflect.EnumType

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 

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

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 (x *SimpleMockResource_NestedMessage) ProtoReflect() protoreflect.Message

func (*SimpleMockResource_NestedMessage) Reset added in v0.19.0 

func (x *SimpleMockResource_NestedMessage) Reset()

func (*SimpleMockResource_NestedMessage) String added in v0.19.0 

func (x *SimpleMockResource_NestedMessage) String() string

type TestingEmitter 

type TestingEmitter interface {
	TestingSnapshotEmitter
	Register() error
	SimpleMockResource() SimpleMockResourceClient
	MockResource() MockResourceClient
	FakeResource() FakeResourceClient
	AnotherMockResource() AnotherMockResourceClient
	ClusterResource() ClusterResourceClient
	MockCustomType() MockCustomTypeClient
	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, 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, 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 

type TestingSnapshot struct {
	Simplemocks          SimpleMockResourceList
	Mocks                MockResourceList
	Fakes                FakeResourceList
	Anothermockresources AnotherMockResourceList
	Clusterresources     ClusterResourceList
	Mcts                 MockCustomTypeList
	Pods                 github_com_solo_io_solo_kit_pkg_api_v1_resources_common_kubernetes.PodList
}

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
	Simplemocks          []string
	Mocks                []string
	Fakes                []string
	Anothermockresources []string
	Clusterresources     []string
	Mcts                 []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 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) DeltaMockXdsResourceConfig(MockXdsResourceDiscoveryService_DeltaMockXdsResourceConfigServer) error

func (*UnimplementedMockXdsResourceDiscoveryServiceServer) FetchMockXdsResourceConfig 

func (*UnimplementedMockXdsResourceDiscoveryServiceServer) FetchMockXdsResourceConfig(context.Context, *v2.DiscoveryRequest) (*v2.DiscoveryResponse, error)

func (*UnimplementedMockXdsResourceDiscoveryServiceServer) StreamMockXdsResourceConfig 

func (*UnimplementedMockXdsResourceDiscoveryServiceServer) StreamMockXdsResourceConfig(MockXdsResourceDiscoveryService_StreamMockXdsResourceConfigServer) error

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.