rabbit

Documentation

Index

• type Rabbit
  • func New(ctx context.Context) *Rabbit
  • func (r *Rabbit) ReconcileBinding(ctx context.Context, args *triggerresources.BindingArgs) (Result, error)
  • func (r *Rabbit) ReconcileExchange(ctx context.Context, args *resources.ExchangeArgs) (Result, error)
  • func (r *Rabbit) ReconcileQueue(ctx context.Context, args *triggerresources.QueueArgs) (Result, error)
• type Result
• type Service

Types

type Rabbit

type Rabbit struct {
	rabbitclientset.Interface
}

func New

func New(ctx context.Context) *Rabbit

func (*Rabbit) ReconcileBinding

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

func (*Rabbit) ReconcileExchange

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

func (*Rabbit) ReconcileQueue

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

type Result

type Result struct {
	Name  string
	Ready bool
}

type Service

type Service interface {
	ReconcileExchange(context.Context, *resources.ExchangeArgs) (Result, error)
	ReconcileQueue(context.Context, *triggerresources.QueueArgs) (Result, error)
	ReconcileBinding(context.Context, *triggerresources.BindingArgs) (Result, error)
}