fake

package
v0.5.0 Latest Latest
Warning

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

 Go to latest Published: Feb 7, 2020 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Overview

Package fake has the automatically generated clients.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type FakeGateways added in v0.5.0 

type FakeGateways struct {
	Fake *FakeStreamingV1alpha1
	// contains filtered or unexported fields
}

FakeGateways implements GatewayInterface

func (*FakeGateways) Create added in v0.5.0 

func (c *FakeGateways) Create(gateway *v1alpha1.Gateway) (result *v1alpha1.Gateway, err error)

Create takes the representation of a gateway and creates it. Returns the server's representation of the gateway, and an error, if there is any.

func (*FakeGateways) Delete added in v0.5.0 

func (c *FakeGateways) Delete(name string, options *v1.DeleteOptions) error

Delete takes name of the gateway and deletes it. Returns an error if one occurs.

func (*FakeGateways) DeleteCollection added in v0.5.0 

func (c *FakeGateways) DeleteCollection(options *v1.DeleteOptions, listOptions v1.ListOptions) error

DeleteCollection deletes a collection of objects.

func (*FakeGateways) Get added in v0.5.0 

func (c *FakeGateways) Get(name string, options v1.GetOptions) (result *v1alpha1.Gateway, err error)

Get takes name of the gateway, and returns the corresponding gateway object, and an error if there is any.

func (*FakeGateways) List added in v0.5.0 

func (c *FakeGateways) List(opts v1.ListOptions) (result *v1alpha1.GatewayList, err error)

List takes label and field selectors, and returns the list of Gateways that match those selectors.

func (*FakeGateways) Patch added in v0.5.0 

func (c *FakeGateways) Patch(name string, pt types.PatchType, data []byte, subresources ...string) (result *v1alpha1.Gateway, err error)

Patch applies the patch and returns the patched gateway.

func (*FakeGateways) Update added in v0.5.0 

func (c *FakeGateways) Update(gateway *v1alpha1.Gateway) (result *v1alpha1.Gateway, err error)

Update takes the representation of a gateway and updates it. Returns the server's representation of the gateway, and an error, if there is any.

func (*FakeGateways) UpdateStatus added in v0.5.0 

func (c *FakeGateways) UpdateStatus(gateway *v1alpha1.Gateway) (*v1alpha1.Gateway, error)

UpdateStatus was generated because the type contains a Status member. Add a +genclient:noStatus comment above the type to avoid generating UpdateStatus().

func (*FakeGateways) Watch added in v0.5.0 

func (c *FakeGateways) Watch(opts v1.ListOptions) (watch.Interface, error)

Watch returns a watch.Interface that watches the requested gateways.

type FakeInMemoryGateways added in v0.5.0 

type FakeInMemoryGateways struct {
	Fake *FakeStreamingV1alpha1
	// contains filtered or unexported fields
}

FakeInMemoryGateways implements InMemoryGatewayInterface

func (*FakeInMemoryGateways) Create added in v0.5.0 

func (c *FakeInMemoryGateways) Create(inMemoryGateway *v1alpha1.InMemoryGateway) (result *v1alpha1.InMemoryGateway, err error)

Create takes the representation of a inMemoryGateway and creates it. Returns the server's representation of the inMemoryGateway, and an error, if there is any.

func (*FakeInMemoryGateways) Delete added in v0.5.0 

func (c *FakeInMemoryGateways) Delete(name string, options *v1.DeleteOptions) error

Delete takes name of the inMemoryGateway and deletes it. Returns an error if one occurs.

func (*FakeInMemoryGateways) DeleteCollection added in v0.5.0 

func (c *FakeInMemoryGateways) DeleteCollection(options *v1.DeleteOptions, listOptions v1.ListOptions) error

DeleteCollection deletes a collection of objects.

func (*FakeInMemoryGateways) Get added in v0.5.0 

func (c *FakeInMemoryGateways) Get(name string, options v1.GetOptions) (result *v1alpha1.InMemoryGateway, err error)

Get takes name of the inMemoryGateway, and returns the corresponding inMemoryGateway object, and an error if there is any.

func (*FakeInMemoryGateways) List added in v0.5.0 

func (c *FakeInMemoryGateways) List(opts v1.ListOptions) (result *v1alpha1.InMemoryGatewayList, err error)

List takes label and field selectors, and returns the list of InMemoryGateways that match those selectors.

func (*FakeInMemoryGateways) Patch added in v0.5.0 

func (c *FakeInMemoryGateways) Patch(name string, pt types.PatchType, data []byte, subresources ...string) (result *v1alpha1.InMemoryGateway, err error)

Patch applies the patch and returns the patched inMemoryGateway.

func (*FakeInMemoryGateways) Update added in v0.5.0 

func (c *FakeInMemoryGateways) Update(inMemoryGateway *v1alpha1.InMemoryGateway) (result *v1alpha1.InMemoryGateway, err error)

Update takes the representation of a inMemoryGateway and updates it. Returns the server's representation of the inMemoryGateway, and an error, if there is any.

func (*FakeInMemoryGateways) UpdateStatus added in v0.5.0 

func (c *FakeInMemoryGateways) UpdateStatus(inMemoryGateway *v1alpha1.InMemoryGateway) (*v1alpha1.InMemoryGateway, error)

UpdateStatus was generated because the type contains a Status member. Add a +genclient:noStatus comment above the type to avoid generating UpdateStatus().

func (*FakeInMemoryGateways) Watch added in v0.5.0 

func (c *FakeInMemoryGateways) Watch(opts v1.ListOptions) (watch.Interface, error)

Watch returns a watch.Interface that watches the requested inMemoryGateways.

type FakeKafkaGateways added in v0.5.0 

type FakeKafkaGateways struct {
	Fake *FakeStreamingV1alpha1
	// contains filtered or unexported fields
}

FakeKafkaGateways implements KafkaGatewayInterface

func (*FakeKafkaGateways) Create added in v0.5.0 

func (c *FakeKafkaGateways) Create(kafkaGateway *v1alpha1.KafkaGateway) (result *v1alpha1.KafkaGateway, err error)

Create takes the representation of a kafkaGateway and creates it. Returns the server's representation of the kafkaGateway, and an error, if there is any.

func (*FakeKafkaGateways) Delete added in v0.5.0 

func (c *FakeKafkaGateways) Delete(name string, options *v1.DeleteOptions) error

Delete takes name of the kafkaGateway and deletes it. Returns an error if one occurs.

func (*FakeKafkaGateways) DeleteCollection added in v0.5.0 

func (c *FakeKafkaGateways) DeleteCollection(options *v1.DeleteOptions, listOptions v1.ListOptions) error

DeleteCollection deletes a collection of objects.

func (*FakeKafkaGateways) Get added in v0.5.0 

func (c *FakeKafkaGateways) Get(name string, options v1.GetOptions) (result *v1alpha1.KafkaGateway, err error)

Get takes name of the kafkaGateway, and returns the corresponding kafkaGateway object, and an error if there is any.

func (*FakeKafkaGateways) List added in v0.5.0 

func (c *FakeKafkaGateways) List(opts v1.ListOptions) (result *v1alpha1.KafkaGatewayList, err error)

List takes label and field selectors, and returns the list of KafkaGateways that match those selectors.

func (*FakeKafkaGateways) Patch added in v0.5.0 

func (c *FakeKafkaGateways) Patch(name string, pt types.PatchType, data []byte, subresources ...string) (result *v1alpha1.KafkaGateway, err error)

Patch applies the patch and returns the patched kafkaGateway.

func (*FakeKafkaGateways) Update added in v0.5.0 

func (c *FakeKafkaGateways) Update(kafkaGateway *v1alpha1.KafkaGateway) (result *v1alpha1.KafkaGateway, err error)

Update takes the representation of a kafkaGateway and updates it. Returns the server's representation of the kafkaGateway, and an error, if there is any.

func (*FakeKafkaGateways) UpdateStatus added in v0.5.0 

func (c *FakeKafkaGateways) UpdateStatus(kafkaGateway *v1alpha1.KafkaGateway) (*v1alpha1.KafkaGateway, error)

UpdateStatus was generated because the type contains a Status member. Add a +genclient:noStatus comment above the type to avoid generating UpdateStatus().

func (*FakeKafkaGateways) Watch added in v0.5.0 

func (c *FakeKafkaGateways) Watch(opts v1.ListOptions) (watch.Interface, error)

Watch returns a watch.Interface that watches the requested kafkaGateways.

type FakeProcessors 

type FakeProcessors struct {
	Fake *FakeStreamingV1alpha1
	// contains filtered or unexported fields
}

FakeProcessors implements ProcessorInterface

func (*FakeProcessors) Create 

func (c *FakeProcessors) Create(processor *v1alpha1.Processor) (result *v1alpha1.Processor, err error)

Create takes the representation of a processor and creates it. Returns the server's representation of the processor, and an error, if there is any.

func (*FakeProcessors) Delete 

func (c *FakeProcessors) Delete(name string, options *v1.DeleteOptions) error

Delete takes name of the processor and deletes it. Returns an error if one occurs.

func (*FakeProcessors) DeleteCollection 

func (c *FakeProcessors) DeleteCollection(options *v1.DeleteOptions, listOptions v1.ListOptions) error

DeleteCollection deletes a collection of objects.

func (*FakeProcessors) Get 

func (c *FakeProcessors) Get(name string, options v1.GetOptions) (result *v1alpha1.Processor, err error)

Get takes name of the processor, and returns the corresponding processor object, and an error if there is any.

func (*FakeProcessors) List 

func (c *FakeProcessors) List(opts v1.ListOptions) (result *v1alpha1.ProcessorList, err error)

List takes label and field selectors, and returns the list of Processors that match those selectors.

func (*FakeProcessors) Patch 

func (c *FakeProcessors) Patch(name string, pt types.PatchType, data []byte, subresources ...string) (result *v1alpha1.Processor, err error)

Patch applies the patch and returns the patched processor.

func (*FakeProcessors) Update 

func (c *FakeProcessors) Update(processor *v1alpha1.Processor) (result *v1alpha1.Processor, err error)

Update takes the representation of a processor and updates it. Returns the server's representation of the processor, and an error, if there is any.

func (*FakeProcessors) UpdateStatus 

func (c *FakeProcessors) UpdateStatus(processor *v1alpha1.Processor) (*v1alpha1.Processor, error)

UpdateStatus was generated because the type contains a Status member. Add a +genclient:noStatus comment above the type to avoid generating UpdateStatus().

func (*FakeProcessors) Watch 

func (c *FakeProcessors) Watch(opts v1.ListOptions) (watch.Interface, error)

Watch returns a watch.Interface that watches the requested processors.

type FakePulsarGateways added in v0.5.0 

type FakePulsarGateways struct {
	Fake *FakeStreamingV1alpha1
	// contains filtered or unexported fields
}

FakePulsarGateways implements PulsarGatewayInterface

func (*FakePulsarGateways) Create added in v0.5.0 

func (c *FakePulsarGateways) Create(pulsarGateway *v1alpha1.PulsarGateway) (result *v1alpha1.PulsarGateway, err error)

Create takes the representation of a pulsarGateway and creates it. Returns the server's representation of the pulsarGateway, and an error, if there is any.

func (*FakePulsarGateways) Delete added in v0.5.0 

func (c *FakePulsarGateways) Delete(name string, options *v1.DeleteOptions) error

Delete takes name of the pulsarGateway and deletes it. Returns an error if one occurs.

func (*FakePulsarGateways) DeleteCollection added in v0.5.0 

func (c *FakePulsarGateways) DeleteCollection(options *v1.DeleteOptions, listOptions v1.ListOptions) error

DeleteCollection deletes a collection of objects.

func (*FakePulsarGateways) Get added in v0.5.0 

func (c *FakePulsarGateways) Get(name string, options v1.GetOptions) (result *v1alpha1.PulsarGateway, err error)

Get takes name of the pulsarGateway, and returns the corresponding pulsarGateway object, and an error if there is any.

func (*FakePulsarGateways) List added in v0.5.0 

func (c *FakePulsarGateways) List(opts v1.ListOptions) (result *v1alpha1.PulsarGatewayList, err error)

List takes label and field selectors, and returns the list of PulsarGateways that match those selectors.

func (*FakePulsarGateways) Patch added in v0.5.0 

func (c *FakePulsarGateways) Patch(name string, pt types.PatchType, data []byte, subresources ...string) (result *v1alpha1.PulsarGateway, err error)

Patch applies the patch and returns the patched pulsarGateway.

func (*FakePulsarGateways) Update added in v0.5.0 

func (c *FakePulsarGateways) Update(pulsarGateway *v1alpha1.PulsarGateway) (result *v1alpha1.PulsarGateway, err error)

Update takes the representation of a pulsarGateway and updates it. Returns the server's representation of the pulsarGateway, and an error, if there is any.

func (*FakePulsarGateways) UpdateStatus added in v0.5.0 

func (c *FakePulsarGateways) UpdateStatus(pulsarGateway *v1alpha1.PulsarGateway) (*v1alpha1.PulsarGateway, error)

UpdateStatus was generated because the type contains a Status member. Add a +genclient:noStatus comment above the type to avoid generating UpdateStatus().

func (*FakePulsarGateways) Watch added in v0.5.0 

func (c *FakePulsarGateways) Watch(opts v1.ListOptions) (watch.Interface, error)

Watch returns a watch.Interface that watches the requested pulsarGateways.

type FakeStreamingV1alpha1 

type FakeStreamingV1alpha1 struct {
	*testing.Fake
}

func (*FakeStreamingV1alpha1) Gateways added in v0.5.0 

func (c *FakeStreamingV1alpha1) Gateways(namespace string) v1alpha1.GatewayInterface

func (*FakeStreamingV1alpha1) InMemoryGateways added in v0.5.0 

func (c *FakeStreamingV1alpha1) InMemoryGateways(namespace string) v1alpha1.InMemoryGatewayInterface

func (*FakeStreamingV1alpha1) KafkaGateways added in v0.5.0 

func (c *FakeStreamingV1alpha1) KafkaGateways(namespace string) v1alpha1.KafkaGatewayInterface

func (*FakeStreamingV1alpha1) Processors 

func (c *FakeStreamingV1alpha1) Processors(namespace string) v1alpha1.ProcessorInterface

func (*FakeStreamingV1alpha1) PulsarGateways added in v0.5.0 

func (c *FakeStreamingV1alpha1) PulsarGateways(namespace string) v1alpha1.PulsarGatewayInterface

func (*FakeStreamingV1alpha1) RESTClient 

func (c *FakeStreamingV1alpha1) RESTClient() rest.Interface

RESTClient returns a RESTClient that is used to communicate with API server by this client implementation.

func (*FakeStreamingV1alpha1) Streams 

func (c *FakeStreamingV1alpha1) Streams(namespace string) v1alpha1.StreamInterface

type FakeStreams 

type FakeStreams struct {
	Fake *FakeStreamingV1alpha1
	// contains filtered or unexported fields
}

FakeStreams implements StreamInterface

func (*FakeStreams) Create 

func (c *FakeStreams) Create(stream *v1alpha1.Stream) (result *v1alpha1.Stream, err error)

Create takes the representation of a stream and creates it. Returns the server's representation of the stream, and an error, if there is any.

func (*FakeStreams) Delete 

func (c *FakeStreams) Delete(name string, options *v1.DeleteOptions) error

Delete takes name of the stream and deletes it. Returns an error if one occurs.

func (*FakeStreams) DeleteCollection 

func (c *FakeStreams) DeleteCollection(options *v1.DeleteOptions, listOptions v1.ListOptions) error

DeleteCollection deletes a collection of objects.

func (*FakeStreams) Get 

func (c *FakeStreams) Get(name string, options v1.GetOptions) (result *v1alpha1.Stream, err error)

Get takes name of the stream, and returns the corresponding stream object, and an error if there is any.

func (*FakeStreams) List 

func (c *FakeStreams) List(opts v1.ListOptions) (result *v1alpha1.StreamList, err error)

List takes label and field selectors, and returns the list of Streams that match those selectors.

func (*FakeStreams) Patch 

func (c *FakeStreams) Patch(name string, pt types.PatchType, data []byte, subresources ...string) (result *v1alpha1.Stream, err error)

Patch applies the patch and returns the patched stream.

func (*FakeStreams) Update 

func (c *FakeStreams) Update(stream *v1alpha1.Stream) (result *v1alpha1.Stream, err error)

Update takes the representation of a stream and updates it. Returns the server's representation of the stream, and an error, if there is any.

func (*FakeStreams) UpdateStatus 

func (c *FakeStreams) UpdateStatus(stream *v1alpha1.Stream) (*v1alpha1.Stream, error)

UpdateStatus was generated because the type contains a Status member. Add a +genclient:noStatus comment above the type to avoid generating UpdateStatus().

func (*FakeStreams) Watch 

func (c *FakeStreams) Watch(opts v1.ListOptions) (watch.Interface, error)

Watch returns a watch.Interface that watches the requested streams.

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.