lib

Documentation

Index

• func CreateKafkaBindingV1Beta1OrFail(c *testlib.Client, kafkaBinding *bindingsv1beta1.KafkaBinding)
• func CreateKafkaSourceV1Beta1OrFail(c *testlib.Client, kafkaSource *sourcesv1beta1.KafkaSource)
• func DeleteResourceOrFail(ctx context.Context, c *testlib.Client, name string, ...)
• func GetKafkaSourceV1Beta1OrFail(c *testlib.Client, kafkaSource string) *sourcesv1beta1.KafkaSource
• func NewScheme() *runtime.Scheme
• func UpdateKafkaSourceV1Beta1OrFail(c *testlib.Client, kafkaSource *sourcesv1beta1.KafkaSource)
• type Listers
  • func NewListers(objs []runtime.Object) Listers
  • func (l Listers) GetAllObjects() []runtime.Object
  • func (l Listers) GetEventingObjects() []runtime.Object
  • func (l Listers) GetKubeObjects() []runtime.Object

Functions

func CreateKafkaBindingV1Beta1OrFail

func CreateKafkaBindingV1Beta1OrFail(c *testlib.Client, kafkaBinding *bindingsv1beta1.KafkaBinding)

func CreateKafkaSourceV1Beta1OrFail

func CreateKafkaSourceV1Beta1OrFail(c *testlib.Client, kafkaSource *sourcesv1beta1.KafkaSource)

func DeleteResourceOrFail

func DeleteResourceOrFail(ctx context.Context, c *testlib.Client, name string, gvr schema.GroupVersionResource)

func GetKafkaSourceV1Beta1OrFail

func GetKafkaSourceV1Beta1OrFail(c *testlib.Client, kafkaSource string) *sourcesv1beta1.KafkaSource

func NewScheme

func NewScheme() *runtime.Scheme

func UpdateKafkaSourceV1Beta1OrFail

func UpdateKafkaSourceV1Beta1OrFail(c *testlib.Client, kafkaSource *sourcesv1beta1.KafkaSource)

Types

type Listers

type Listers struct {
	// contains filtered or unexported fields
}

func NewListers

func NewListers(objs []runtime.Object) Listers

func (Listers) GetAllObjects

func (l Listers) GetAllObjects() []runtime.Object

func (Listers) GetEventingObjects

func (l Listers) GetEventingObjects() []runtime.Object

func (Listers) GetKubeObjects

func (l Listers) GetKubeObjects() []runtime.Object