busfakes

package

v3.11.2 Latest Latest Go to latest Published: Jun 25, 2026 License: Apache-2.0 Imports: 3 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

FakeMessagePipe is a mock message pipe

func NewFakeMessagePipe() *FakeMessagePipe

func (p *FakeMessagePipe) ClearMessages()

func (p *FakeMessagePipe) DeRegister(ctx context.Context, pluginNames []string) error

func (p *FakeMessagePipe) Index(pluginName string, plugins []bus.Plugin) int

func (p *FakeMessagePipe) IsPluginRegistered(pluginName string) bool

func (p *FakeMessagePipe) Messages() []*bus.Message

func (p *FakeMessagePipe) Plugins() []bus.Plugin

func (p *FakeMessagePipe) Process(_ context.Context, msgs ...*bus.Message)

func (p *FakeMessagePipe) ProcessedMessages() []*bus.Message

func (p *FakeMessagePipe) Register(size int, plugins []bus.Plugin) error

func (p *FakeMessagePipe) Run(ctx context.Context)

func (p *FakeMessagePipe) RunWithoutInit(ctx context.Context)