Documentation
¶
Index ¶
- Constants
- Variables
- func NewMockXdsResourceConfigClient(nodeinfo *core.Node, typedApply ApplyMockXdsResourceConfig) client.Client
- func NewTestingEventLoop(emitter TestingSnapshotEmitter, syncer TestingSyncer) eventloop.EventLoop
- func NewTestingSimpleEventLoop(emitter TestingSimpleEmitter, syncers ...TestingSyncer) eventloop.SimpleEventLoop
- func RegisterMockXdsResourceDiscoveryServiceServer(s *grpc.Server, srv MockXdsResourceDiscoveryServiceServer)
- type AnotherMockResource
- func (o *AnotherMockResource) DeepCopyInto(out *AnotherMockResource)
- func (o *AnotherMockResource) DeepCopyObject() runtime.Object
- func (*AnotherMockResource) Descriptor() ([]byte, []int)deprecated
- func (m *AnotherMockResource) Equal(that interface{}) bool
- func (x *AnotherMockResource) GetBasicField() string
- func (x *AnotherMockResource) GetMetadata() *core.Metadata
- func (x *AnotherMockResource) GetNamespacedStatuses() *core.NamespacedStatuses
- func (o *AnotherMockResource) GetObjectKind() schema.ObjectKind
- func (r *AnotherMockResource) GetStatus() *core.Status
- func (r *AnotherMockResource) GroupVersionKind() schema.GroupVersionKind
- func (m *AnotherMockResource) Hash(hasher hash.Hash64) (uint64, error)
- func (r *AnotherMockResource) MustHash() uint64
- func (*AnotherMockResource) ProtoMessage()
- func (x *AnotherMockResource) ProtoReflect() protoreflect.Message
- func (x *AnotherMockResource) Reset()
- func (r *AnotherMockResource) SetMetadata(meta *core.Metadata)
- func (r *AnotherMockResource) SetNamespacedStatuses(namespacedStatuses *core.NamespacedStatuses)
- func (r *AnotherMockResource) SetStatus(status *core.Status)
- func (x *AnotherMockResource) String() string
- type AnotherMockResourceClient
- func NewAnotherMockResourceClient(ctx context.Context, rcFactory factory.ResourceClientFactory) (AnotherMockResourceClient, error)
- func NewAnotherMockResourceClientWithBase(rc clients.ResourceClient) AnotherMockResourceClient
- func NewAnotherMockResourceClientWithToken(ctx context.Context, rcFactory factory.ResourceClientFactory, token string) (AnotherMockResourceClient, error)
- type AnotherMockResourceList
- func (list AnotherMockResourceList) AsInputResources() resources.InputResourceList
- func (list AnotherMockResourceList) AsInterfaces() []interface{}
- func (list AnotherMockResourceList) AsResources() resources.ResourceList
- func (list AnotherMockResourceList) Clone() AnotherMockResourceList
- func (list AnotherMockResourceList) Each(f func(element *AnotherMockResource))
- func (list AnotherMockResourceList) EachResource(f func(element resources.Resource))
- func (list AnotherMockResourceList) Find(namespace, name string) (*AnotherMockResource, error)
- func (list AnotherMockResourceList) Names() []string
- func (list AnotherMockResourceList) NamespacesDotNames() []string
- func (list AnotherMockResourceList) Sort() AnotherMockResourceList
- type AnotherMockResourceReconciler
- type AnotherMockResourceWatcher
- type ApplyMockXdsResourceConfig
- type CloneableMockCustomType
- type ClusterResource
- func (o *ClusterResource) DeepCopyInto(out *ClusterResource)
- func (o *ClusterResource) DeepCopyObject() runtime.Object
- func (*ClusterResource) Descriptor() ([]byte, []int)deprecated
- func (m *ClusterResource) Equal(that interface{}) bool
- func (x *ClusterResource) GetBasicField() string
- func (x *ClusterResource) GetMetadata() *core.Metadata
- func (x *ClusterResource) GetNamespacedStatuses() *core.NamespacedStatuses
- func (o *ClusterResource) GetObjectKind() schema.ObjectKind
- func (r *ClusterResource) GetStatus() *core.Status
- func (r *ClusterResource) GroupVersionKind() schema.GroupVersionKind
- func (m *ClusterResource) Hash(hasher hash.Hash64) (uint64, error)
- func (r *ClusterResource) MustHash() uint64
- func (*ClusterResource) ProtoMessage()
- func (x *ClusterResource) ProtoReflect() protoreflect.Message
- func (x *ClusterResource) Reset()
- func (r *ClusterResource) SetMetadata(meta *core.Metadata)
- func (r *ClusterResource) SetNamespacedStatuses(namespacedStatuses *core.NamespacedStatuses)
- func (r *ClusterResource) SetStatus(status *core.Status)
- func (x *ClusterResource) String() string
- type ClusterResourceClient
- func NewClusterResourceClient(ctx context.Context, rcFactory factory.ResourceClientFactory) (ClusterResourceClient, error)
- func NewClusterResourceClientWithBase(rc clients.ResourceClient) ClusterResourceClient
- func NewClusterResourceClientWithToken(ctx context.Context, rcFactory factory.ResourceClientFactory, token string) (ClusterResourceClient, error)
- type ClusterResourceList
- func (list ClusterResourceList) AsInputResources() resources.InputResourceList
- func (list ClusterResourceList) AsInterfaces() []interface{}
- func (list ClusterResourceList) AsResources() resources.ResourceList
- func (list ClusterResourceList) Clone() ClusterResourceList
- func (list ClusterResourceList) Each(f func(element *ClusterResource))
- func (list ClusterResourceList) EachResource(f func(element resources.Resource))
- func (list ClusterResourceList) Find(namespace, name string) (*ClusterResource, error)
- func (list ClusterResourceList) Names() []string
- func (list ClusterResourceList) NamespacesDotNames() []string
- func (list ClusterResourceList) Sort() ClusterResourceList
- type ClusterResourceReconciler
- type ClusterResourceWatcher
- type FakeResource
- func (o *FakeResource) DeepCopyInto(out *FakeResource)
- func (o *FakeResource) DeepCopyObject() runtime.Object
- func (*FakeResource) Descriptor() ([]byte, []int)deprecated
- func (m *FakeResource) Equal(that interface{}) bool
- func (x *FakeResource) GetCount() uint32
- func (x *FakeResource) GetMetadata() *core.Metadata
- func (o *FakeResource) GetObjectKind() schema.ObjectKind
- func (r *FakeResource) GroupVersionKind() schema.GroupVersionKind
- func (m *FakeResource) Hash(hasher hash.Hash64) (uint64, error)
- func (r *FakeResource) MustHash() uint64
- func (*FakeResource) ProtoMessage()
- func (x *FakeResource) ProtoReflect() protoreflect.Message
- func (x *FakeResource) Reset()
- func (r *FakeResource) SetMetadata(meta *core.Metadata)
- func (x *FakeResource) String() string
- type FakeResourceClient
- func NewFakeResourceClient(ctx context.Context, rcFactory factory.ResourceClientFactory) (FakeResourceClient, error)
- func NewFakeResourceClientWithBase(rc clients.ResourceClient) FakeResourceClient
- func NewFakeResourceClientWithToken(ctx context.Context, rcFactory factory.ResourceClientFactory, token string) (FakeResourceClient, error)
- type FakeResourceList
- func (list FakeResourceList) AsInterfaces() []interface{}
- func (list FakeResourceList) AsResources() resources.ResourceList
- func (list FakeResourceList) Clone() FakeResourceList
- func (list FakeResourceList) Each(f func(element *FakeResource))
- func (list FakeResourceList) EachResource(f func(element resources.Resource))
- func (list FakeResourceList) Find(namespace, name string) (*FakeResource, error)
- func (list FakeResourceList) Names() []string
- func (list FakeResourceList) NamespacesDotNames() []string
- func (list FakeResourceList) Sort() FakeResourceList
- type FakeResourceReconciler
- type FakeResourceWatcher
- type InternalOneOf
- func (*InternalOneOf) Descriptor() ([]byte, []int)deprecated
- func (m *InternalOneOf) Equal(that interface{}) bool
- func (m *InternalOneOf) GetOption() isInternalOneOf_Option
- func (x *InternalOneOf) GetOptionA() string
- func (x *InternalOneOf) GetOptionB() string
- func (m *InternalOneOf) Hash(hasher hash.Hash64) (uint64, error)
- func (*InternalOneOf) ProtoMessage()
- func (x *InternalOneOf) ProtoReflect() protoreflect.Message
- func (x *InternalOneOf) Reset()
- func (x *InternalOneOf) String() string
- type InternalOneOf_OptionA
- type InternalOneOf_OptionB
- type MockCustomType
- type MockCustomTypeClient
- func NewMockCustomTypeClient(ctx context.Context, rcFactory factory.ResourceClientFactory) (MockCustomTypeClient, error)
- func NewMockCustomTypeClientWithBase(rc clients.ResourceClient) MockCustomTypeClient
- func NewMockCustomTypeClientWithToken(ctx context.Context, rcFactory factory.ResourceClientFactory, token string) (MockCustomTypeClient, error)
- type MockCustomTypeList
- func (list MockCustomTypeList) AsInterfaces() []interface{}
- func (list MockCustomTypeList) AsResources() resources.ResourceList
- func (list MockCustomTypeList) Clone() MockCustomTypeList
- func (list MockCustomTypeList) Each(f func(element *MockCustomType))
- func (list MockCustomTypeList) EachResource(f func(element resources.Resource))
- func (list MockCustomTypeList) Find(namespace, name string) (*MockCustomType, error)
- func (list MockCustomTypeList) Names() []string
- func (list MockCustomTypeList) NamespacesDotNames() []string
- func (list MockCustomTypeList) Sort() MockCustomTypeList
- type MockCustomTypeReconciler
- type MockCustomTypeWatcher
- type MockResource
- func (o *MockResource) DeepCopyInto(out *MockResource)
- func (o *MockResource) DeepCopyObject() runtime.Object
- func (*MockResource) Descriptor() ([]byte, []int)deprecated
- func (m *MockResource) Equal(that interface{}) bool
- func (x *MockResource) GetData() string
- func (x *MockResource) GetMetadata() *core.Metadata
- func (x *MockResource) GetNamespacedStatuses() *core.NamespacedStatuses
- func (m *MockResource) GetNestedOneofOptions() isMockResource_NestedOneofOptions
- func (o *MockResource) GetObjectKind() schema.ObjectKind
- func (x *MockResource) GetOneofNestedoneof() *NestedOneOf
- func (x *MockResource) GetOneofOne() string
- func (x *MockResource) GetOneofTwo() bool
- func (x *MockResource) GetSomeDumbField() string
- func (r *MockResource) GetStatus() *core.Status
- func (m *MockResource) GetTestOneofFields() isMockResource_TestOneofFields
- func (r *MockResource) GroupVersionKind() schema.GroupVersionKind
- func (m *MockResource) Hash(hasher hash.Hash64) (uint64, error)
- func (r *MockResource) MustHash() uint64
- func (*MockResource) ProtoMessage()
- func (x *MockResource) ProtoReflect() protoreflect.Message
- func (x *MockResource) Reset()
- func (r *MockResource) SetMetadata(meta *core.Metadata)
- func (r *MockResource) SetNamespacedStatuses(namespacedStatuses *core.NamespacedStatuses)
- func (r *MockResource) SetStatus(status *core.Status)
- func (x *MockResource) String() string
- type MockResourceClient
- func NewMockResourceClient(ctx context.Context, rcFactory factory.ResourceClientFactory) (MockResourceClient, error)
- func NewMockResourceClientWithBase(rc clients.ResourceClient) MockResourceClient
- func NewMockResourceClientWithToken(ctx context.Context, rcFactory factory.ResourceClientFactory, token string) (MockResourceClient, error)
- type MockResourceList
- func (list MockResourceList) AsInputResources() resources.InputResourceList
- func (list MockResourceList) AsInterfaces() []interface{}
- func (list MockResourceList) AsResources() resources.ResourceList
- func (list MockResourceList) Clone() MockResourceList
- func (list MockResourceList) Each(f func(element *MockResource))
- func (list MockResourceList) EachResource(f func(element resources.Resource))
- func (list MockResourceList) Find(namespace, name string) (*MockResource, error)
- func (list MockResourceList) Names() []string
- func (list MockResourceList) NamespacesDotNames() []string
- func (list MockResourceList) Sort() MockResourceList
- type MockResourceReconciler
- type MockResourceWatcher
- type MockResource_OneofNestedoneof
- type MockResource_OneofOne
- type MockResource_OneofTwo
- type MockXdsResourceConfig
- func (*MockXdsResourceConfig) Descriptor() ([]byte, []int)deprecated
- func (m *MockXdsResourceConfig) Equal(that interface{}) bool
- func (x *MockXdsResourceConfig) GetDomain() string
- func (m *MockXdsResourceConfig) Hash(hasher hash.Hash64) (uint64, error)
- func (*MockXdsResourceConfig) ProtoMessage()
- func (x *MockXdsResourceConfig) ProtoReflect() protoreflect.Message
- func (x *MockXdsResourceConfig) Reset()
- func (x *MockXdsResourceConfig) String() string
- type MockXdsResourceConfigXdsResourceWrapper
- type MockXdsResourceDiscoveryServiceClient
- type MockXdsResourceDiscoveryServiceServer
- type MockXdsResourceDiscoveryService_DeltaMockXdsResourceConfigClient
- type MockXdsResourceDiscoveryService_DeltaMockXdsResourceConfigServer
- type MockXdsResourceDiscoveryService_StreamMockXdsResourceConfigClient
- type MockXdsResourceDiscoveryService_StreamMockXdsResourceConfigServer
- type NestedOneOf
- func (*NestedOneOf) Descriptor() ([]byte, []int)deprecated
- func (m *NestedOneOf) Equal(that interface{}) bool
- func (x *NestedOneOf) GetAnotherNestedOneofOne() *InternalOneOf
- func (x *NestedOneOf) GetAnotherNestedOneofTwo() *InternalOneOf
- func (m *NestedOneOf) GetAnotherOption() isNestedOneOf_AnotherOption
- func (x *NestedOneOf) GetAnotherOptionA() string
- func (x *NestedOneOf) GetAnotherOptionB() string
- func (m *NestedOneOf) GetNestedOneof() isNestedOneOf_NestedOneof
- func (m *NestedOneOf) GetOption() isNestedOneOf_Option
- func (x *NestedOneOf) GetOptionA() string
- func (x *NestedOneOf) GetOptionB() string
- func (m *NestedOneOf) Hash(hasher hash.Hash64) (uint64, error)
- func (*NestedOneOf) ProtoMessage()
- func (x *NestedOneOf) ProtoReflect() protoreflect.Message
- func (x *NestedOneOf) Reset()
- func (x *NestedOneOf) String() string
- type NestedOneOf_AnotherNestedOneofOne
- type NestedOneOf_AnotherNestedOneofTwo
- type NestedOneOf_AnotherOptionA
- type NestedOneOf_AnotherOptionB
- type NestedOneOf_OptionA
- type NestedOneOf_OptionB
- type SimpleMockResource
- func (o *SimpleMockResource) DeepCopyInto(out *SimpleMockResource)
- func (o *SimpleMockResource) DeepCopyObject() runtime.Object
- func (*SimpleMockResource) Descriptor() ([]byte, []int)deprecated
- func (m *SimpleMockResource) Equal(that interface{}) bool
- func (x *SimpleMockResource) GetAny() *any.Any
- func (x *SimpleMockResource) GetBoolValue() *wrappers.BoolValue
- func (x *SimpleMockResource) GetData() string
- func (x *SimpleMockResource) GetDataWithLongComment() string
- func (x *SimpleMockResource) GetDoubleValue() *wrappers.DoubleValue
- func (x *SimpleMockResource) GetDuration() *duration.Duration
- func (x *SimpleMockResource) GetEmpty() *empty.Empty
- func (x *SimpleMockResource) GetEnumOptions() SimpleMockResource_EnumOptions
- func (x *SimpleMockResource) GetFloatValue() *wrappers.FloatValue
- func (x *SimpleMockResource) GetInt32Value() *wrappers.Int32Value
- func (x *SimpleMockResource) GetInt64Data() int64
- func (x *SimpleMockResource) GetList() []bool
- func (x *SimpleMockResource) GetMappedData() map[string]string
- func (x *SimpleMockResource) GetMappedStruct() map[string]*_struct.Struct
- func (x *SimpleMockResource) GetMetadata() *core.Metadata
- func (x *SimpleMockResource) GetNestedMessage() *SimpleMockResource_NestedMessage
- func (x *SimpleMockResource) GetNestedMessageList() []*SimpleMockResource_NestedMessage
- func (o *SimpleMockResource) GetObjectKind() schema.ObjectKind
- func (x *SimpleMockResource) GetStringValue() *wrappers.StringValue
- func (x *SimpleMockResource) GetStruct() *_struct.Struct
- func (x *SimpleMockResource) GetTimestamp() *timestamp.Timestamp
- func (x *SimpleMockResource) GetUint32Value() *wrappers.UInt32Value
- func (r *SimpleMockResource) GroupVersionKind() schema.GroupVersionKind
- func (m *SimpleMockResource) Hash(hasher hash.Hash64) (uint64, error)
- func (r *SimpleMockResource) MustHash() uint64
- func (*SimpleMockResource) ProtoMessage()
- func (x *SimpleMockResource) ProtoReflect() protoreflect.Message
- func (x *SimpleMockResource) Reset()
- func (r *SimpleMockResource) SetMetadata(meta *core.Metadata)
- func (x *SimpleMockResource) String() string
- type SimpleMockResourceClient
- func NewSimpleMockResourceClient(ctx context.Context, rcFactory factory.ResourceClientFactory) (SimpleMockResourceClient, error)
- func NewSimpleMockResourceClientWithBase(rc clients.ResourceClient) SimpleMockResourceClient
- func NewSimpleMockResourceClientWithToken(ctx context.Context, rcFactory factory.ResourceClientFactory, token string) (SimpleMockResourceClient, error)
- type SimpleMockResourceList
- func (list SimpleMockResourceList) AsInterfaces() []interface{}
- func (list SimpleMockResourceList) AsResources() resources.ResourceList
- func (list SimpleMockResourceList) Clone() SimpleMockResourceList
- func (list SimpleMockResourceList) Each(f func(element *SimpleMockResource))
- func (list SimpleMockResourceList) EachResource(f func(element resources.Resource))
- func (list SimpleMockResourceList) Find(namespace, name string) (*SimpleMockResource, error)
- func (list SimpleMockResourceList) Names() []string
- func (list SimpleMockResourceList) NamespacesDotNames() []string
- func (list SimpleMockResourceList) Sort() SimpleMockResourceList
- type SimpleMockResourceReconciler
- type SimpleMockResourceWatcher
- type SimpleMockResource_EnumOptions
- func (SimpleMockResource_EnumOptions) Descriptor() protoreflect.EnumDescriptor
- func (x SimpleMockResource_EnumOptions) Enum() *SimpleMockResource_EnumOptions
- func (SimpleMockResource_EnumOptions) EnumDescriptor() ([]byte, []int)deprecated
- func (x SimpleMockResource_EnumOptions) Number() protoreflect.EnumNumber
- func (x SimpleMockResource_EnumOptions) String() string
- func (SimpleMockResource_EnumOptions) Type() protoreflect.EnumType
- type SimpleMockResource_NestedMessage
- func (*SimpleMockResource_NestedMessage) Descriptor() ([]byte, []int)deprecated
- func (m *SimpleMockResource_NestedMessage) Equal(that interface{}) bool
- func (x *SimpleMockResource_NestedMessage) GetOptionBool() bool
- func (x *SimpleMockResource_NestedMessage) GetOptionString() string
- func (m *SimpleMockResource_NestedMessage) Hash(hasher hash.Hash64) (uint64, error)
- func (*SimpleMockResource_NestedMessage) ProtoMessage()
- func (x *SimpleMockResource_NestedMessage) ProtoReflect() protoreflect.Message
- func (x *SimpleMockResource_NestedMessage) Reset()
- func (x *SimpleMockResource_NestedMessage) String() string
- type TestingEmitter
- type TestingSimpleEmitter
- type TestingSnapshot
- type TestingSnapshotEmitter
- type TestingSnapshotStringer
- type TestingSyncDeciderdeprecated
- type TestingSyncDeciderWithContext
- type TestingSyncer
- type TestingSyncers
- type TransitionAnotherMockResourceFunc
- type TransitionClusterResourceFunc
- type TransitionFakeResourceFunc
- type TransitionMockCustomTypeFunc
- type TransitionMockResourceFunc
- type TransitionSimpleMockResourceFunc
- type UnimplementedMockXdsResourceDiscoveryServiceServer
- func (*UnimplementedMockXdsResourceDiscoveryServiceServer) DeltaMockXdsResourceConfig(MockXdsResourceDiscoveryService_DeltaMockXdsResourceConfigServer) error
- func (*UnimplementedMockXdsResourceDiscoveryServiceServer) FetchMockXdsResourceConfig(context.Context, *v2.DiscoveryRequest) (*v2.DiscoveryResponse, error)
- func (*UnimplementedMockXdsResourceDiscoveryServiceServer) StreamMockXdsResourceConfig(MockXdsResourceDiscoveryService_StreamMockXdsResourceConfigServer) error
Constants ¶
const MockXdsResourceConfigType = types.TypePrefix + "/testing.solo.io.MockXdsResourceConfig"
Variables ¶
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.
var (
AnotherMockResourceCrd = crd.NewCrd(
"anothermockresources",
AnotherMockResourceGVK.Group,
AnotherMockResourceGVK.Version,
AnotherMockResourceGVK.Kind,
"amr",
false,
&AnotherMockResource{})
)
var (
AnotherMockResourceGVK = schema.GroupVersionKind{
Version: "v1",
Group: "testing.solo.io",
Kind: "AnotherMockResource",
}
)
var (
ClusterResourceCrd = crd.NewCrd(
"clusterresources",
ClusterResourceGVK.Group,
ClusterResourceGVK.Version,
ClusterResourceGVK.Kind,
"clr",
true,
&ClusterResource{})
)
var (
ClusterResourceGVK = schema.GroupVersionKind{
Version: "v1",
Group: "testing.solo.io",
Kind: "ClusterResource",
}
)
var (
FakeResourceCrd = crd.NewCrd(
"fakes",
FakeResourceGVK.Group,
FakeResourceGVK.Version,
FakeResourceGVK.Kind,
"fk",
false,
&FakeResource{})
)
var (
FakeResourceGVK = schema.GroupVersionKind{
Version: "v1",
Group: "testing.solo.io",
Kind: "FakeResource",
}
)
var File_github_com_solo_io_solo_kit_test_mocks_api_v1_mock_resources_proto protoreflect.FileDescriptor
var File_github_com_solo_io_solo_kit_test_mocks_api_v1_more_mock_resources_proto protoreflect.FileDescriptor
var File_github_com_solo_io_solo_kit_test_mocks_api_v1_simple_mock_resources_proto protoreflect.FileDescriptor
var (
MockCustomTypeGVK = schema.GroupVersionKind{
Version: "v1",
Group: "testing.solo.io",
Kind: "MockCustomType",
}
)
var (
MockResourceCrd = crd.NewCrd(
"mocks",
MockResourceGVK.Group,
MockResourceGVK.Version,
MockResourceGVK.Kind,
"mk",
false,
&MockResource{})
)
var (
MockResourceGVK = schema.GroupVersionKind{
Version: "v1",
Group: "testing.solo.io",
Kind: "MockResource",
}
)
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.
var (
SimpleMockResourceCrd = crd.NewCrd(
"simplemocks",
SimpleMockResourceGVK.Group,
SimpleMockResourceGVK.Version,
SimpleMockResourceGVK.Kind,
"smk",
false,
&SimpleMockResource{})
)
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) SetMetadata ¶
func (r *AnotherMockResource) SetMetadata(meta *core.Metadata)
func (*AnotherMockResource) SetNamespacedStatuses ¶ added in v0.23.0
func (r *AnotherMockResource) SetNamespacedStatuses(namespacedStatuses *core.NamespacedStatuses)
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) NamespacesDotNames ¶
func (list AnotherMockResourceList) NamespacesDotNames() []string
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) 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) ProtoMessage ¶
func (*ClusterResource) ProtoMessage()
func (*ClusterResource) ProtoReflect ¶ added in v0.16.0
func (x *ClusterResource) ProtoReflect() protoreflect.Message
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)
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) 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) NamespacesDotNames ¶
func (list ClusterResourceList) NamespacesDotNames() []string
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) 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) ProtoMessage ¶
func (*FakeResource) ProtoMessage()
func (*FakeResource) ProtoReflect ¶ added in v0.16.0
func (x *FakeResource) ProtoReflect() protoreflect.Message
func (*FakeResource) SetMetadata ¶
func (r *FakeResource) SetMetadata(meta *core.Metadata)
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) EachResource ¶
func (list FakeResourceList) EachResource(f func(element resources.Resource))
func (FakeResourceList) Find ¶
func (list FakeResourceList) Find(namespace, name string) (*FakeResource, error)
func (FakeResourceList) NamespacesDotNames ¶
func (list FakeResourceList) NamespacesDotNames() []string
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
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) GroupVersionKind ¶ added in v0.10.4
func (r *MockCustomType) GroupVersionKind() schema.GroupVersionKind
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) 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) NamespacesDotNames ¶
func (list MockCustomTypeList) NamespacesDotNames() []string
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) 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) 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) ProtoMessage ¶
func (*MockResource) ProtoMessage()
func (*MockResource) ProtoReflect ¶ added in v0.16.0
func (x *MockResource) ProtoReflect() protoreflect.Message
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)
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) EachResource ¶
func (list MockResourceList) EachResource(f func(element resources.Resource))
func (MockResourceList) Find ¶
func (list MockResourceList) Find(namespace, name string) (*MockResource, error)
func (MockResourceList) NamespacesDotNames ¶
func (list MockResourceList) NamespacesDotNames() []string
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) 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
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
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
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) GetBoolValue ¶ added in v0.19.0
func (x *SimpleMockResource) GetBoolValue() *wrappers.BoolValue
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) 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) SetMetadata ¶ added in v0.19.0
func (r *SimpleMockResource) SetMetadata(meta *core.Metadata)
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
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
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
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) HashFields ¶
func (s TestingSnapshot) HashFields() []zap.Field
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
}
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
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
¶
- another_mock_resource.sk.go
- another_mock_resource_client.sk.go
- another_mock_resource_reconciler.sk.go
- cluster_resource.sk.go
- cluster_resource_client.sk.go
- cluster_resource_reconciler.sk.go
- fake_resource.sk.go
- fake_resource_client.sk.go
- fake_resource_reconciler.sk.go
- mock_custom_type.sk.go
- mock_custom_type_client.sk.go
- mock_custom_type_reconciler.sk.go
- mock_resource.sk.go
- mock_resource_client.sk.go
- mock_resource_reconciler.sk.go
- mock_resources.pb.equal.go
- mock_resources.pb.go
- mock_resources.pb.hash.go
- mock_xds_resource_discovery_service_xds.sk.go
- more_mock_resources.pb.equal.go
- more_mock_resources.pb.go
- more_mock_resources.pb.hash.go
- simple_mock_resource.sk.go
- simple_mock_resource_client.sk.go
- simple_mock_resource_reconciler.sk.go
- simple_mock_resources.pb.equal.go
- simple_mock_resources.pb.go
- simple_mock_resources.pb.hash.go
- testing_event_loop.sk.go
- testing_simple_event_loop.sk.go
- testing_snapshot.sk.go
- testing_snapshot_emitter.sk.go
- testing_snapshot_simple_emitter.sk.go