support

Documentation

Index

• func LoadRoutes(ctx context.Context, route string, params any) error
• type ChannelVerticle
  • func (p *ChannelVerticle) Receive(ac actor.Context)
  • func (p *ChannelVerticle) Reify(_ context.Context) (camel.Verticle, error)
• type ProcessorVerticle
  • func (p *ProcessorVerticle) Receive(ac actor.Context)
  • func (p *ProcessorVerticle) Reify(_ context.Context) (camel.Verticle, error)
• type ReifyableVerticle
  • func NewChannelVerticle(channel chan camel.Message) ReifyableVerticle
  • func NewProcessorsVerticle(processor camel.Processor) ReifyableVerticle
• type RootVerticle
  • func NewRootVerticle(v camel.Verticle) *RootVerticle
  • func (r *RootVerticle) Get(timeout time.Duration) (camel.Message, error)
  • func (r *RootVerticle) Receive(ac actor.Context)
• type T
  • func (t *T) Camel() camel.Context
  • func (t *T) Ctx() context.Context
  • func (t *T) T() *testing.T
• type Test
  • func With(t *testing.T) Test

Functions

func LoadRoutes

func LoadRoutes(ctx context.Context, route string, params any) error

Types

type ChannelVerticle

type ChannelVerticle struct {
	processors.DefaultVerticle
	// contains filtered or unexported fields
}

func (*ChannelVerticle) Receive

func (p *ChannelVerticle) Receive(ac actor.Context)

func (*ChannelVerticle) Reify

func (p *ChannelVerticle) Reify(_ context.Context) (camel.Verticle, error)

type ProcessorVerticle

type ProcessorVerticle struct {
	processors.DefaultVerticle
	// contains filtered or unexported fields
}

func (*ProcessorVerticle) Receive

func (p *ProcessorVerticle) Receive(ac actor.Context)

func (*ProcessorVerticle) Reify

func (p *ProcessorVerticle) Reify(_ context.Context) (camel.Verticle, error)

type ReifyableVerticle

type ReifyableVerticle interface {
	camel.Verticle
	processors.Reifyable
}

func NewChannelVerticle

func NewChannelVerticle(channel chan camel.Message) ReifyableVerticle

func NewProcessorsVerticle

func NewProcessorsVerticle(processor camel.Processor) ReifyableVerticle

type RootVerticle

type RootVerticle struct {
	processors.DefaultVerticle

	V camel.Verticle
	P *actor.PID
	C chan camel.Message
}

func NewRootVerticle

func NewRootVerticle(v camel.Verticle) *RootVerticle

func (*RootVerticle) Get

func (r *RootVerticle) Get(timeout time.Duration) (camel.Message, error)

func (*RootVerticle) Receive

func (r *RootVerticle) Receive(ac actor.Context)

type T

type T struct {
	*gomega.WithT
	// contains filtered or unexported fields
}

func (*T) Camel

func (t *T) Camel() camel.Context

func (*T) Ctx

func (t *T) Ctx() context.Context

func (*T) T

func (t *T) T() *testing.T

type Test

type Test interface {
	T() *testing.T
	Ctx() context.Context
	Camel() camel.Context

	gomega.Gomega
}

func With

func With(t *testing.T) Test