Versions in this module Expand all Collapse all v2 v2.1.4 Oct 1, 2025 v2.1.2 Sep 25, 2025 Changes in this version + type FakeMessenger struct + ErrorsStub func() <-chan error + MessagesStub func() <-chan *v1.DataPlaneResponse + RunStub func(context.Context) + SendStub func(context.Context, *v1.ManagementPlaneRequest) error + func (fake *FakeMessenger) Errors() <-chan error + func (fake *FakeMessenger) ErrorsCallCount() int + func (fake *FakeMessenger) ErrorsCalls(stub func() <-chan error) + func (fake *FakeMessenger) ErrorsReturns(result1 <-chan error) + func (fake *FakeMessenger) ErrorsReturnsOnCall(i int, result1 <-chan error) + func (fake *FakeMessenger) Invocations() map[string][][]interface{} + func (fake *FakeMessenger) Messages() <-chan *v1.DataPlaneResponse + func (fake *FakeMessenger) MessagesCallCount() int + func (fake *FakeMessenger) MessagesCalls(stub func() <-chan *v1.DataPlaneResponse) + func (fake *FakeMessenger) MessagesReturns(result1 <-chan *v1.DataPlaneResponse) + func (fake *FakeMessenger) MessagesReturnsOnCall(i int, result1 <-chan *v1.DataPlaneResponse) + func (fake *FakeMessenger) Run(arg1 context.Context) + func (fake *FakeMessenger) RunArgsForCall(i int) context.Context + func (fake *FakeMessenger) RunCallCount() int + func (fake *FakeMessenger) RunCalls(stub func(context.Context)) + func (fake *FakeMessenger) Send(arg1 context.Context, arg2 *v1.ManagementPlaneRequest) error + func (fake *FakeMessenger) SendArgsForCall(i int) (context.Context, *v1.ManagementPlaneRequest) + func (fake *FakeMessenger) SendCallCount() int + func (fake *FakeMessenger) SendCalls(stub func(context.Context, *v1.ManagementPlaneRequest) error) + func (fake *FakeMessenger) SendReturns(result1 error) + func (fake *FakeMessenger) SendReturnsOnCall(i int, result1 error)