mock

Documentation

Index

• type BrokerClusterLister
  • func NewMockBrokerClusterLister() *BrokerClusterLister
  • func (s *BrokerClusterLister) BrokerClusters(namespace string) listersv1alpha1.BrokerClusterNamespaceLister
  • func (s *BrokerClusterLister) List(selector labels.Selector) (ret []*v1alpha1.BrokerCluster, err error)
• type BrokerClusterNamespaceLister
  • func NewMockBrokerClusterNamespaceLister() *BrokerClusterNamespaceLister
  • func (s BrokerClusterNamespaceLister) Get(name string) (*v1alpha1.BrokerCluster, error)
  • func (s BrokerClusterNamespaceLister) List(selector labels.Selector) (ret []*v1alpha1.BrokerCluster, err error)
• type BrokerClusters
  • func (bc *BrokerClusters) Create(c *v1alpha1.BrokerCluster) (*v1alpha1.BrokerCluster, error)
  • func (bc *BrokerClusters) Delete(name string, options *v1.DeleteOptions) error
  • func (bc *BrokerClusters) DeleteCollection(options *v1.DeleteOptions, listOptions v1.ListOptions) error
  • func (bc *BrokerClusters) Get(name string, options v1.GetOptions) (*v1alpha1.BrokerCluster, error)
  • func (bc *BrokerClusters) List(opts v1.ListOptions) (*v1alpha1.BrokerClusterList, error)
  • func (bc *BrokerClusters) Patch(name string, pt types.PatchType, data []byte, subresources ...string) (result *v1alpha1.BrokerCluster, err error)
  • func (bc *BrokerClusters) Update(c *v1alpha1.BrokerCluster) (*v1alpha1.BrokerCluster, error)
  • func (bc *BrokerClusters) Watch(opts v1.ListOptions) (watch.Interface, error)
• type ClientSet
  • func NewMockClient() *ClientSet
  • func (c *ClientSet) Discovery() discovery.DiscoveryInterface
  • func (c *ClientSet) ROCKETMQ() rocketmqv1alpha1.ROCKETMQV1alpha1Interface
  • func (c *ClientSet) ROCKETMQV1alpha1() rocketmqv1alpha1.ROCKETMQV1alpha1Interface
• type ROCKETMQV1alpha1Client
  • func NewMockROCKETMQClient() *ROCKETMQV1alpha1Client
  • func (c *ROCKETMQV1alpha1Client) BrokerClusters(namespace string) rocketmqv1alpha1.BrokerClusterInterface
  • func (c *ROCKETMQV1alpha1Client) RESTClient() rest.Interface

Types

type BrokerClusterLister

type BrokerClusterLister struct {
	ListCallback func(selector labels.Selector) (ret []*v1alpha1.BrokerCluster, err error)
	NsLister     *BrokerClusterNamespaceLister
}

func NewMockBrokerClusterLister

func NewMockBrokerClusterLister() *BrokerClusterLister

func (*BrokerClusterLister) BrokerClusters

func (s *BrokerClusterLister) BrokerClusters(namespace string) listersv1alpha1.BrokerClusterNamespaceLister

func (*BrokerClusterLister) List

func (s *BrokerClusterLister) List(selector labels.Selector) (ret []*v1alpha1.BrokerCluster, err error)

type BrokerClusterNamespaceLister

type BrokerClusterNamespaceLister struct {
	ListCallback func(selector labels.Selector) (ret []*v1alpha1.BrokerCluster, err error)
	GetCallback  func(name string) (*v1alpha1.BrokerCluster, error)
}

func NewMockBrokerClusterNamespaceLister

func NewMockBrokerClusterNamespaceLister() *BrokerClusterNamespaceLister

func (BrokerClusterNamespaceLister) Get

func (s BrokerClusterNamespaceLister) Get(name string) (*v1alpha1.BrokerCluster, error)

func (BrokerClusterNamespaceLister) List

func (s BrokerClusterNamespaceLister) List(selector labels.Selector) (ret []*v1alpha1.BrokerCluster, err error)

type BrokerClusters

type BrokerClusters struct {
	CreateCallback           func(*v1alpha1.BrokerCluster) (*v1alpha1.BrokerCluster, error)
	UpdateCallback           func(*v1alpha1.BrokerCluster) (*v1alpha1.BrokerCluster, error)
	DeleteCallback           func(name string, options *v1.DeleteOptions) error
	DeleteCollectionCallback func(options *v1.DeleteOptions, listOptions v1.ListOptions) error
	GetCallback              func(name string, options v1.GetOptions) (*v1alpha1.BrokerCluster, error)
	ListCallback             func(opts v1.ListOptions) (*v1alpha1.BrokerClusterList, error)
	WatchCallback            func(opts v1.ListOptions) (watch.Interface, error)
	PatchCallback            func(name string, pt types.PatchType, data []byte, subresources ...string) (result *v1alpha1.BrokerCluster, err error)
}

func (*BrokerClusters) Create

func (bc *BrokerClusters) Create(c *v1alpha1.BrokerCluster) (*v1alpha1.BrokerCluster, error)

func (*BrokerClusters) Delete

func (bc *BrokerClusters) Delete(name string, options *v1.DeleteOptions) error

func (*BrokerClusters) DeleteCollection

func (bc *BrokerClusters) DeleteCollection(options *v1.DeleteOptions, listOptions v1.ListOptions) error

func (*BrokerClusters) Get

func (bc *BrokerClusters) Get(name string, options v1.GetOptions) (*v1alpha1.BrokerCluster, error)

func (*BrokerClusters) List

func (bc *BrokerClusters) List(opts v1.ListOptions) (*v1alpha1.BrokerClusterList, error)

func (*BrokerClusters) Patch

func (bc *BrokerClusters) Patch(name string, pt types.PatchType, data []byte, subresources ...string) (result *v1alpha1.BrokerCluster, err error)

func (*BrokerClusters) Update

func (bc *BrokerClusters) Update(c *v1alpha1.BrokerCluster) (*v1alpha1.BrokerCluster, error)

func (*BrokerClusters) Watch

func (bc *BrokerClusters) Watch(opts v1.ListOptions) (watch.Interface, error)

type ClientSet

type ClientSet struct {
	*discovery.DiscoveryClient
	ROCKETMQClient *ROCKETMQV1alpha1Client
}

func NewMockClient

func NewMockClient() *ClientSet

func (*ClientSet) Discovery

func (c *ClientSet) Discovery() discovery.DiscoveryInterface

func (*ClientSet) ROCKETMQ

func (c *ClientSet) ROCKETMQ() rocketmqv1alpha1.ROCKETMQV1alpha1Interface

func (*ClientSet) ROCKETMQV1alpha1

func (c *ClientSet) ROCKETMQV1alpha1() rocketmqv1alpha1.ROCKETMQV1alpha1Interface

type ROCKETMQV1alpha1Client

type ROCKETMQV1alpha1Client struct {
	BrokerClustersRef *BrokerClusters
	// contains filtered or unexported fields
}

func NewMockROCKETMQClient

func NewMockROCKETMQClient() *ROCKETMQV1alpha1Client

func (*ROCKETMQV1alpha1Client) BrokerClusters

func (c *ROCKETMQV1alpha1Client) BrokerClusters(namespace string) rocketmqv1alpha1.BrokerClusterInterface

func (*ROCKETMQV1alpha1Client) RESTClient

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