Documentation
¶
Overview ¶
This package has the automatically generated typed clients.
Index ¶
- type GatewayExpansion
- type GatewayInterface
- type GatewaysGetter
- type InMemoryGatewayExpansion
- type InMemoryGatewayInterface
- type InMemoryGatewaysGetter
- type KafkaGatewayExpansion
- type KafkaGatewayInterface
- type KafkaGatewaysGetter
- type ProcessorExpansion
- type ProcessorInterface
- type ProcessorsGetter
- type PulsarGatewayExpansion
- type PulsarGatewayInterface
- type PulsarGatewaysGetter
- type StreamExpansion
- type StreamInterface
- type StreamingV1alpha1Client
- func (c *StreamingV1alpha1Client) Gateways(namespace string) GatewayInterface
- func (c *StreamingV1alpha1Client) InMemoryGateways(namespace string) InMemoryGatewayInterface
- func (c *StreamingV1alpha1Client) KafkaGateways(namespace string) KafkaGatewayInterface
- func (c *StreamingV1alpha1Client) Processors(namespace string) ProcessorInterface
- func (c *StreamingV1alpha1Client) PulsarGateways(namespace string) PulsarGatewayInterface
- func (c *StreamingV1alpha1Client) RESTClient() rest.Interface
- func (c *StreamingV1alpha1Client) Streams(namespace string) StreamInterface
- type StreamingV1alpha1Interface
- type StreamsGetter
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type GatewayExpansion ¶ added in v0.5.0
type GatewayExpansion interface{}
type GatewayInterface ¶ added in v0.5.0
type GatewayInterface interface { Create(*v1alpha1.Gateway) (*v1alpha1.Gateway, error) Update(*v1alpha1.Gateway) (*v1alpha1.Gateway, error) UpdateStatus(*v1alpha1.Gateway) (*v1alpha1.Gateway, error) Delete(name string, options *v1.DeleteOptions) error DeleteCollection(options *v1.DeleteOptions, listOptions v1.ListOptions) error Get(name string, options v1.GetOptions) (*v1alpha1.Gateway, error) List(opts v1.ListOptions) (*v1alpha1.GatewayList, error) Watch(opts v1.ListOptions) (watch.Interface, error) Patch(name string, pt types.PatchType, data []byte, subresources ...string) (result *v1alpha1.Gateway, err error) GatewayExpansion }
GatewayInterface has methods to work with Gateway resources.
type GatewaysGetter ¶ added in v0.5.0
type GatewaysGetter interface {
Gateways(namespace string) GatewayInterface
}
GatewaysGetter has a method to return a GatewayInterface. A group's client should implement this interface.
type InMemoryGatewayExpansion ¶ added in v0.5.0
type InMemoryGatewayExpansion interface{}
type InMemoryGatewayInterface ¶ added in v0.5.0
type InMemoryGatewayInterface interface { Create(*v1alpha1.InMemoryGateway) (*v1alpha1.InMemoryGateway, error) Update(*v1alpha1.InMemoryGateway) (*v1alpha1.InMemoryGateway, error) UpdateStatus(*v1alpha1.InMemoryGateway) (*v1alpha1.InMemoryGateway, error) Delete(name string, options *v1.DeleteOptions) error DeleteCollection(options *v1.DeleteOptions, listOptions v1.ListOptions) error Get(name string, options v1.GetOptions) (*v1alpha1.InMemoryGateway, error) List(opts v1.ListOptions) (*v1alpha1.InMemoryGatewayList, error) Watch(opts v1.ListOptions) (watch.Interface, error) Patch(name string, pt types.PatchType, data []byte, subresources ...string) (result *v1alpha1.InMemoryGateway, err error) InMemoryGatewayExpansion }
InMemoryGatewayInterface has methods to work with InMemoryGateway resources.
type InMemoryGatewaysGetter ¶ added in v0.5.0
type InMemoryGatewaysGetter interface {
InMemoryGateways(namespace string) InMemoryGatewayInterface
}
InMemoryGatewaysGetter has a method to return a InMemoryGatewayInterface. A group's client should implement this interface.
type KafkaGatewayExpansion ¶ added in v0.5.0
type KafkaGatewayExpansion interface{}
type KafkaGatewayInterface ¶ added in v0.5.0
type KafkaGatewayInterface interface { Create(*v1alpha1.KafkaGateway) (*v1alpha1.KafkaGateway, error) Update(*v1alpha1.KafkaGateway) (*v1alpha1.KafkaGateway, error) UpdateStatus(*v1alpha1.KafkaGateway) (*v1alpha1.KafkaGateway, error) Delete(name string, options *v1.DeleteOptions) error DeleteCollection(options *v1.DeleteOptions, listOptions v1.ListOptions) error Get(name string, options v1.GetOptions) (*v1alpha1.KafkaGateway, error) List(opts v1.ListOptions) (*v1alpha1.KafkaGatewayList, error) Watch(opts v1.ListOptions) (watch.Interface, error) Patch(name string, pt types.PatchType, data []byte, subresources ...string) (result *v1alpha1.KafkaGateway, err error) KafkaGatewayExpansion }
KafkaGatewayInterface has methods to work with KafkaGateway resources.
type KafkaGatewaysGetter ¶ added in v0.5.0
type KafkaGatewaysGetter interface {
KafkaGateways(namespace string) KafkaGatewayInterface
}
KafkaGatewaysGetter has a method to return a KafkaGatewayInterface. A group's client should implement this interface.
type ProcessorExpansion ¶
type ProcessorExpansion interface{}
type ProcessorInterface ¶
type ProcessorInterface interface { Create(*v1alpha1.Processor) (*v1alpha1.Processor, error) Update(*v1alpha1.Processor) (*v1alpha1.Processor, error) UpdateStatus(*v1alpha1.Processor) (*v1alpha1.Processor, error) Delete(name string, options *v1.DeleteOptions) error DeleteCollection(options *v1.DeleteOptions, listOptions v1.ListOptions) error Get(name string, options v1.GetOptions) (*v1alpha1.Processor, error) List(opts v1.ListOptions) (*v1alpha1.ProcessorList, error) Watch(opts v1.ListOptions) (watch.Interface, error) Patch(name string, pt types.PatchType, data []byte, subresources ...string) (result *v1alpha1.Processor, err error) ProcessorExpansion }
ProcessorInterface has methods to work with Processor resources.
type ProcessorsGetter ¶
type ProcessorsGetter interface {
Processors(namespace string) ProcessorInterface
}
ProcessorsGetter has a method to return a ProcessorInterface. A group's client should implement this interface.
type PulsarGatewayExpansion ¶ added in v0.5.0
type PulsarGatewayExpansion interface{}
type PulsarGatewayInterface ¶ added in v0.5.0
type PulsarGatewayInterface interface { Create(*v1alpha1.PulsarGateway) (*v1alpha1.PulsarGateway, error) Update(*v1alpha1.PulsarGateway) (*v1alpha1.PulsarGateway, error) UpdateStatus(*v1alpha1.PulsarGateway) (*v1alpha1.PulsarGateway, error) Delete(name string, options *v1.DeleteOptions) error DeleteCollection(options *v1.DeleteOptions, listOptions v1.ListOptions) error Get(name string, options v1.GetOptions) (*v1alpha1.PulsarGateway, error) List(opts v1.ListOptions) (*v1alpha1.PulsarGatewayList, error) Watch(opts v1.ListOptions) (watch.Interface, error) Patch(name string, pt types.PatchType, data []byte, subresources ...string) (result *v1alpha1.PulsarGateway, err error) PulsarGatewayExpansion }
PulsarGatewayInterface has methods to work with PulsarGateway resources.
type PulsarGatewaysGetter ¶ added in v0.5.0
type PulsarGatewaysGetter interface {
PulsarGateways(namespace string) PulsarGatewayInterface
}
PulsarGatewaysGetter has a method to return a PulsarGatewayInterface. A group's client should implement this interface.
type StreamExpansion ¶
type StreamExpansion interface{}
type StreamInterface ¶
type StreamInterface interface { Create(*v1alpha1.Stream) (*v1alpha1.Stream, error) Update(*v1alpha1.Stream) (*v1alpha1.Stream, error) UpdateStatus(*v1alpha1.Stream) (*v1alpha1.Stream, error) Delete(name string, options *v1.DeleteOptions) error DeleteCollection(options *v1.DeleteOptions, listOptions v1.ListOptions) error Get(name string, options v1.GetOptions) (*v1alpha1.Stream, error) List(opts v1.ListOptions) (*v1alpha1.StreamList, error) Watch(opts v1.ListOptions) (watch.Interface, error) Patch(name string, pt types.PatchType, data []byte, subresources ...string) (result *v1alpha1.Stream, err error) StreamExpansion }
StreamInterface has methods to work with Stream resources.
type StreamingV1alpha1Client ¶
type StreamingV1alpha1Client struct {
// contains filtered or unexported fields
}
StreamingV1alpha1Client is used to interact with features provided by the streaming.projectriff.io group.
func New ¶
func New(c rest.Interface) *StreamingV1alpha1Client
New creates a new StreamingV1alpha1Client for the given RESTClient.
func NewForConfig ¶
func NewForConfig(c *rest.Config) (*StreamingV1alpha1Client, error)
NewForConfig creates a new StreamingV1alpha1Client for the given config.
func NewForConfigOrDie ¶
func NewForConfigOrDie(c *rest.Config) *StreamingV1alpha1Client
NewForConfigOrDie creates a new StreamingV1alpha1Client for the given config and panics if there is an error in the config.
func (*StreamingV1alpha1Client) Gateways ¶ added in v0.5.0
func (c *StreamingV1alpha1Client) Gateways(namespace string) GatewayInterface
func (*StreamingV1alpha1Client) InMemoryGateways ¶ added in v0.5.0
func (c *StreamingV1alpha1Client) InMemoryGateways(namespace string) InMemoryGatewayInterface
func (*StreamingV1alpha1Client) KafkaGateways ¶ added in v0.5.0
func (c *StreamingV1alpha1Client) KafkaGateways(namespace string) KafkaGatewayInterface
func (*StreamingV1alpha1Client) Processors ¶
func (c *StreamingV1alpha1Client) Processors(namespace string) ProcessorInterface
func (*StreamingV1alpha1Client) PulsarGateways ¶ added in v0.5.0
func (c *StreamingV1alpha1Client) PulsarGateways(namespace string) PulsarGatewayInterface
func (*StreamingV1alpha1Client) RESTClient ¶
func (c *StreamingV1alpha1Client) RESTClient() rest.Interface
RESTClient returns a RESTClient that is used to communicate with API server by this client implementation.
func (*StreamingV1alpha1Client) Streams ¶
func (c *StreamingV1alpha1Client) Streams(namespace string) StreamInterface
type StreamingV1alpha1Interface ¶
type StreamingV1alpha1Interface interface { RESTClient() rest.Interface GatewaysGetter InMemoryGatewaysGetter KafkaGatewaysGetter ProcessorsGetter PulsarGatewaysGetter StreamsGetter }
type StreamsGetter ¶
type StreamsGetter interface {
Streams(namespace string) StreamInterface
}
StreamsGetter has a method to return a StreamInterface. A group's client should implement this interface.