services

Documentation

Index

• type Rabbit
  • func NewRabbit(ctx context.Context) *Rabbit
  • func NewRabbitTest(rabbitClientSet rabbitclientset.Interface, ...) *Rabbit
  • func (r *Rabbit) ReconcileBinding(ctx context.Context, args *triggerresources.BindingArgs) (*v1beta1.Binding, error)
  • func (r *Rabbit) ReconcileExchange(ctx context.Context, args *resources.ExchangeArgs) (*v1beta1.Exchange, error)
  • func (r *Rabbit) ReconcileQueue(ctx context.Context, args *triggerresources.QueueArgs) (*v1beta1.Queue, error)

Types

type Rabbit

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

func NewRabbit

func NewRabbit(ctx context.Context) *Rabbit

func NewRabbitTest

func NewRabbitTest(
	rabbitClientSet rabbitclientset.Interface,
	exchangeLister rabbitlisters.ExchangeLister,
	queueLister rabbitlisters.QueueLister,
	bindingLister rabbitlisters.BindingLister,
) *Rabbit

func (*Rabbit) ReconcileBinding

func (r *Rabbit) ReconcileBinding(ctx context.Context, args *triggerresources.BindingArgs) (*v1beta1.Binding, error)

func (*Rabbit) ReconcileExchange

func (r *Rabbit) ReconcileExchange(ctx context.Context, args *resources.ExchangeArgs) (*v1beta1.Exchange, error)

func (*Rabbit) ReconcileQueue

func (r *Rabbit) ReconcileQueue(ctx context.Context, args *triggerresources.QueueArgs) (*v1beta1.Queue, error)