Help us shape the future of Go! Take the 2026 Go Developer Survey

mock

package
v0.47.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 16, 2026 License: AGPL-3.0 Imports: 16 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type BasicResolver added in v0.43.2 

type BasicResolver struct {
	mock.Mock
}

BasicResolver is an autogenerated mock type for the BasicResolver type

func NewBasicResolver added in v0.43.2 

func NewBasicResolver(t interface {
	mock.TestingT
	Cleanup(func())
}) *BasicResolver

NewBasicResolver creates a new instance of BasicResolver. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*BasicResolver) EXPECT added in v0.46.0 

func (_m *BasicResolver) EXPECT() *BasicResolver_Expecter

func (*BasicResolver) LookupIPAddr added in v0.43.2 

func (_mock *BasicResolver) LookupIPAddr(context1 context.Context, s string) ([]net.IPAddr, error)

LookupIPAddr provides a mock function for the type BasicResolver

func (*BasicResolver) LookupTXT added in v0.43.2 

func (_mock *BasicResolver) LookupTXT(context1 context.Context, s string) ([]string, error)

LookupTXT provides a mock function for the type BasicResolver

type BasicResolver_Expecter added in v0.46.0 

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

func (*BasicResolver_Expecter) LookupIPAddr added in v0.46.0 

func (_e *BasicResolver_Expecter) LookupIPAddr(context1 interface{}, s interface{}) *BasicResolver_LookupIPAddr_Call

LookupIPAddr is a helper method to define mock.On call

  • context1 context.Context
  • s string

func (*BasicResolver_Expecter) LookupTXT added in v0.46.0 

func (_e *BasicResolver_Expecter) LookupTXT(context1 interface{}, s interface{}) *BasicResolver_LookupTXT_Call

LookupTXT is a helper method to define mock.On call

  • context1 context.Context
  • s string

type BasicResolver_LookupIPAddr_Call added in v0.46.0 

type BasicResolver_LookupIPAddr_Call struct {
	*mock.Call
}

BasicResolver_LookupIPAddr_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'LookupIPAddr'

func (*BasicResolver_LookupIPAddr_Call) Return added in v0.46.0 

func (_c *BasicResolver_LookupIPAddr_Call) Return(iPAddrs []net.IPAddr, err error) *BasicResolver_LookupIPAddr_Call

func (*BasicResolver_LookupIPAddr_Call) Run added in v0.46.0 

func (_c *BasicResolver_LookupIPAddr_Call) Run(run func(context1 context.Context, s string)) *BasicResolver_LookupIPAddr_Call

func (*BasicResolver_LookupIPAddr_Call) RunAndReturn added in v0.46.0 

func (_c *BasicResolver_LookupIPAddr_Call) RunAndReturn(run func(context1 context.Context, s string) ([]net.IPAddr, error)) *BasicResolver_LookupIPAddr_Call

type BasicResolver_LookupTXT_Call added in v0.46.0 

type BasicResolver_LookupTXT_Call struct {
	*mock.Call
}

BasicResolver_LookupTXT_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'LookupTXT'

func (*BasicResolver_LookupTXT_Call) Return added in v0.46.0 

func (_c *BasicResolver_LookupTXT_Call) Return(strings []string, err error) *BasicResolver_LookupTXT_Call

func (*BasicResolver_LookupTXT_Call) Run added in v0.46.0 

func (_c *BasicResolver_LookupTXT_Call) Run(run func(context1 context.Context, s string)) *BasicResolver_LookupTXT_Call

func (*BasicResolver_LookupTXT_Call) RunAndReturn added in v0.46.0 

func (_c *BasicResolver_LookupTXT_Call) RunAndReturn(run func(context1 context.Context, s string) ([]string, error)) *BasicResolver_LookupTXT_Call

type BlobGetter added in v0.43.2 

type BlobGetter struct {
	mock.Mock
}

BlobGetter is an autogenerated mock type for the BlobGetter type

func NewBlobGetter added in v0.43.2 

func NewBlobGetter(t interface {
	mock.TestingT
	Cleanup(func())
}) *BlobGetter

NewBlobGetter creates a new instance of BlobGetter. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*BlobGetter) EXPECT added in v0.46.0 

func (_m *BlobGetter) EXPECT() *BlobGetter_Expecter

func (*BlobGetter) GetBlob added in v0.43.2 

func (_mock *BlobGetter) GetBlob(ctx context.Context, c cid.Cid) (blobs.Blob, error)

GetBlob provides a mock function for the type BlobGetter

func (*BlobGetter) GetBlobs added in v0.43.2 

func (_mock *BlobGetter) GetBlobs(ctx context.Context, ks []cid.Cid) <-chan blobs.Blob

GetBlobs provides a mock function for the type BlobGetter

type BlobGetter_Expecter added in v0.46.0 

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

func (*BlobGetter_Expecter) GetBlob added in v0.46.0 

func (_e *BlobGetter_Expecter) GetBlob(ctx interface{}, c interface{}) *BlobGetter_GetBlob_Call

GetBlob is a helper method to define mock.On call

  • ctx context.Context
  • c cid.Cid

func (*BlobGetter_Expecter) GetBlobs added in v0.46.0 

func (_e *BlobGetter_Expecter) GetBlobs(ctx interface{}, ks interface{}) *BlobGetter_GetBlobs_Call

GetBlobs is a helper method to define mock.On call

  • ctx context.Context
  • ks []cid.Cid

type BlobGetter_GetBlob_Call added in v0.46.0 

type BlobGetter_GetBlob_Call struct {
	*mock.Call
}

BlobGetter_GetBlob_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetBlob'

func (*BlobGetter_GetBlob_Call) Return added in v0.46.0 

func (_c *BlobGetter_GetBlob_Call) Return(v blobs.Blob, err error) *BlobGetter_GetBlob_Call

func (*BlobGetter_GetBlob_Call) Run added in v0.46.0 

func (_c *BlobGetter_GetBlob_Call) Run(run func(ctx context.Context, c cid.Cid)) *BlobGetter_GetBlob_Call

func (*BlobGetter_GetBlob_Call) RunAndReturn added in v0.46.0 

func (_c *BlobGetter_GetBlob_Call) RunAndReturn(run func(ctx context.Context, c cid.Cid) (blobs.Blob, error)) *BlobGetter_GetBlob_Call

type BlobGetter_GetBlobs_Call added in v0.46.0 

type BlobGetter_GetBlobs_Call struct {
	*mock.Call
}

BlobGetter_GetBlobs_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetBlobs'

func (*BlobGetter_GetBlobs_Call) Return added in v0.46.0 

func (_c *BlobGetter_GetBlobs_Call) Return(vCh <-chan blobs.Blob) *BlobGetter_GetBlobs_Call

func (*BlobGetter_GetBlobs_Call) Run added in v0.46.0 

func (_c *BlobGetter_GetBlobs_Call) Run(run func(ctx context.Context, ks []cid.Cid)) *BlobGetter_GetBlobs_Call

func (*BlobGetter_GetBlobs_Call) RunAndReturn added in v0.46.0 

func (_c *BlobGetter_GetBlobs_Call) RunAndReturn(run func(ctx context.Context, ks []cid.Cid) <-chan blobs.Blob) *BlobGetter_GetBlobs_Call

type BlobService added in v0.43.2 

type BlobService struct {
	mock.Mock
}

BlobService is an autogenerated mock type for the BlobService type

func NewBlobService added in v0.43.2 

func NewBlobService(t interface {
	mock.TestingT
	Cleanup(func())
}) *BlobService

NewBlobService creates a new instance of BlobService. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*BlobService) AddBlob added in v0.43.2 

func (_mock *BlobService) AddBlob(ctx context.Context, b blobs.Blob) error

AddBlob provides a mock function for the type BlobService

func (*BlobService) AddBlobs added in v0.43.2 

func (_mock *BlobService) AddBlobs(ctx context.Context, bs []blobs.Blob) error

AddBlobs provides a mock function for the type BlobService

func (*BlobService) DeleteBlob added in v0.43.2 

func (_mock *BlobService) DeleteBlob(ctx context.Context, c cid.Cid) error

DeleteBlob provides a mock function for the type BlobService

func (*BlobService) Done added in v0.43.2 

func (_mock *BlobService) Done() <-chan struct{}

Done provides a mock function for the type BlobService

func (*BlobService) EXPECT added in v0.46.0 

func (_m *BlobService) EXPECT() *BlobService_Expecter

func (*BlobService) GetBlob added in v0.43.2 

func (_mock *BlobService) GetBlob(ctx context.Context, c cid.Cid) (blobs.Blob, error)

GetBlob provides a mock function for the type BlobService

func (*BlobService) GetBlobs added in v0.43.2 

func (_mock *BlobService) GetBlobs(ctx context.Context, ks []cid.Cid) <-chan blobs.Blob

GetBlobs provides a mock function for the type BlobService

func (*BlobService) GetSession added in v0.43.2 

func (_mock *BlobService) GetSession(ctx context.Context) network.BlobGetter

GetSession provides a mock function for the type BlobService

func (*BlobService) Ready added in v0.43.2 

func (_mock *BlobService) Ready() <-chan struct{}

Ready provides a mock function for the type BlobService

func (*BlobService) Start added in v0.43.2 

func (_mock *BlobService) Start(signalerContext irrecoverable.SignalerContext)

Start provides a mock function for the type BlobService

func (*BlobService) TriggerReprovide added in v0.43.2 

func (_mock *BlobService) TriggerReprovide(ctx context.Context) error

TriggerReprovide provides a mock function for the type BlobService

type BlobService_AddBlob_Call added in v0.46.0 

type BlobService_AddBlob_Call struct {
	*mock.Call
}

BlobService_AddBlob_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'AddBlob'

func (*BlobService_AddBlob_Call) Return added in v0.46.0 

func (_c *BlobService_AddBlob_Call) Return(err error) *BlobService_AddBlob_Call

func (*BlobService_AddBlob_Call) Run added in v0.46.0 

func (_c *BlobService_AddBlob_Call) Run(run func(ctx context.Context, b blobs.Blob)) *BlobService_AddBlob_Call

func (*BlobService_AddBlob_Call) RunAndReturn added in v0.46.0 

func (_c *BlobService_AddBlob_Call) RunAndReturn(run func(ctx context.Context, b blobs.Blob) error) *BlobService_AddBlob_Call

type BlobService_AddBlobs_Call added in v0.46.0 

type BlobService_AddBlobs_Call struct {
	*mock.Call
}

BlobService_AddBlobs_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'AddBlobs'

func (*BlobService_AddBlobs_Call) Return added in v0.46.0 

func (_c *BlobService_AddBlobs_Call) Return(err error) *BlobService_AddBlobs_Call

func (*BlobService_AddBlobs_Call) Run added in v0.46.0 

func (_c *BlobService_AddBlobs_Call) Run(run func(ctx context.Context, bs []blobs.Blob)) *BlobService_AddBlobs_Call

func (*BlobService_AddBlobs_Call) RunAndReturn added in v0.46.0 

func (_c *BlobService_AddBlobs_Call) RunAndReturn(run func(ctx context.Context, bs []blobs.Blob) error) *BlobService_AddBlobs_Call

type BlobService_DeleteBlob_Call added in v0.46.0 

type BlobService_DeleteBlob_Call struct {
	*mock.Call
}

BlobService_DeleteBlob_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeleteBlob'

func (*BlobService_DeleteBlob_Call) Return added in v0.46.0 

func (_c *BlobService_DeleteBlob_Call) Return(err error) *BlobService_DeleteBlob_Call

func (*BlobService_DeleteBlob_Call) Run added in v0.46.0 

func (_c *BlobService_DeleteBlob_Call) Run(run func(ctx context.Context, c cid.Cid)) *BlobService_DeleteBlob_Call

func (*BlobService_DeleteBlob_Call) RunAndReturn added in v0.46.0 

func (_c *BlobService_DeleteBlob_Call) RunAndReturn(run func(ctx context.Context, c cid.Cid) error) *BlobService_DeleteBlob_Call

type BlobService_Done_Call added in v0.46.0 

type BlobService_Done_Call struct {
	*mock.Call
}

BlobService_Done_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Done'

func (*BlobService_Done_Call) Return added in v0.46.0 

func (_c *BlobService_Done_Call) Return(valCh <-chan struct{}) *BlobService_Done_Call

func (*BlobService_Done_Call) Run added in v0.46.0 

func (_c *BlobService_Done_Call) Run(run func()) *BlobService_Done_Call

func (*BlobService_Done_Call) RunAndReturn added in v0.46.0 

func (_c *BlobService_Done_Call) RunAndReturn(run func() <-chan struct{}) *BlobService_Done_Call

type BlobService_Expecter added in v0.46.0 

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

func (*BlobService_Expecter) AddBlob added in v0.46.0 

func (_e *BlobService_Expecter) AddBlob(ctx interface{}, b interface{}) *BlobService_AddBlob_Call

AddBlob is a helper method to define mock.On call

  • ctx context.Context
  • b blobs.Blob

func (*BlobService_Expecter) AddBlobs added in v0.46.0 

func (_e *BlobService_Expecter) AddBlobs(ctx interface{}, bs interface{}) *BlobService_AddBlobs_Call

AddBlobs is a helper method to define mock.On call

  • ctx context.Context
  • bs []blobs.Blob

func (*BlobService_Expecter) DeleteBlob added in v0.46.0 

func (_e *BlobService_Expecter) DeleteBlob(ctx interface{}, c interface{}) *BlobService_DeleteBlob_Call

DeleteBlob is a helper method to define mock.On call

  • ctx context.Context
  • c cid.Cid

func (*BlobService_Expecter) Done added in v0.46.0 

func (_e *BlobService_Expecter) Done() *BlobService_Done_Call

Done is a helper method to define mock.On call

func (*BlobService_Expecter) GetBlob added in v0.46.0 

func (_e *BlobService_Expecter) GetBlob(ctx interface{}, c interface{}) *BlobService_GetBlob_Call

GetBlob is a helper method to define mock.On call

  • ctx context.Context
  • c cid.Cid

func (*BlobService_Expecter) GetBlobs added in v0.46.0 

func (_e *BlobService_Expecter) GetBlobs(ctx interface{}, ks interface{}) *BlobService_GetBlobs_Call

GetBlobs is a helper method to define mock.On call

  • ctx context.Context
  • ks []cid.Cid

func (*BlobService_Expecter) GetSession added in v0.46.0 

func (_e *BlobService_Expecter) GetSession(ctx interface{}) *BlobService_GetSession_Call

GetSession is a helper method to define mock.On call

  • ctx context.Context

func (*BlobService_Expecter) Ready added in v0.46.0 

func (_e *BlobService_Expecter) Ready() *BlobService_Ready_Call

Ready is a helper method to define mock.On call

func (*BlobService_Expecter) Start added in v0.46.0 

func (_e *BlobService_Expecter) Start(signalerContext interface{}) *BlobService_Start_Call

Start is a helper method to define mock.On call

  • signalerContext irrecoverable.SignalerContext

func (*BlobService_Expecter) TriggerReprovide added in v0.46.0 

func (_e *BlobService_Expecter) TriggerReprovide(ctx interface{}) *BlobService_TriggerReprovide_Call

TriggerReprovide is a helper method to define mock.On call

  • ctx context.Context

type BlobService_GetBlob_Call added in v0.46.0 

type BlobService_GetBlob_Call struct {
	*mock.Call
}

BlobService_GetBlob_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetBlob'

func (*BlobService_GetBlob_Call) Return added in v0.46.0 

func (_c *BlobService_GetBlob_Call) Return(v blobs.Blob, err error) *BlobService_GetBlob_Call

func (*BlobService_GetBlob_Call) Run added in v0.46.0 

func (_c *BlobService_GetBlob_Call) Run(run func(ctx context.Context, c cid.Cid)) *BlobService_GetBlob_Call

func (*BlobService_GetBlob_Call) RunAndReturn added in v0.46.0 

func (_c *BlobService_GetBlob_Call) RunAndReturn(run func(ctx context.Context, c cid.Cid) (blobs.Blob, error)) *BlobService_GetBlob_Call

type BlobService_GetBlobs_Call added in v0.46.0 

type BlobService_GetBlobs_Call struct {
	*mock.Call
}

BlobService_GetBlobs_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetBlobs'

func (*BlobService_GetBlobs_Call) Return added in v0.46.0 

func (_c *BlobService_GetBlobs_Call) Return(vCh <-chan blobs.Blob) *BlobService_GetBlobs_Call

func (*BlobService_GetBlobs_Call) Run added in v0.46.0 

func (_c *BlobService_GetBlobs_Call) Run(run func(ctx context.Context, ks []cid.Cid)) *BlobService_GetBlobs_Call

func (*BlobService_GetBlobs_Call) RunAndReturn added in v0.46.0 

func (_c *BlobService_GetBlobs_Call) RunAndReturn(run func(ctx context.Context, ks []cid.Cid) <-chan blobs.Blob) *BlobService_GetBlobs_Call

type BlobService_GetSession_Call added in v0.46.0 

type BlobService_GetSession_Call struct {
	*mock.Call
}

BlobService_GetSession_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetSession'

func (*BlobService_GetSession_Call) Return added in v0.46.0 

func (_c *BlobService_GetSession_Call) Return(blobGetter network.BlobGetter) *BlobService_GetSession_Call

func (*BlobService_GetSession_Call) Run added in v0.46.0 

func (_c *BlobService_GetSession_Call) Run(run func(ctx context.Context)) *BlobService_GetSession_Call

func (*BlobService_GetSession_Call) RunAndReturn added in v0.46.0 

func (_c *BlobService_GetSession_Call) RunAndReturn(run func(ctx context.Context) network.BlobGetter) *BlobService_GetSession_Call

type BlobService_Ready_Call added in v0.46.0 

type BlobService_Ready_Call struct {
	*mock.Call
}

BlobService_Ready_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Ready'

func (*BlobService_Ready_Call) Return added in v0.46.0 

func (_c *BlobService_Ready_Call) Return(valCh <-chan struct{}) *BlobService_Ready_Call

func (*BlobService_Ready_Call) Run added in v0.46.0 

func (_c *BlobService_Ready_Call) Run(run func()) *BlobService_Ready_Call

func (*BlobService_Ready_Call) RunAndReturn added in v0.46.0 

func (_c *BlobService_Ready_Call) RunAndReturn(run func() <-chan struct{}) *BlobService_Ready_Call

type BlobService_Start_Call added in v0.46.0 

type BlobService_Start_Call struct {
	*mock.Call
}

BlobService_Start_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Start'

func (*BlobService_Start_Call) Return added in v0.46.0 

func (_c *BlobService_Start_Call) Return() *BlobService_Start_Call

func (*BlobService_Start_Call) Run added in v0.46.0 

func (_c *BlobService_Start_Call) Run(run func(signalerContext irrecoverable.SignalerContext)) *BlobService_Start_Call

func (*BlobService_Start_Call) RunAndReturn added in v0.46.0 

func (_c *BlobService_Start_Call) RunAndReturn(run func(signalerContext irrecoverable.SignalerContext)) *BlobService_Start_Call

type BlobService_TriggerReprovide_Call added in v0.46.0 

type BlobService_TriggerReprovide_Call struct {
	*mock.Call
}

BlobService_TriggerReprovide_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'TriggerReprovide'

func (*BlobService_TriggerReprovide_Call) Return added in v0.46.0 

func (_c *BlobService_TriggerReprovide_Call) Return(err error) *BlobService_TriggerReprovide_Call

func (*BlobService_TriggerReprovide_Call) Run added in v0.46.0 

func (_c *BlobService_TriggerReprovide_Call) Run(run func(ctx context.Context)) *BlobService_TriggerReprovide_Call

func (*BlobService_TriggerReprovide_Call) RunAndReturn added in v0.46.0 

func (_c *BlobService_TriggerReprovide_Call) RunAndReturn(run func(ctx context.Context) error) *BlobService_TriggerReprovide_Call

type Codec 

type Codec struct {
	mock.Mock
}

Codec is an autogenerated mock type for the Codec type

func NewCodec added in v0.43.2 

func NewCodec(t interface {
	mock.TestingT
	Cleanup(func())
}) *Codec

NewCodec creates a new instance of Codec. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*Codec) Decode 

func (_mock *Codec) Decode(data []byte) (messages.UntrustedMessage, error)

Decode provides a mock function for the type Codec

func (*Codec) EXPECT added in v0.46.0 

func (_m *Codec) EXPECT() *Codec_Expecter

func (*Codec) Encode 

func (_mock *Codec) Encode(v any) ([]byte, error)

Encode provides a mock function for the type Codec

func (*Codec) NewDecoder 

func (_mock *Codec) NewDecoder(r io.Reader) network.Decoder

NewDecoder provides a mock function for the type Codec

func (*Codec) NewEncoder 

func (_mock *Codec) NewEncoder(w io.Writer) network.Encoder

NewEncoder provides a mock function for the type Codec

type Codec_Decode_Call added in v0.46.0 

type Codec_Decode_Call struct {
	*mock.Call
}

Codec_Decode_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Decode'

func (*Codec_Decode_Call) Return added in v0.46.0 

func (_c *Codec_Decode_Call) Return(untrustedMessage messages.UntrustedMessage, err error) *Codec_Decode_Call

func (*Codec_Decode_Call) Run added in v0.46.0 

func (_c *Codec_Decode_Call) Run(run func(data []byte)) *Codec_Decode_Call

func (*Codec_Decode_Call) RunAndReturn added in v0.46.0 

func (_c *Codec_Decode_Call) RunAndReturn(run func(data []byte) (messages.UntrustedMessage, error)) *Codec_Decode_Call

type Codec_Encode_Call added in v0.46.0 

type Codec_Encode_Call struct {
	*mock.Call
}

Codec_Encode_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Encode'

func (*Codec_Encode_Call) Return added in v0.46.0 

func (_c *Codec_Encode_Call) Return(bytes []byte, err error) *Codec_Encode_Call

func (*Codec_Encode_Call) Run added in v0.46.0 

func (_c *Codec_Encode_Call) Run(run func(v any)) *Codec_Encode_Call

func (*Codec_Encode_Call) RunAndReturn added in v0.46.0 

func (_c *Codec_Encode_Call) RunAndReturn(run func(v any) ([]byte, error)) *Codec_Encode_Call

type Codec_Expecter added in v0.46.0 

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

func (*Codec_Expecter) Decode added in v0.46.0 

func (_e *Codec_Expecter) Decode(data interface{}) *Codec_Decode_Call

Decode is a helper method to define mock.On call

  • data []byte

func (*Codec_Expecter) Encode added in v0.46.0 

func (_e *Codec_Expecter) Encode(v interface{}) *Codec_Encode_Call

Encode is a helper method to define mock.On call

  • v any

func (*Codec_Expecter) NewDecoder added in v0.46.0 

func (_e *Codec_Expecter) NewDecoder(r interface{}) *Codec_NewDecoder_Call

NewDecoder is a helper method to define mock.On call

  • r io.Reader

func (*Codec_Expecter) NewEncoder added in v0.46.0 

func (_e *Codec_Expecter) NewEncoder(w interface{}) *Codec_NewEncoder_Call

NewEncoder is a helper method to define mock.On call

  • w io.Writer

type Codec_NewDecoder_Call added in v0.46.0 

type Codec_NewDecoder_Call struct {
	*mock.Call
}

Codec_NewDecoder_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'NewDecoder'

func (*Codec_NewDecoder_Call) Return added in v0.46.0 

func (_c *Codec_NewDecoder_Call) Return(decoder network.Decoder) *Codec_NewDecoder_Call

func (*Codec_NewDecoder_Call) Run added in v0.46.0 

func (_c *Codec_NewDecoder_Call) Run(run func(r io.Reader)) *Codec_NewDecoder_Call

func (*Codec_NewDecoder_Call) RunAndReturn added in v0.46.0 

func (_c *Codec_NewDecoder_Call) RunAndReturn(run func(r io.Reader) network.Decoder) *Codec_NewDecoder_Call

type Codec_NewEncoder_Call added in v0.46.0 

type Codec_NewEncoder_Call struct {
	*mock.Call
}

Codec_NewEncoder_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'NewEncoder'

func (*Codec_NewEncoder_Call) Return added in v0.46.0 

func (_c *Codec_NewEncoder_Call) Return(encoder network.Encoder) *Codec_NewEncoder_Call

func (*Codec_NewEncoder_Call) Run added in v0.46.0 

func (_c *Codec_NewEncoder_Call) Run(run func(w io.Writer)) *Codec_NewEncoder_Call

func (*Codec_NewEncoder_Call) RunAndReturn added in v0.46.0 

func (_c *Codec_NewEncoder_Call) RunAndReturn(run func(w io.Writer) network.Encoder) *Codec_NewEncoder_Call

type Compressor added in v0.43.2 

type Compressor struct {
	mock.Mock
}

Compressor is an autogenerated mock type for the Compressor type

func NewCompressor added in v0.43.2 

func NewCompressor(t interface {
	mock.TestingT
	Cleanup(func())
}) *Compressor

NewCompressor creates a new instance of Compressor. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*Compressor) EXPECT added in v0.46.0 

func (_m *Compressor) EXPECT() *Compressor_Expecter

func (*Compressor) NewReader added in v0.43.2 

func (_mock *Compressor) NewReader(reader io.Reader) (io.ReadCloser, error)

NewReader provides a mock function for the type Compressor

func (*Compressor) NewWriter added in v0.43.2 

func (_mock *Compressor) NewWriter(writer io.Writer) (network.WriteCloseFlusher, error)

NewWriter provides a mock function for the type Compressor

type Compressor_Expecter added in v0.46.0 

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

func (*Compressor_Expecter) NewReader added in v0.46.0 

func (_e *Compressor_Expecter) NewReader(reader interface{}) *Compressor_NewReader_Call

NewReader is a helper method to define mock.On call

  • reader io.Reader

func (*Compressor_Expecter) NewWriter added in v0.46.0 

func (_e *Compressor_Expecter) NewWriter(writer interface{}) *Compressor_NewWriter_Call

NewWriter is a helper method to define mock.On call

  • writer io.Writer

type Compressor_NewReader_Call added in v0.46.0 

type Compressor_NewReader_Call struct {
	*mock.Call
}

Compressor_NewReader_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'NewReader'

func (*Compressor_NewReader_Call) Return added in v0.46.0 

func (_c *Compressor_NewReader_Call) Return(readCloser io.ReadCloser, err error) *Compressor_NewReader_Call

func (*Compressor_NewReader_Call) Run added in v0.46.0 

func (_c *Compressor_NewReader_Call) Run(run func(reader io.Reader)) *Compressor_NewReader_Call

func (*Compressor_NewReader_Call) RunAndReturn added in v0.46.0 

func (_c *Compressor_NewReader_Call) RunAndReturn(run func(reader io.Reader) (io.ReadCloser, error)) *Compressor_NewReader_Call

type Compressor_NewWriter_Call added in v0.46.0 

type Compressor_NewWriter_Call struct {
	*mock.Call
}

Compressor_NewWriter_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'NewWriter'

func (*Compressor_NewWriter_Call) Return added in v0.46.0 

func (_c *Compressor_NewWriter_Call) Return(writeCloseFlusher network.WriteCloseFlusher, err error) *Compressor_NewWriter_Call

func (*Compressor_NewWriter_Call) Run added in v0.46.0 

func (_c *Compressor_NewWriter_Call) Run(run func(writer io.Writer)) *Compressor_NewWriter_Call

func (*Compressor_NewWriter_Call) RunAndReturn added in v0.46.0 

func (_c *Compressor_NewWriter_Call) RunAndReturn(run func(writer io.Writer) (network.WriteCloseFlusher, error)) *Compressor_NewWriter_Call

type Conduit 

type Conduit struct {
	mock.Mock
}

Conduit is an autogenerated mock type for the Conduit type

func NewConduit added in v0.43.2 

func NewConduit(t interface {
	mock.TestingT
	Cleanup(func())
}) *Conduit

NewConduit creates a new instance of Conduit. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*Conduit) Close 

func (_mock *Conduit) Close() error

Close provides a mock function for the type Conduit

func (*Conduit) EXPECT added in v0.46.0 

func (_m *Conduit) EXPECT() *Conduit_Expecter

func (*Conduit) Multicast 

func (_mock *Conduit) Multicast(event any, num uint, targetIDs ...flow.Identifier) error

Multicast provides a mock function for the type Conduit

func (*Conduit) Publish 

func (_mock *Conduit) Publish(event any, targetIDs ...flow.Identifier) error

Publish provides a mock function for the type Conduit

func (*Conduit) ReportMisbehavior added in v0.43.2 

func (_mock *Conduit) ReportMisbehavior(misbehaviorReport network.MisbehaviorReport)

ReportMisbehavior provides a mock function for the type Conduit

func (*Conduit) Unicast 

func (_mock *Conduit) Unicast(event any, targetID flow.Identifier) error

Unicast provides a mock function for the type Conduit

type ConduitAdapter added in v0.43.2 

type ConduitAdapter struct {
	mock.Mock
}

ConduitAdapter is an autogenerated mock type for the ConduitAdapter type

func NewConduitAdapter added in v0.43.2 

func NewConduitAdapter(t interface {
	mock.TestingT
	Cleanup(func())
}) *ConduitAdapter

NewConduitAdapter creates a new instance of ConduitAdapter. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*ConduitAdapter) EXPECT added in v0.46.0 

func (_m *ConduitAdapter) EXPECT() *ConduitAdapter_Expecter

func (*ConduitAdapter) MulticastOnChannel added in v0.43.2 

func (_mock *ConduitAdapter) MulticastOnChannel(channel channels.Channel, v any, v1 uint, identifiers ...flow.Identifier) error

MulticastOnChannel provides a mock function for the type ConduitAdapter

func (*ConduitAdapter) PublishOnChannel added in v0.43.2 

func (_mock *ConduitAdapter) PublishOnChannel(channel channels.Channel, v any, identifiers ...flow.Identifier) error

PublishOnChannel provides a mock function for the type ConduitAdapter

func (*ConduitAdapter) ReportMisbehaviorOnChannel added in v0.43.2 

func (_mock *ConduitAdapter) ReportMisbehaviorOnChannel(channel channels.Channel, report network.MisbehaviorReport)

ReportMisbehaviorOnChannel provides a mock function for the type ConduitAdapter

func (*ConduitAdapter) UnRegisterChannel added in v0.43.2 

func (_mock *ConduitAdapter) UnRegisterChannel(channel channels.Channel) error

UnRegisterChannel provides a mock function for the type ConduitAdapter

func (*ConduitAdapter) UnicastOnChannel added in v0.43.2 

func (_mock *ConduitAdapter) UnicastOnChannel(channel channels.Channel, v any, identifier flow.Identifier) error

UnicastOnChannel provides a mock function for the type ConduitAdapter

type ConduitAdapter_Expecter added in v0.46.0 

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

func (*ConduitAdapter_Expecter) MulticastOnChannel added in v0.46.0 

func (_e *ConduitAdapter_Expecter) MulticastOnChannel(channel interface{}, v interface{}, v1 interface{}, identifiers ...interface{}) *ConduitAdapter_MulticastOnChannel_Call

MulticastOnChannel is a helper method to define mock.On call

  • channel channels.Channel
  • v any
  • v1 uint
  • identifiers ...flow.Identifier

func (*ConduitAdapter_Expecter) PublishOnChannel added in v0.46.0 

func (_e *ConduitAdapter_Expecter) PublishOnChannel(channel interface{}, v interface{}, identifiers ...interface{}) *ConduitAdapter_PublishOnChannel_Call

PublishOnChannel is a helper method to define mock.On call

  • channel channels.Channel
  • v any
  • identifiers ...flow.Identifier

func (*ConduitAdapter_Expecter) ReportMisbehaviorOnChannel added in v0.46.0 

func (_e *ConduitAdapter_Expecter) ReportMisbehaviorOnChannel(channel interface{}, report interface{}) *ConduitAdapter_ReportMisbehaviorOnChannel_Call

ReportMisbehaviorOnChannel is a helper method to define mock.On call

  • channel channels.Channel
  • report network.MisbehaviorReport

func (*ConduitAdapter_Expecter) UnRegisterChannel added in v0.46.0 

func (_e *ConduitAdapter_Expecter) UnRegisterChannel(channel interface{}) *ConduitAdapter_UnRegisterChannel_Call

UnRegisterChannel is a helper method to define mock.On call

  • channel channels.Channel

func (*ConduitAdapter_Expecter) UnicastOnChannel added in v0.46.0 

func (_e *ConduitAdapter_Expecter) UnicastOnChannel(channel interface{}, v interface{}, identifier interface{}) *ConduitAdapter_UnicastOnChannel_Call

UnicastOnChannel is a helper method to define mock.On call

  • channel channels.Channel
  • v any
  • identifier flow.Identifier

type ConduitAdapter_MulticastOnChannel_Call added in v0.46.0 

type ConduitAdapter_MulticastOnChannel_Call struct {
	*mock.Call
}

ConduitAdapter_MulticastOnChannel_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'MulticastOnChannel'

func (*ConduitAdapter_MulticastOnChannel_Call) Return added in v0.46.0 

func (_c *ConduitAdapter_MulticastOnChannel_Call) Return(err error) *ConduitAdapter_MulticastOnChannel_Call

func (*ConduitAdapter_MulticastOnChannel_Call) Run added in v0.46.0 

func (_c *ConduitAdapter_MulticastOnChannel_Call) Run(run func(channel channels.Channel, v any, v1 uint, identifiers ...flow.Identifier)) *ConduitAdapter_MulticastOnChannel_Call

func (*ConduitAdapter_MulticastOnChannel_Call) RunAndReturn added in v0.46.0 

func (_c *ConduitAdapter_MulticastOnChannel_Call) RunAndReturn(run func(channel channels.Channel, v any, v1 uint, identifiers ...flow.Identifier) error) *ConduitAdapter_MulticastOnChannel_Call

type ConduitAdapter_PublishOnChannel_Call added in v0.46.0 

type ConduitAdapter_PublishOnChannel_Call struct {
	*mock.Call
}

ConduitAdapter_PublishOnChannel_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'PublishOnChannel'

func (*ConduitAdapter_PublishOnChannel_Call) Return added in v0.46.0 

func (_c *ConduitAdapter_PublishOnChannel_Call) Return(err error) *ConduitAdapter_PublishOnChannel_Call

func (*ConduitAdapter_PublishOnChannel_Call) Run added in v0.46.0 

func (_c *ConduitAdapter_PublishOnChannel_Call) Run(run func(channel channels.Channel, v any, identifiers ...flow.Identifier)) *ConduitAdapter_PublishOnChannel_Call

func (*ConduitAdapter_PublishOnChannel_Call) RunAndReturn added in v0.46.0 

func (_c *ConduitAdapter_PublishOnChannel_Call) RunAndReturn(run func(channel channels.Channel, v any, identifiers ...flow.Identifier) error) *ConduitAdapter_PublishOnChannel_Call

type ConduitAdapter_ReportMisbehaviorOnChannel_Call added in v0.46.0 

type ConduitAdapter_ReportMisbehaviorOnChannel_Call struct {
	*mock.Call
}

ConduitAdapter_ReportMisbehaviorOnChannel_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ReportMisbehaviorOnChannel'

func (*ConduitAdapter_ReportMisbehaviorOnChannel_Call) Return added in v0.46.0 

func (_c *ConduitAdapter_ReportMisbehaviorOnChannel_Call) Return() *ConduitAdapter_ReportMisbehaviorOnChannel_Call

func (*ConduitAdapter_ReportMisbehaviorOnChannel_Call) Run added in v0.46.0 

func (_c *ConduitAdapter_ReportMisbehaviorOnChannel_Call) Run(run func(channel channels.Channel, report network.MisbehaviorReport)) *ConduitAdapter_ReportMisbehaviorOnChannel_Call

func (*ConduitAdapter_ReportMisbehaviorOnChannel_Call) RunAndReturn added in v0.46.0 

func (_c *ConduitAdapter_ReportMisbehaviorOnChannel_Call) RunAndReturn(run func(channel channels.Channel, report network.MisbehaviorReport)) *ConduitAdapter_ReportMisbehaviorOnChannel_Call

type ConduitAdapter_UnRegisterChannel_Call added in v0.46.0 

type ConduitAdapter_UnRegisterChannel_Call struct {
	*mock.Call
}

ConduitAdapter_UnRegisterChannel_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UnRegisterChannel'

func (*ConduitAdapter_UnRegisterChannel_Call) Return added in v0.46.0 

func (_c *ConduitAdapter_UnRegisterChannel_Call) Return(err error) *ConduitAdapter_UnRegisterChannel_Call

func (*ConduitAdapter_UnRegisterChannel_Call) Run added in v0.46.0 

func (_c *ConduitAdapter_UnRegisterChannel_Call) Run(run func(channel channels.Channel)) *ConduitAdapter_UnRegisterChannel_Call

func (*ConduitAdapter_UnRegisterChannel_Call) RunAndReturn added in v0.46.0 

func (_c *ConduitAdapter_UnRegisterChannel_Call) RunAndReturn(run func(channel channels.Channel) error) *ConduitAdapter_UnRegisterChannel_Call

type ConduitAdapter_UnicastOnChannel_Call added in v0.46.0 

type ConduitAdapter_UnicastOnChannel_Call struct {
	*mock.Call
}

ConduitAdapter_UnicastOnChannel_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UnicastOnChannel'

func (*ConduitAdapter_UnicastOnChannel_Call) Return added in v0.46.0 

func (_c *ConduitAdapter_UnicastOnChannel_Call) Return(err error) *ConduitAdapter_UnicastOnChannel_Call

func (*ConduitAdapter_UnicastOnChannel_Call) Run added in v0.46.0 

func (_c *ConduitAdapter_UnicastOnChannel_Call) Run(run func(channel channels.Channel, v any, identifier flow.Identifier)) *ConduitAdapter_UnicastOnChannel_Call

func (*ConduitAdapter_UnicastOnChannel_Call) RunAndReturn added in v0.46.0 

func (_c *ConduitAdapter_UnicastOnChannel_Call) RunAndReturn(run func(channel channels.Channel, v any, identifier flow.Identifier) error) *ConduitAdapter_UnicastOnChannel_Call

type ConduitFactory added in v0.43.2 

type ConduitFactory struct {
	mock.Mock
}

ConduitFactory is an autogenerated mock type for the ConduitFactory type

func NewConduitFactory added in v0.43.2 

func NewConduitFactory(t interface {
	mock.TestingT
	Cleanup(func())
}) *ConduitFactory

NewConduitFactory creates a new instance of ConduitFactory. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*ConduitFactory) EXPECT added in v0.46.0 

func (_m *ConduitFactory) EXPECT() *ConduitFactory_Expecter

func (*ConduitFactory) NewConduit added in v0.43.2 

func (_mock *ConduitFactory) NewConduit(context1 context.Context, channel channels.Channel) (network.Conduit, error)

NewConduit provides a mock function for the type ConduitFactory

func (*ConduitFactory) RegisterAdapter added in v0.43.2 

func (_mock *ConduitFactory) RegisterAdapter(conduitAdapter network.ConduitAdapter) error

RegisterAdapter provides a mock function for the type ConduitFactory

type ConduitFactory_Expecter added in v0.46.0 

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

func (*ConduitFactory_Expecter) NewConduit added in v0.46.0 

func (_e *ConduitFactory_Expecter) NewConduit(context1 interface{}, channel interface{}) *ConduitFactory_NewConduit_Call

NewConduit is a helper method to define mock.On call

  • context1 context.Context
  • channel channels.Channel

func (*ConduitFactory_Expecter) RegisterAdapter added in v0.46.0 

func (_e *ConduitFactory_Expecter) RegisterAdapter(conduitAdapter interface{}) *ConduitFactory_RegisterAdapter_Call

RegisterAdapter is a helper method to define mock.On call

  • conduitAdapter network.ConduitAdapter

type ConduitFactory_NewConduit_Call added in v0.46.0 

type ConduitFactory_NewConduit_Call struct {
	*mock.Call
}

ConduitFactory_NewConduit_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'NewConduit'

func (*ConduitFactory_NewConduit_Call) Return added in v0.46.0 

func (_c *ConduitFactory_NewConduit_Call) Return(conduit network.Conduit, err error) *ConduitFactory_NewConduit_Call

func (*ConduitFactory_NewConduit_Call) Run added in v0.46.0 

func (_c *ConduitFactory_NewConduit_Call) Run(run func(context1 context.Context, channel channels.Channel)) *ConduitFactory_NewConduit_Call

func (*ConduitFactory_NewConduit_Call) RunAndReturn added in v0.46.0 

func (_c *ConduitFactory_NewConduit_Call) RunAndReturn(run func(context1 context.Context, channel channels.Channel) (network.Conduit, error)) *ConduitFactory_NewConduit_Call

type ConduitFactory_RegisterAdapter_Call added in v0.46.0 

type ConduitFactory_RegisterAdapter_Call struct {
	*mock.Call
}

ConduitFactory_RegisterAdapter_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RegisterAdapter'

func (*ConduitFactory_RegisterAdapter_Call) Return added in v0.46.0 

func (_c *ConduitFactory_RegisterAdapter_Call) Return(err error) *ConduitFactory_RegisterAdapter_Call

func (*ConduitFactory_RegisterAdapter_Call) Run added in v0.46.0 

func (_c *ConduitFactory_RegisterAdapter_Call) Run(run func(conduitAdapter network.ConduitAdapter)) *ConduitFactory_RegisterAdapter_Call

func (*ConduitFactory_RegisterAdapter_Call) RunAndReturn added in v0.46.0 

func (_c *ConduitFactory_RegisterAdapter_Call) RunAndReturn(run func(conduitAdapter network.ConduitAdapter) error) *ConduitFactory_RegisterAdapter_Call

type Conduit_Close_Call added in v0.46.0 

type Conduit_Close_Call struct {
	*mock.Call
}

Conduit_Close_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Close'

func (*Conduit_Close_Call) Return added in v0.46.0 

func (_c *Conduit_Close_Call) Return(err error) *Conduit_Close_Call

func (*Conduit_Close_Call) Run added in v0.46.0 

func (_c *Conduit_Close_Call) Run(run func()) *Conduit_Close_Call

func (*Conduit_Close_Call) RunAndReturn added in v0.46.0 

func (_c *Conduit_Close_Call) RunAndReturn(run func() error) *Conduit_Close_Call

type Conduit_Expecter added in v0.46.0 

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

func (*Conduit_Expecter) Close added in v0.46.0 

func (_e *Conduit_Expecter) Close() *Conduit_Close_Call

Close is a helper method to define mock.On call

func (*Conduit_Expecter) Multicast added in v0.46.0 

func (_e *Conduit_Expecter) Multicast(event interface{}, num interface{}, targetIDs ...interface{}) *Conduit_Multicast_Call

Multicast is a helper method to define mock.On call

  • event any
  • num uint
  • targetIDs ...flow.Identifier

func (*Conduit_Expecter) Publish added in v0.46.0 

func (_e *Conduit_Expecter) Publish(event interface{}, targetIDs ...interface{}) *Conduit_Publish_Call

Publish is a helper method to define mock.On call

  • event any
  • targetIDs ...flow.Identifier

func (*Conduit_Expecter) ReportMisbehavior added in v0.46.0 

func (_e *Conduit_Expecter) ReportMisbehavior(misbehaviorReport interface{}) *Conduit_ReportMisbehavior_Call

ReportMisbehavior is a helper method to define mock.On call

  • misbehaviorReport network.MisbehaviorReport

func (*Conduit_Expecter) Unicast added in v0.46.0 

func (_e *Conduit_Expecter) Unicast(event interface{}, targetID interface{}) *Conduit_Unicast_Call

Unicast is a helper method to define mock.On call

  • event any
  • targetID flow.Identifier

type Conduit_Multicast_Call added in v0.46.0 

type Conduit_Multicast_Call struct {
	*mock.Call
}

Conduit_Multicast_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Multicast'

func (*Conduit_Multicast_Call) Return added in v0.46.0 

func (_c *Conduit_Multicast_Call) Return(err error) *Conduit_Multicast_Call

func (*Conduit_Multicast_Call) Run added in v0.46.0 

func (_c *Conduit_Multicast_Call) Run(run func(event any, num uint, targetIDs ...flow.Identifier)) *Conduit_Multicast_Call

func (*Conduit_Multicast_Call) RunAndReturn added in v0.46.0 

func (_c *Conduit_Multicast_Call) RunAndReturn(run func(event any, num uint, targetIDs ...flow.Identifier) error) *Conduit_Multicast_Call

type Conduit_Publish_Call added in v0.46.0 

type Conduit_Publish_Call struct {
	*mock.Call
}

Conduit_Publish_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Publish'

func (*Conduit_Publish_Call) Return added in v0.46.0 

func (_c *Conduit_Publish_Call) Return(err error) *Conduit_Publish_Call

func (*Conduit_Publish_Call) Run added in v0.46.0 

func (_c *Conduit_Publish_Call) Run(run func(event any, targetIDs ...flow.Identifier)) *Conduit_Publish_Call

func (*Conduit_Publish_Call) RunAndReturn added in v0.46.0 

func (_c *Conduit_Publish_Call) RunAndReturn(run func(event any, targetIDs ...flow.Identifier) error) *Conduit_Publish_Call

type Conduit_ReportMisbehavior_Call added in v0.46.0 

type Conduit_ReportMisbehavior_Call struct {
	*mock.Call
}

Conduit_ReportMisbehavior_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ReportMisbehavior'

func (*Conduit_ReportMisbehavior_Call) Return added in v0.46.0 

func (_c *Conduit_ReportMisbehavior_Call) Return() *Conduit_ReportMisbehavior_Call

func (*Conduit_ReportMisbehavior_Call) Run added in v0.46.0 

func (_c *Conduit_ReportMisbehavior_Call) Run(run func(misbehaviorReport network.MisbehaviorReport)) *Conduit_ReportMisbehavior_Call

func (*Conduit_ReportMisbehavior_Call) RunAndReturn added in v0.46.0 

func (_c *Conduit_ReportMisbehavior_Call) RunAndReturn(run func(misbehaviorReport network.MisbehaviorReport)) *Conduit_ReportMisbehavior_Call

type Conduit_Unicast_Call added in v0.46.0 

type Conduit_Unicast_Call struct {
	*mock.Call
}

Conduit_Unicast_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Unicast'

func (*Conduit_Unicast_Call) Return added in v0.46.0 

func (_c *Conduit_Unicast_Call) Return(err error) *Conduit_Unicast_Call

func (*Conduit_Unicast_Call) Run added in v0.46.0 

func (_c *Conduit_Unicast_Call) Run(run func(event any, targetID flow.Identifier)) *Conduit_Unicast_Call

func (*Conduit_Unicast_Call) RunAndReturn added in v0.46.0 

func (_c *Conduit_Unicast_Call) RunAndReturn(run func(event any, targetID flow.Identifier) error) *Conduit_Unicast_Call

type Connection added in v0.43.2 

type Connection struct {
	mock.Mock
}

Connection is an autogenerated mock type for the Connection type

func NewConnection added in v0.43.2 

func NewConnection(t interface {
	mock.TestingT
	Cleanup(func())
}) *Connection

NewConnection creates a new instance of Connection. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*Connection) EXPECT added in v0.46.0 

func (_m *Connection) EXPECT() *Connection_Expecter

func (*Connection) Receive added in v0.43.2 

func (_mock *Connection) Receive() (any, error)

Receive provides a mock function for the type Connection

func (*Connection) Send added in v0.43.2 

func (_mock *Connection) Send(msg any) error

Send provides a mock function for the type Connection

type Connection_Expecter added in v0.46.0 

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

func (*Connection_Expecter) Receive added in v0.46.0 

func (_e *Connection_Expecter) Receive() *Connection_Receive_Call

Receive is a helper method to define mock.On call

func (*Connection_Expecter) Send added in v0.46.0 

func (_e *Connection_Expecter) Send(msg interface{}) *Connection_Send_Call

Send is a helper method to define mock.On call

  • msg any

type Connection_Receive_Call added in v0.46.0 

type Connection_Receive_Call struct {
	*mock.Call
}

Connection_Receive_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Receive'

func (*Connection_Receive_Call) Return added in v0.46.0 

func (_c *Connection_Receive_Call) Return(v any, err error) *Connection_Receive_Call

func (*Connection_Receive_Call) Run added in v0.46.0 

func (_c *Connection_Receive_Call) Run(run func()) *Connection_Receive_Call

func (*Connection_Receive_Call) RunAndReturn added in v0.46.0 

func (_c *Connection_Receive_Call) RunAndReturn(run func() (any, error)) *Connection_Receive_Call

type Connection_Send_Call added in v0.46.0 

type Connection_Send_Call struct {
	*mock.Call
}

Connection_Send_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Send'

func (*Connection_Send_Call) Return added in v0.46.0 

func (_c *Connection_Send_Call) Return(err error) *Connection_Send_Call

func (*Connection_Send_Call) Run added in v0.46.0 

func (_c *Connection_Send_Call) Run(run func(msg any)) *Connection_Send_Call

func (*Connection_Send_Call) RunAndReturn added in v0.46.0 

func (_c *Connection_Send_Call) RunAndReturn(run func(msg any) error) *Connection_Send_Call

type Decoder 

type Decoder struct {
	mock.Mock
}

Decoder is an autogenerated mock type for the Decoder type

func NewDecoder added in v0.43.2 

func NewDecoder(t interface {
	mock.TestingT
	Cleanup(func())
}) *Decoder

NewDecoder creates a new instance of Decoder. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*Decoder) Decode 

func (_mock *Decoder) Decode() (messages.UntrustedMessage, error)

Decode provides a mock function for the type Decoder

func (*Decoder) EXPECT added in v0.46.0 

func (_m *Decoder) EXPECT() *Decoder_Expecter

type Decoder_Decode_Call added in v0.46.0 

type Decoder_Decode_Call struct {
	*mock.Call
}

Decoder_Decode_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Decode'

func (*Decoder_Decode_Call) Return added in v0.46.0 

func (_c *Decoder_Decode_Call) Return(untrustedMessage messages.UntrustedMessage, err error) *Decoder_Decode_Call

func (*Decoder_Decode_Call) Run added in v0.46.0 

func (_c *Decoder_Decode_Call) Run(run func()) *Decoder_Decode_Call

func (*Decoder_Decode_Call) RunAndReturn added in v0.46.0 

func (_c *Decoder_Decode_Call) RunAndReturn(run func() (messages.UntrustedMessage, error)) *Decoder_Decode_Call

type Decoder_Expecter added in v0.46.0 

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

func (*Decoder_Expecter) Decode added in v0.46.0 

func (_e *Decoder_Expecter) Decode() *Decoder_Decode_Call

Decode is a helper method to define mock.On call

type DisallowListNotificationConsumer added in v0.43.2 

type DisallowListNotificationConsumer struct {
	mock.Mock
}

DisallowListNotificationConsumer is an autogenerated mock type for the DisallowListNotificationConsumer type

func NewDisallowListNotificationConsumer added in v0.43.2 

func NewDisallowListNotificationConsumer(t interface {
	mock.TestingT
	Cleanup(func())
}) *DisallowListNotificationConsumer

NewDisallowListNotificationConsumer creates a new instance of DisallowListNotificationConsumer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*DisallowListNotificationConsumer) EXPECT added in v0.46.0 

func (_m *DisallowListNotificationConsumer) EXPECT() *DisallowListNotificationConsumer_Expecter

func (*DisallowListNotificationConsumer) OnAllowListNotification added in v0.43.2 

func (_mock *DisallowListNotificationConsumer) OnAllowListNotification(allowListingUpdate *network.AllowListingUpdate)

OnAllowListNotification provides a mock function for the type DisallowListNotificationConsumer

func (*DisallowListNotificationConsumer) OnDisallowListNotification added in v0.43.2 

func (_mock *DisallowListNotificationConsumer) OnDisallowListNotification(disallowListingUpdate *network.DisallowListingUpdate)

OnDisallowListNotification provides a mock function for the type DisallowListNotificationConsumer

type DisallowListNotificationConsumer_Expecter added in v0.46.0 

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

func (*DisallowListNotificationConsumer_Expecter) OnAllowListNotification added in v0.46.0 

func (_e *DisallowListNotificationConsumer_Expecter) OnAllowListNotification(allowListingUpdate interface{}) *DisallowListNotificationConsumer_OnAllowListNotification_Call

OnAllowListNotification is a helper method to define mock.On call

  • allowListingUpdate *network.AllowListingUpdate

func (*DisallowListNotificationConsumer_Expecter) OnDisallowListNotification added in v0.46.0 

func (_e *DisallowListNotificationConsumer_Expecter) OnDisallowListNotification(disallowListingUpdate interface{}) *DisallowListNotificationConsumer_OnDisallowListNotification_Call

OnDisallowListNotification is a helper method to define mock.On call

  • disallowListingUpdate *network.DisallowListingUpdate

type DisallowListNotificationConsumer_OnAllowListNotification_Call added in v0.46.0 

type DisallowListNotificationConsumer_OnAllowListNotification_Call struct {
	*mock.Call
}

DisallowListNotificationConsumer_OnAllowListNotification_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'OnAllowListNotification'

func (*DisallowListNotificationConsumer_OnAllowListNotification_Call) Return added in v0.46.0 

func (_c *DisallowListNotificationConsumer_OnAllowListNotification_Call) Return() *DisallowListNotificationConsumer_OnAllowListNotification_Call

func (*DisallowListNotificationConsumer_OnAllowListNotification_Call) Run added in v0.46.0 

func (_c *DisallowListNotificationConsumer_OnAllowListNotification_Call) Run(run func(allowListingUpdate *network.AllowListingUpdate)) *DisallowListNotificationConsumer_OnAllowListNotification_Call

func (*DisallowListNotificationConsumer_OnAllowListNotification_Call) RunAndReturn added in v0.46.0 

func (_c *DisallowListNotificationConsumer_OnAllowListNotification_Call) RunAndReturn(run func(allowListingUpdate *network.AllowListingUpdate)) *DisallowListNotificationConsumer_OnAllowListNotification_Call

type DisallowListNotificationConsumer_OnDisallowListNotification_Call added in v0.46.0 

type DisallowListNotificationConsumer_OnDisallowListNotification_Call struct {
	*mock.Call
}

DisallowListNotificationConsumer_OnDisallowListNotification_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'OnDisallowListNotification'

func (*DisallowListNotificationConsumer_OnDisallowListNotification_Call) Return added in v0.46.0 

func (_c *DisallowListNotificationConsumer_OnDisallowListNotification_Call) Return() *DisallowListNotificationConsumer_OnDisallowListNotification_Call

func (*DisallowListNotificationConsumer_OnDisallowListNotification_Call) Run added in v0.46.0 

func (_c *DisallowListNotificationConsumer_OnDisallowListNotification_Call) Run(run func(disallowListingUpdate *network.DisallowListingUpdate)) *DisallowListNotificationConsumer_OnDisallowListNotification_Call

func (*DisallowListNotificationConsumer_OnDisallowListNotification_Call) RunAndReturn added in v0.46.0 

func (_c *DisallowListNotificationConsumer_OnDisallowListNotification_Call) RunAndReturn(run func(disallowListingUpdate *network.DisallowListingUpdate)) *DisallowListNotificationConsumer_OnDisallowListNotification_Call

type Encoder 

type Encoder struct {
	mock.Mock
}

Encoder is an autogenerated mock type for the Encoder type

func NewEncoder added in v0.43.2 

func NewEncoder(t interface {
	mock.TestingT
	Cleanup(func())
}) *Encoder

NewEncoder creates a new instance of Encoder. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*Encoder) EXPECT added in v0.46.0 

func (_m *Encoder) EXPECT() *Encoder_Expecter

func (*Encoder) Encode 

func (_mock *Encoder) Encode(v any) error

Encode provides a mock function for the type Encoder

type Encoder_Encode_Call added in v0.46.0 

type Encoder_Encode_Call struct {
	*mock.Call
}

Encoder_Encode_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Encode'

func (*Encoder_Encode_Call) Return added in v0.46.0 

func (_c *Encoder_Encode_Call) Return(err error) *Encoder_Encode_Call

func (*Encoder_Encode_Call) Run added in v0.46.0 

func (_c *Encoder_Encode_Call) Run(run func(v any)) *Encoder_Encode_Call

func (*Encoder_Encode_Call) RunAndReturn added in v0.46.0 

func (_c *Encoder_Encode_Call) RunAndReturn(run func(v any) error) *Encoder_Encode_Call

type Encoder_Expecter added in v0.46.0 

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

func (*Encoder_Expecter) Encode added in v0.46.0 

func (_e *Encoder_Expecter) Encode(v interface{}) *Encoder_Encode_Call

Encode is a helper method to define mock.On call

  • v any

type Engine 

type Engine struct {
	mock.Mock
}

Engine is an autogenerated mock type for the Engine type

func NewEngine added in v0.43.2 

func NewEngine(t interface {
	mock.TestingT
	Cleanup(func())
}) *Engine

NewEngine creates a new instance of Engine. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*Engine) Done added in v0.43.2 

func (_mock *Engine) Done() <-chan struct{}

Done provides a mock function for the type Engine

func (*Engine) EXPECT added in v0.46.0 

func (_m *Engine) EXPECT() *Engine_Expecter

func (*Engine) Process 

func (_mock *Engine) Process(channel channels.Channel, originID flow.Identifier, event any) error

Process provides a mock function for the type Engine

func (*Engine) ProcessLocal 

func (_mock *Engine) ProcessLocal(event any) error

ProcessLocal provides a mock function for the type Engine

func (*Engine) Ready added in v0.43.2 

func (_mock *Engine) Ready() <-chan struct{}

Ready provides a mock function for the type Engine

func (*Engine) Submit 

func (_mock *Engine) Submit(channel channels.Channel, originID flow.Identifier, event any)

Submit provides a mock function for the type Engine

func (*Engine) SubmitLocal 

func (_mock *Engine) SubmitLocal(event any)

SubmitLocal provides a mock function for the type Engine

type EngineRegistry added in v0.43.2 

type EngineRegistry struct {
	mock.Mock
}

EngineRegistry is an autogenerated mock type for the EngineRegistry type

func NewEngineRegistry added in v0.43.2 

func NewEngineRegistry(t interface {
	mock.TestingT
	Cleanup(func())
}) *EngineRegistry

NewEngineRegistry creates a new instance of EngineRegistry. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*EngineRegistry) Done added in v0.43.2 

func (_mock *EngineRegistry) Done() <-chan struct{}

Done provides a mock function for the type EngineRegistry

func (*EngineRegistry) EXPECT added in v0.46.0 

func (_m *EngineRegistry) EXPECT() *EngineRegistry_Expecter

func (*EngineRegistry) Ready added in v0.43.2 

func (_mock *EngineRegistry) Ready() <-chan struct{}

Ready provides a mock function for the type EngineRegistry

func (*EngineRegistry) Register added in v0.43.2 

func (_mock *EngineRegistry) Register(channel channels.Channel, messageProcessor network.MessageProcessor) (network.Conduit, error)

Register provides a mock function for the type EngineRegistry

func (*EngineRegistry) RegisterBlobService added in v0.43.2 

func (_mock *EngineRegistry) RegisterBlobService(channel channels.Channel, store datastore.Batching, opts ...network.BlobServiceOption) (network.BlobService, error)

RegisterBlobService provides a mock function for the type EngineRegistry

func (*EngineRegistry) RegisterPingService added in v0.43.2 

func (_mock *EngineRegistry) RegisterPingService(pingProtocolID protocol.ID, pingInfoProvider network.PingInfoProvider) (network.PingService, error)

RegisterPingService provides a mock function for the type EngineRegistry

func (*EngineRegistry) Start added in v0.43.2 

func (_mock *EngineRegistry) Start(signalerContext irrecoverable.SignalerContext)

Start provides a mock function for the type EngineRegistry

type EngineRegistry_Done_Call added in v0.46.0 

type EngineRegistry_Done_Call struct {
	*mock.Call
}

EngineRegistry_Done_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Done'

func (*EngineRegistry_Done_Call) Return added in v0.46.0 

func (_c *EngineRegistry_Done_Call) Return(valCh <-chan struct{}) *EngineRegistry_Done_Call

func (*EngineRegistry_Done_Call) Run added in v0.46.0 

func (_c *EngineRegistry_Done_Call) Run(run func()) *EngineRegistry_Done_Call

func (*EngineRegistry_Done_Call) RunAndReturn added in v0.46.0 

func (_c *EngineRegistry_Done_Call) RunAndReturn(run func() <-chan struct{}) *EngineRegistry_Done_Call

type EngineRegistry_Expecter added in v0.46.0 

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

func (*EngineRegistry_Expecter) Done added in v0.46.0 

func (_e *EngineRegistry_Expecter) Done() *EngineRegistry_Done_Call

Done is a helper method to define mock.On call

func (*EngineRegistry_Expecter) Ready added in v0.46.0 

func (_e *EngineRegistry_Expecter) Ready() *EngineRegistry_Ready_Call

Ready is a helper method to define mock.On call

func (*EngineRegistry_Expecter) Register added in v0.46.0 

func (_e *EngineRegistry_Expecter) Register(channel interface{}, messageProcessor interface{}) *EngineRegistry_Register_Call

Register is a helper method to define mock.On call

  • channel channels.Channel
  • messageProcessor network.MessageProcessor

func (*EngineRegistry_Expecter) RegisterBlobService added in v0.46.0 

func (_e *EngineRegistry_Expecter) RegisterBlobService(channel interface{}, store interface{}, opts ...interface{}) *EngineRegistry_RegisterBlobService_Call

RegisterBlobService is a helper method to define mock.On call

  • channel channels.Channel
  • store datastore.Batching
  • opts ...network.BlobServiceOption

func (*EngineRegistry_Expecter) RegisterPingService added in v0.46.0 

func (_e *EngineRegistry_Expecter) RegisterPingService(pingProtocolID interface{}, pingInfoProvider interface{}) *EngineRegistry_RegisterPingService_Call

RegisterPingService is a helper method to define mock.On call

  • pingProtocolID protocol.ID
  • pingInfoProvider network.PingInfoProvider

func (*EngineRegistry_Expecter) Start added in v0.46.0 

func (_e *EngineRegistry_Expecter) Start(signalerContext interface{}) *EngineRegistry_Start_Call

Start is a helper method to define mock.On call

  • signalerContext irrecoverable.SignalerContext

type EngineRegistry_Ready_Call added in v0.46.0 

type EngineRegistry_Ready_Call struct {
	*mock.Call
}

EngineRegistry_Ready_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Ready'

func (*EngineRegistry_Ready_Call) Return added in v0.46.0 

func (_c *EngineRegistry_Ready_Call) Return(valCh <-chan struct{}) *EngineRegistry_Ready_Call

func (*EngineRegistry_Ready_Call) Run added in v0.46.0 

func (_c *EngineRegistry_Ready_Call) Run(run func()) *EngineRegistry_Ready_Call

func (*EngineRegistry_Ready_Call) RunAndReturn added in v0.46.0 

func (_c *EngineRegistry_Ready_Call) RunAndReturn(run func() <-chan struct{}) *EngineRegistry_Ready_Call

type EngineRegistry_RegisterBlobService_Call added in v0.46.0 

type EngineRegistry_RegisterBlobService_Call struct {
	*mock.Call
}

EngineRegistry_RegisterBlobService_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RegisterBlobService'

func (*EngineRegistry_RegisterBlobService_Call) Return added in v0.46.0 

func (_c *EngineRegistry_RegisterBlobService_Call) Return(blobService network.BlobService, err error) *EngineRegistry_RegisterBlobService_Call

func (*EngineRegistry_RegisterBlobService_Call) Run added in v0.46.0 

func (_c *EngineRegistry_RegisterBlobService_Call) Run(run func(channel channels.Channel, store datastore.Batching, opts ...network.BlobServiceOption)) *EngineRegistry_RegisterBlobService_Call

func (*EngineRegistry_RegisterBlobService_Call) RunAndReturn added in v0.46.0 

func (_c *EngineRegistry_RegisterBlobService_Call) RunAndReturn(run func(channel channels.Channel, store datastore.Batching, opts ...network.BlobServiceOption) (network.BlobService, error)) *EngineRegistry_RegisterBlobService_Call

type EngineRegistry_RegisterPingService_Call added in v0.46.0 

type EngineRegistry_RegisterPingService_Call struct {
	*mock.Call
}

EngineRegistry_RegisterPingService_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RegisterPingService'

func (*EngineRegistry_RegisterPingService_Call) Return added in v0.46.0 

func (_c *EngineRegistry_RegisterPingService_Call) Return(pingService network.PingService, err error) *EngineRegistry_RegisterPingService_Call

func (*EngineRegistry_RegisterPingService_Call) Run added in v0.46.0 

func (_c *EngineRegistry_RegisterPingService_Call) Run(run func(pingProtocolID protocol.ID, pingInfoProvider network.PingInfoProvider)) *EngineRegistry_RegisterPingService_Call

func (*EngineRegistry_RegisterPingService_Call) RunAndReturn added in v0.46.0 

func (_c *EngineRegistry_RegisterPingService_Call) RunAndReturn(run func(pingProtocolID protocol.ID, pingInfoProvider network.PingInfoProvider) (network.PingService, error)) *EngineRegistry_RegisterPingService_Call

type EngineRegistry_Register_Call added in v0.46.0 

type EngineRegistry_Register_Call struct {
	*mock.Call
}

EngineRegistry_Register_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Register'

func (*EngineRegistry_Register_Call) Return added in v0.46.0 

func (_c *EngineRegistry_Register_Call) Return(conduit network.Conduit, err error) *EngineRegistry_Register_Call

func (*EngineRegistry_Register_Call) Run added in v0.46.0 

func (_c *EngineRegistry_Register_Call) Run(run func(channel channels.Channel, messageProcessor network.MessageProcessor)) *EngineRegistry_Register_Call

func (*EngineRegistry_Register_Call) RunAndReturn added in v0.46.0 

func (_c *EngineRegistry_Register_Call) RunAndReturn(run func(channel channels.Channel, messageProcessor network.MessageProcessor) (network.Conduit, error)) *EngineRegistry_Register_Call

type EngineRegistry_Start_Call added in v0.46.0 

type EngineRegistry_Start_Call struct {
	*mock.Call
}

EngineRegistry_Start_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Start'

func (*EngineRegistry_Start_Call) Return added in v0.46.0 

func (_c *EngineRegistry_Start_Call) Return() *EngineRegistry_Start_Call

func (*EngineRegistry_Start_Call) Run added in v0.46.0 

func (_c *EngineRegistry_Start_Call) Run(run func(signalerContext irrecoverable.SignalerContext)) *EngineRegistry_Start_Call

func (*EngineRegistry_Start_Call) RunAndReturn added in v0.46.0 

func (_c *EngineRegistry_Start_Call) RunAndReturn(run func(signalerContext irrecoverable.SignalerContext)) *EngineRegistry_Start_Call

type Engine_Done_Call added in v0.46.0 

type Engine_Done_Call struct {
	*mock.Call
}

Engine_Done_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Done'

func (*Engine_Done_Call) Return added in v0.46.0 

func (_c *Engine_Done_Call) Return(valCh <-chan struct{}) *Engine_Done_Call

func (*Engine_Done_Call) Run added in v0.46.0 

func (_c *Engine_Done_Call) Run(run func()) *Engine_Done_Call

func (*Engine_Done_Call) RunAndReturn added in v0.46.0 

func (_c *Engine_Done_Call) RunAndReturn(run func() <-chan struct{}) *Engine_Done_Call

type Engine_Expecter added in v0.46.0 

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

func (*Engine_Expecter) Done added in v0.46.0 

func (_e *Engine_Expecter) Done() *Engine_Done_Call

Done is a helper method to define mock.On call

func (*Engine_Expecter) Process added in v0.46.0 

func (_e *Engine_Expecter) Process(channel interface{}, originID interface{}, event interface{}) *Engine_Process_Call

Process is a helper method to define mock.On call

  • channel channels.Channel
  • originID flow.Identifier
  • event any

func (*Engine_Expecter) ProcessLocal added in v0.46.0 

func (_e *Engine_Expecter) ProcessLocal(event interface{}) *Engine_ProcessLocal_Call

ProcessLocal is a helper method to define mock.On call

  • event any

func (*Engine_Expecter) Ready added in v0.46.0 

func (_e *Engine_Expecter) Ready() *Engine_Ready_Call

Ready is a helper method to define mock.On call

func (*Engine_Expecter) Submit added in v0.46.0 

func (_e *Engine_Expecter) Submit(channel interface{}, originID interface{}, event interface{}) *Engine_Submit_Call

Submit is a helper method to define mock.On call

  • channel channels.Channel
  • originID flow.Identifier
  • event any

func (*Engine_Expecter) SubmitLocal added in v0.46.0 

func (_e *Engine_Expecter) SubmitLocal(event interface{}) *Engine_SubmitLocal_Call

SubmitLocal is a helper method to define mock.On call

  • event any

type Engine_ProcessLocal_Call added in v0.46.0 

type Engine_ProcessLocal_Call struct {
	*mock.Call
}

Engine_ProcessLocal_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ProcessLocal'

func (*Engine_ProcessLocal_Call) Return added in v0.46.0 

func (_c *Engine_ProcessLocal_Call) Return(err error) *Engine_ProcessLocal_Call

func (*Engine_ProcessLocal_Call) Run added in v0.46.0 

func (_c *Engine_ProcessLocal_Call) Run(run func(event any)) *Engine_ProcessLocal_Call

func (*Engine_ProcessLocal_Call) RunAndReturn added in v0.46.0 

func (_c *Engine_ProcessLocal_Call) RunAndReturn(run func(event any) error) *Engine_ProcessLocal_Call

type Engine_Process_Call added in v0.46.0 

type Engine_Process_Call struct {
	*mock.Call
}

Engine_Process_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Process'

func (*Engine_Process_Call) Return added in v0.46.0 

func (_c *Engine_Process_Call) Return(err error) *Engine_Process_Call

func (*Engine_Process_Call) Run added in v0.46.0 

func (_c *Engine_Process_Call) Run(run func(channel channels.Channel, originID flow.Identifier, event any)) *Engine_Process_Call

func (*Engine_Process_Call) RunAndReturn added in v0.46.0 

func (_c *Engine_Process_Call) RunAndReturn(run func(channel channels.Channel, originID flow.Identifier, event any) error) *Engine_Process_Call

type Engine_Ready_Call added in v0.46.0 

type Engine_Ready_Call struct {
	*mock.Call
}

Engine_Ready_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Ready'

func (*Engine_Ready_Call) Return added in v0.46.0 

func (_c *Engine_Ready_Call) Return(valCh <-chan struct{}) *Engine_Ready_Call

func (*Engine_Ready_Call) Run added in v0.46.0 

func (_c *Engine_Ready_Call) Run(run func()) *Engine_Ready_Call

func (*Engine_Ready_Call) RunAndReturn added in v0.46.0 

func (_c *Engine_Ready_Call) RunAndReturn(run func() <-chan struct{}) *Engine_Ready_Call

type Engine_SubmitLocal_Call added in v0.46.0 

type Engine_SubmitLocal_Call struct {
	*mock.Call
}

Engine_SubmitLocal_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SubmitLocal'

func (*Engine_SubmitLocal_Call) Return added in v0.46.0 

func (_c *Engine_SubmitLocal_Call) Return() *Engine_SubmitLocal_Call

func (*Engine_SubmitLocal_Call) Run added in v0.46.0 

func (_c *Engine_SubmitLocal_Call) Run(run func(event any)) *Engine_SubmitLocal_Call

func (*Engine_SubmitLocal_Call) RunAndReturn added in v0.46.0 

func (_c *Engine_SubmitLocal_Call) RunAndReturn(run func(event any)) *Engine_SubmitLocal_Call

type Engine_Submit_Call added in v0.46.0 

type Engine_Submit_Call struct {
	*mock.Call
}

Engine_Submit_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Submit'

func (*Engine_Submit_Call) Return added in v0.46.0 

func (_c *Engine_Submit_Call) Return() *Engine_Submit_Call

func (*Engine_Submit_Call) Run added in v0.46.0 

func (_c *Engine_Submit_Call) Run(run func(channel channels.Channel, originID flow.Identifier, event any)) *Engine_Submit_Call

func (*Engine_Submit_Call) RunAndReturn added in v0.46.0 

func (_c *Engine_Submit_Call) RunAndReturn(run func(channel channels.Channel, originID flow.Identifier, event any)) *Engine_Submit_Call

type IncomingMessageScope added in v0.43.2 

type IncomingMessageScope struct {
	mock.Mock
}

IncomingMessageScope is an autogenerated mock type for the IncomingMessageScope type

func NewIncomingMessageScope added in v0.43.2 

func NewIncomingMessageScope(t interface {
	mock.TestingT
	Cleanup(func())
}) *IncomingMessageScope

NewIncomingMessageScope creates a new instance of IncomingMessageScope. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*IncomingMessageScope) Channel added in v0.43.2 

func (_mock *IncomingMessageScope) Channel() channels.Channel

Channel provides a mock function for the type IncomingMessageScope

func (*IncomingMessageScope) DecodedPayload added in v0.43.2 

func (_mock *IncomingMessageScope) DecodedPayload() any

DecodedPayload provides a mock function for the type IncomingMessageScope

func (*IncomingMessageScope) EXPECT added in v0.46.0 

func (_m *IncomingMessageScope) EXPECT() *IncomingMessageScope_Expecter

func (*IncomingMessageScope) EventID added in v0.43.2 

func (_mock *IncomingMessageScope) EventID() []byte

EventID provides a mock function for the type IncomingMessageScope

func (*IncomingMessageScope) OriginId added in v0.43.2 

func (_mock *IncomingMessageScope) OriginId() flow.Identifier

OriginId provides a mock function for the type IncomingMessageScope

func (*IncomingMessageScope) PayloadType added in v0.43.2 

func (_mock *IncomingMessageScope) PayloadType() string

PayloadType provides a mock function for the type IncomingMessageScope

func (*IncomingMessageScope) Proto added in v0.43.2 

func (_mock *IncomingMessageScope) Proto() *message.Message

Proto provides a mock function for the type IncomingMessageScope

func (*IncomingMessageScope) Protocol added in v0.43.2 

func (_mock *IncomingMessageScope) Protocol() message.ProtocolType

Protocol provides a mock function for the type IncomingMessageScope

func (*IncomingMessageScope) Size added in v0.43.2 

func (_mock *IncomingMessageScope) Size() int

Size provides a mock function for the type IncomingMessageScope

func (*IncomingMessageScope) TargetIDs added in v0.43.2 

func (_mock *IncomingMessageScope) TargetIDs() flow.IdentifierList

TargetIDs provides a mock function for the type IncomingMessageScope

type IncomingMessageScope_Channel_Call added in v0.46.0 

type IncomingMessageScope_Channel_Call struct {
	*mock.Call
}

IncomingMessageScope_Channel_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Channel'

func (*IncomingMessageScope_Channel_Call) Return added in v0.46.0 

func (_c *IncomingMessageScope_Channel_Call) Return(channel channels.Channel) *IncomingMessageScope_Channel_Call

func (*IncomingMessageScope_Channel_Call) Run added in v0.46.0 

func (_c *IncomingMessageScope_Channel_Call) Run(run func()) *IncomingMessageScope_Channel_Call

func (*IncomingMessageScope_Channel_Call) RunAndReturn added in v0.46.0 

func (_c *IncomingMessageScope_Channel_Call) RunAndReturn(run func() channels.Channel) *IncomingMessageScope_Channel_Call

type IncomingMessageScope_DecodedPayload_Call added in v0.46.0 

type IncomingMessageScope_DecodedPayload_Call struct {
	*mock.Call
}

IncomingMessageScope_DecodedPayload_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DecodedPayload'

func (*IncomingMessageScope_DecodedPayload_Call) Return added in v0.46.0 

func (_c *IncomingMessageScope_DecodedPayload_Call) Return(v any) *IncomingMessageScope_DecodedPayload_Call

func (*IncomingMessageScope_DecodedPayload_Call) Run added in v0.46.0 

func (_c *IncomingMessageScope_DecodedPayload_Call) Run(run func()) *IncomingMessageScope_DecodedPayload_Call

func (*IncomingMessageScope_DecodedPayload_Call) RunAndReturn added in v0.46.0 

func (_c *IncomingMessageScope_DecodedPayload_Call) RunAndReturn(run func() any) *IncomingMessageScope_DecodedPayload_Call

type IncomingMessageScope_EventID_Call added in v0.46.0 

type IncomingMessageScope_EventID_Call struct {
	*mock.Call
}

IncomingMessageScope_EventID_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'EventID'

func (*IncomingMessageScope_EventID_Call) Return added in v0.46.0 

func (_c *IncomingMessageScope_EventID_Call) Return(bytes []byte) *IncomingMessageScope_EventID_Call

func (*IncomingMessageScope_EventID_Call) Run added in v0.46.0 

func (_c *IncomingMessageScope_EventID_Call) Run(run func()) *IncomingMessageScope_EventID_Call

func (*IncomingMessageScope_EventID_Call) RunAndReturn added in v0.46.0 

func (_c *IncomingMessageScope_EventID_Call) RunAndReturn(run func() []byte) *IncomingMessageScope_EventID_Call

type IncomingMessageScope_Expecter added in v0.46.0 

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

func (*IncomingMessageScope_Expecter) Channel added in v0.46.0 

func (_e *IncomingMessageScope_Expecter) Channel() *IncomingMessageScope_Channel_Call

Channel is a helper method to define mock.On call

func (*IncomingMessageScope_Expecter) DecodedPayload added in v0.46.0 

func (_e *IncomingMessageScope_Expecter) DecodedPayload() *IncomingMessageScope_DecodedPayload_Call

DecodedPayload is a helper method to define mock.On call

func (*IncomingMessageScope_Expecter) EventID added in v0.46.0 

func (_e *IncomingMessageScope_Expecter) EventID() *IncomingMessageScope_EventID_Call

EventID is a helper method to define mock.On call

func (*IncomingMessageScope_Expecter) OriginId added in v0.46.0 

func (_e *IncomingMessageScope_Expecter) OriginId() *IncomingMessageScope_OriginId_Call

OriginId is a helper method to define mock.On call

func (*IncomingMessageScope_Expecter) PayloadType added in v0.46.0 

func (_e *IncomingMessageScope_Expecter) PayloadType() *IncomingMessageScope_PayloadType_Call

PayloadType is a helper method to define mock.On call

func (*IncomingMessageScope_Expecter) Proto added in v0.46.0 

func (_e *IncomingMessageScope_Expecter) Proto() *IncomingMessageScope_Proto_Call

Proto is a helper method to define mock.On call

func (*IncomingMessageScope_Expecter) Protocol added in v0.46.0 

func (_e *IncomingMessageScope_Expecter) Protocol() *IncomingMessageScope_Protocol_Call

Protocol is a helper method to define mock.On call

func (*IncomingMessageScope_Expecter) Size added in v0.46.0 

func (_e *IncomingMessageScope_Expecter) Size() *IncomingMessageScope_Size_Call

Size is a helper method to define mock.On call

func (*IncomingMessageScope_Expecter) TargetIDs added in v0.46.0 

func (_e *IncomingMessageScope_Expecter) TargetIDs() *IncomingMessageScope_TargetIDs_Call

TargetIDs is a helper method to define mock.On call

type IncomingMessageScope_OriginId_Call added in v0.46.0 

type IncomingMessageScope_OriginId_Call struct {
	*mock.Call
}

IncomingMessageScope_OriginId_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'OriginId'

func (*IncomingMessageScope_OriginId_Call) Return added in v0.46.0 

func (_c *IncomingMessageScope_OriginId_Call) Return(identifier flow.Identifier) *IncomingMessageScope_OriginId_Call

func (*IncomingMessageScope_OriginId_Call) Run added in v0.46.0 

func (_c *IncomingMessageScope_OriginId_Call) Run(run func()) *IncomingMessageScope_OriginId_Call

func (*IncomingMessageScope_OriginId_Call) RunAndReturn added in v0.46.0 

func (_c *IncomingMessageScope_OriginId_Call) RunAndReturn(run func() flow.Identifier) *IncomingMessageScope_OriginId_Call

type IncomingMessageScope_PayloadType_Call added in v0.46.0 

type IncomingMessageScope_PayloadType_Call struct {
	*mock.Call
}

IncomingMessageScope_PayloadType_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'PayloadType'

func (*IncomingMessageScope_PayloadType_Call) Return added in v0.46.0 

func (_c *IncomingMessageScope_PayloadType_Call) Return(s string) *IncomingMessageScope_PayloadType_Call

func (*IncomingMessageScope_PayloadType_Call) Run added in v0.46.0 

func (_c *IncomingMessageScope_PayloadType_Call) Run(run func()) *IncomingMessageScope_PayloadType_Call

func (*IncomingMessageScope_PayloadType_Call) RunAndReturn added in v0.46.0 

func (_c *IncomingMessageScope_PayloadType_Call) RunAndReturn(run func() string) *IncomingMessageScope_PayloadType_Call

type IncomingMessageScope_Proto_Call added in v0.46.0 

type IncomingMessageScope_Proto_Call struct {
	*mock.Call
}

IncomingMessageScope_Proto_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Proto'

func (*IncomingMessageScope_Proto_Call) Return added in v0.46.0 

func (_c *IncomingMessageScope_Proto_Call) Return(message1 *message.Message) *IncomingMessageScope_Proto_Call

func (*IncomingMessageScope_Proto_Call) Run added in v0.46.0 

func (_c *IncomingMessageScope_Proto_Call) Run(run func()) *IncomingMessageScope_Proto_Call

func (*IncomingMessageScope_Proto_Call) RunAndReturn added in v0.46.0 

func (_c *IncomingMessageScope_Proto_Call) RunAndReturn(run func() *message.Message) *IncomingMessageScope_Proto_Call

type IncomingMessageScope_Protocol_Call added in v0.46.0 

type IncomingMessageScope_Protocol_Call struct {
	*mock.Call
}

IncomingMessageScope_Protocol_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Protocol'

func (*IncomingMessageScope_Protocol_Call) Return added in v0.46.0 

func (_c *IncomingMessageScope_Protocol_Call) Return(protocolType message.ProtocolType) *IncomingMessageScope_Protocol_Call

func (*IncomingMessageScope_Protocol_Call) Run added in v0.46.0 

func (_c *IncomingMessageScope_Protocol_Call) Run(run func()) *IncomingMessageScope_Protocol_Call

func (*IncomingMessageScope_Protocol_Call) RunAndReturn added in v0.46.0 

func (_c *IncomingMessageScope_Protocol_Call) RunAndReturn(run func() message.ProtocolType) *IncomingMessageScope_Protocol_Call

type IncomingMessageScope_Size_Call added in v0.46.0 

type IncomingMessageScope_Size_Call struct {
	*mock.Call
}

IncomingMessageScope_Size_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Size'

func (*IncomingMessageScope_Size_Call) Return added in v0.46.0 

func (_c *IncomingMessageScope_Size_Call) Return(n int) *IncomingMessageScope_Size_Call

func (*IncomingMessageScope_Size_Call) Run added in v0.46.0 

func (_c *IncomingMessageScope_Size_Call) Run(run func()) *IncomingMessageScope_Size_Call

func (*IncomingMessageScope_Size_Call) RunAndReturn added in v0.46.0 

func (_c *IncomingMessageScope_Size_Call) RunAndReturn(run func() int) *IncomingMessageScope_Size_Call

type IncomingMessageScope_TargetIDs_Call added in v0.46.0 

type IncomingMessageScope_TargetIDs_Call struct {
	*mock.Call
}

IncomingMessageScope_TargetIDs_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'TargetIDs'

func (*IncomingMessageScope_TargetIDs_Call) Return added in v0.46.0 

func (_c *IncomingMessageScope_TargetIDs_Call) Return(identifierList flow.IdentifierList) *IncomingMessageScope_TargetIDs_Call

func (*IncomingMessageScope_TargetIDs_Call) Run added in v0.46.0 

func (_c *IncomingMessageScope_TargetIDs_Call) Run(run func()) *IncomingMessageScope_TargetIDs_Call

func (*IncomingMessageScope_TargetIDs_Call) RunAndReturn added in v0.46.0 

func (_c *IncomingMessageScope_TargetIDs_Call) RunAndReturn(run func() flow.IdentifierList) *IncomingMessageScope_TargetIDs_Call

type MessageProcessor added in v0.43.2 

type MessageProcessor struct {
	mock.Mock
}

MessageProcessor is an autogenerated mock type for the MessageProcessor type

func NewMessageProcessor added in v0.43.2 

func NewMessageProcessor(t interface {
	mock.TestingT
	Cleanup(func())
}) *MessageProcessor

NewMessageProcessor creates a new instance of MessageProcessor. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*MessageProcessor) EXPECT added in v0.46.0 

func (_m *MessageProcessor) EXPECT() *MessageProcessor_Expecter

func (*MessageProcessor) Process added in v0.43.2 

func (_mock *MessageProcessor) Process(channel channels.Channel, originID flow.Identifier, message any) error

Process provides a mock function for the type MessageProcessor

type MessageProcessor_Expecter added in v0.46.0 

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

func (*MessageProcessor_Expecter) Process added in v0.46.0 

func (_e *MessageProcessor_Expecter) Process(channel interface{}, originID interface{}, message interface{}) *MessageProcessor_Process_Call

Process is a helper method to define mock.On call

  • channel channels.Channel
  • originID flow.Identifier
  • message any

type MessageProcessor_Process_Call added in v0.46.0 

type MessageProcessor_Process_Call struct {
	*mock.Call
}

MessageProcessor_Process_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Process'

func (*MessageProcessor_Process_Call) Return added in v0.46.0 

func (_c *MessageProcessor_Process_Call) Return(err error) *MessageProcessor_Process_Call

func (*MessageProcessor_Process_Call) Run added in v0.46.0 

func (_c *MessageProcessor_Process_Call) Run(run func(channel channels.Channel, originID flow.Identifier, message any)) *MessageProcessor_Process_Call

func (*MessageProcessor_Process_Call) RunAndReturn added in v0.46.0 

func (_c *MessageProcessor_Process_Call) RunAndReturn(run func(channel channels.Channel, originID flow.Identifier, message any) error) *MessageProcessor_Process_Call

type MessageQueue added in v0.43.2 

type MessageQueue struct {
	mock.Mock
}

MessageQueue is an autogenerated mock type for the MessageQueue type

func NewMessageQueue added in v0.43.2 

func NewMessageQueue(t interface {
	mock.TestingT
	Cleanup(func())
}) *MessageQueue

NewMessageQueue creates a new instance of MessageQueue. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*MessageQueue) EXPECT added in v0.46.0 

func (_m *MessageQueue) EXPECT() *MessageQueue_Expecter

func (*MessageQueue) Insert added in v0.43.2 

func (_mock *MessageQueue) Insert(message any) error

Insert provides a mock function for the type MessageQueue

func (*MessageQueue) Len added in v0.43.2 

func (_mock *MessageQueue) Len() int

Len provides a mock function for the type MessageQueue

func (*MessageQueue) Remove added in v0.43.2 

func (_mock *MessageQueue) Remove() any

Remove provides a mock function for the type MessageQueue

type MessageQueue_Expecter added in v0.46.0 

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

func (*MessageQueue_Expecter) Insert added in v0.46.0 

func (_e *MessageQueue_Expecter) Insert(message interface{}) *MessageQueue_Insert_Call

Insert is a helper method to define mock.On call

  • message any

func (*MessageQueue_Expecter) Len added in v0.46.0 

func (_e *MessageQueue_Expecter) Len() *MessageQueue_Len_Call

Len is a helper method to define mock.On call

func (*MessageQueue_Expecter) Remove added in v0.46.0 

func (_e *MessageQueue_Expecter) Remove() *MessageQueue_Remove_Call

Remove is a helper method to define mock.On call

type MessageQueue_Insert_Call added in v0.46.0 

type MessageQueue_Insert_Call struct {
	*mock.Call
}

MessageQueue_Insert_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Insert'

func (*MessageQueue_Insert_Call) Return added in v0.46.0 

func (_c *MessageQueue_Insert_Call) Return(err error) *MessageQueue_Insert_Call

func (*MessageQueue_Insert_Call) Run added in v0.46.0 

func (_c *MessageQueue_Insert_Call) Run(run func(message any)) *MessageQueue_Insert_Call

func (*MessageQueue_Insert_Call) RunAndReturn added in v0.46.0 

func (_c *MessageQueue_Insert_Call) RunAndReturn(run func(message any) error) *MessageQueue_Insert_Call

type MessageQueue_Len_Call added in v0.46.0 

type MessageQueue_Len_Call struct {
	*mock.Call
}

MessageQueue_Len_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Len'

func (*MessageQueue_Len_Call) Return added in v0.46.0 

func (_c *MessageQueue_Len_Call) Return(n int) *MessageQueue_Len_Call

func (*MessageQueue_Len_Call) Run added in v0.46.0 

func (_c *MessageQueue_Len_Call) Run(run func()) *MessageQueue_Len_Call

func (*MessageQueue_Len_Call) RunAndReturn added in v0.46.0 

func (_c *MessageQueue_Len_Call) RunAndReturn(run func() int) *MessageQueue_Len_Call

type MessageQueue_Remove_Call added in v0.46.0 

type MessageQueue_Remove_Call struct {
	*mock.Call
}

MessageQueue_Remove_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Remove'

func (*MessageQueue_Remove_Call) Return added in v0.46.0 

func (_c *MessageQueue_Remove_Call) Return(v any) *MessageQueue_Remove_Call

func (*MessageQueue_Remove_Call) Run added in v0.46.0 

func (_c *MessageQueue_Remove_Call) Run(run func()) *MessageQueue_Remove_Call

func (*MessageQueue_Remove_Call) RunAndReturn added in v0.46.0 

func (_c *MessageQueue_Remove_Call) RunAndReturn(run func() any) *MessageQueue_Remove_Call

type MessageValidator added in v0.43.2 

type MessageValidator struct {
	mock.Mock
}

MessageValidator is an autogenerated mock type for the MessageValidator type

func NewMessageValidator added in v0.43.2 

func NewMessageValidator(t interface {
	mock.TestingT
	Cleanup(func())
}) *MessageValidator

NewMessageValidator creates a new instance of MessageValidator. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*MessageValidator) EXPECT added in v0.46.0 

func (_m *MessageValidator) EXPECT() *MessageValidator_Expecter

func (*MessageValidator) Validate added in v0.43.2 

func (_mock *MessageValidator) Validate(msg network.IncomingMessageScope) bool

Validate provides a mock function for the type MessageValidator

type MessageValidator_Expecter added in v0.46.0 

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

func (*MessageValidator_Expecter) Validate added in v0.46.0 

func (_e *MessageValidator_Expecter) Validate(msg interface{}) *MessageValidator_Validate_Call

Validate is a helper method to define mock.On call

  • msg network.IncomingMessageScope

type MessageValidator_Validate_Call added in v0.46.0 

type MessageValidator_Validate_Call struct {
	*mock.Call
}

MessageValidator_Validate_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Validate'

func (*MessageValidator_Validate_Call) Return added in v0.46.0 

func (_c *MessageValidator_Validate_Call) Return(b bool) *MessageValidator_Validate_Call

func (*MessageValidator_Validate_Call) Run added in v0.46.0 

func (_c *MessageValidator_Validate_Call) Run(run func(msg network.IncomingMessageScope)) *MessageValidator_Validate_Call

func (*MessageValidator_Validate_Call) RunAndReturn added in v0.46.0 

func (_c *MessageValidator_Validate_Call) RunAndReturn(run func(msg network.IncomingMessageScope) bool) *MessageValidator_Validate_Call

type MisbehaviorReport added in v0.43.2 

type MisbehaviorReport struct {
	mock.Mock
}

MisbehaviorReport is an autogenerated mock type for the MisbehaviorReport type

func NewMisbehaviorReport added in v0.43.2 

func NewMisbehaviorReport(t interface {
	mock.TestingT
	Cleanup(func())
}) *MisbehaviorReport

NewMisbehaviorReport creates a new instance of MisbehaviorReport. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*MisbehaviorReport) EXPECT added in v0.46.0 

func (_m *MisbehaviorReport) EXPECT() *MisbehaviorReport_Expecter

func (*MisbehaviorReport) OriginId added in v0.43.2 

func (_mock *MisbehaviorReport) OriginId() flow.Identifier

OriginId provides a mock function for the type MisbehaviorReport

func (*MisbehaviorReport) Penalty added in v0.43.2 

func (_mock *MisbehaviorReport) Penalty() float64

Penalty provides a mock function for the type MisbehaviorReport

func (*MisbehaviorReport) Reason added in v0.43.2 

func (_mock *MisbehaviorReport) Reason() network.Misbehavior

Reason provides a mock function for the type MisbehaviorReport

type MisbehaviorReportConsumer added in v0.43.2 

type MisbehaviorReportConsumer struct {
	mock.Mock
}

MisbehaviorReportConsumer is an autogenerated mock type for the MisbehaviorReportConsumer type

func NewMisbehaviorReportConsumer added in v0.43.2 

func NewMisbehaviorReportConsumer(t interface {
	mock.TestingT
	Cleanup(func())
}) *MisbehaviorReportConsumer

NewMisbehaviorReportConsumer creates a new instance of MisbehaviorReportConsumer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*MisbehaviorReportConsumer) EXPECT added in v0.46.0 

func (_m *MisbehaviorReportConsumer) EXPECT() *MisbehaviorReportConsumer_Expecter

func (*MisbehaviorReportConsumer) ReportMisbehaviorOnChannel added in v0.43.2 

func (_mock *MisbehaviorReportConsumer) ReportMisbehaviorOnChannel(channel channels.Channel, report network.MisbehaviorReport)

ReportMisbehaviorOnChannel provides a mock function for the type MisbehaviorReportConsumer

type MisbehaviorReportConsumer_Expecter added in v0.46.0 

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

func (*MisbehaviorReportConsumer_Expecter) ReportMisbehaviorOnChannel added in v0.46.0 

func (_e *MisbehaviorReportConsumer_Expecter) ReportMisbehaviorOnChannel(channel interface{}, report interface{}) *MisbehaviorReportConsumer_ReportMisbehaviorOnChannel_Call

ReportMisbehaviorOnChannel is a helper method to define mock.On call

  • channel channels.Channel
  • report network.MisbehaviorReport

type MisbehaviorReportConsumer_ReportMisbehaviorOnChannel_Call added in v0.46.0 

type MisbehaviorReportConsumer_ReportMisbehaviorOnChannel_Call struct {
	*mock.Call
}

MisbehaviorReportConsumer_ReportMisbehaviorOnChannel_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ReportMisbehaviorOnChannel'

func (*MisbehaviorReportConsumer_ReportMisbehaviorOnChannel_Call) Return added in v0.46.0 

func (_c *MisbehaviorReportConsumer_ReportMisbehaviorOnChannel_Call) Return() *MisbehaviorReportConsumer_ReportMisbehaviorOnChannel_Call

func (*MisbehaviorReportConsumer_ReportMisbehaviorOnChannel_Call) Run added in v0.46.0 

func (_c *MisbehaviorReportConsumer_ReportMisbehaviorOnChannel_Call) Run(run func(channel channels.Channel, report network.MisbehaviorReport)) *MisbehaviorReportConsumer_ReportMisbehaviorOnChannel_Call

func (*MisbehaviorReportConsumer_ReportMisbehaviorOnChannel_Call) RunAndReturn added in v0.46.0 

func (_c *MisbehaviorReportConsumer_ReportMisbehaviorOnChannel_Call) RunAndReturn(run func(channel channels.Channel, report network.MisbehaviorReport)) *MisbehaviorReportConsumer_ReportMisbehaviorOnChannel_Call

type MisbehaviorReportManager added in v0.43.2 

type MisbehaviorReportManager struct {
	mock.Mock
}

MisbehaviorReportManager is an autogenerated mock type for the MisbehaviorReportManager type

func NewMisbehaviorReportManager added in v0.43.2 

func NewMisbehaviorReportManager(t interface {
	mock.TestingT
	Cleanup(func())
}) *MisbehaviorReportManager

NewMisbehaviorReportManager creates a new instance of MisbehaviorReportManager. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*MisbehaviorReportManager) Done added in v0.43.2 

func (_mock *MisbehaviorReportManager) Done() <-chan struct{}

Done provides a mock function for the type MisbehaviorReportManager

func (*MisbehaviorReportManager) EXPECT added in v0.46.0 

func (_m *MisbehaviorReportManager) EXPECT() *MisbehaviorReportManager_Expecter

func (*MisbehaviorReportManager) HandleMisbehaviorReport added in v0.43.2 

func (_mock *MisbehaviorReportManager) HandleMisbehaviorReport(channel channels.Channel, misbehaviorReport network.MisbehaviorReport)

HandleMisbehaviorReport provides a mock function for the type MisbehaviorReportManager

func (*MisbehaviorReportManager) Ready added in v0.43.2 

func (_mock *MisbehaviorReportManager) Ready() <-chan struct{}

Ready provides a mock function for the type MisbehaviorReportManager

func (*MisbehaviorReportManager) Start added in v0.43.2 

func (_mock *MisbehaviorReportManager) Start(signalerContext irrecoverable.SignalerContext)

Start provides a mock function for the type MisbehaviorReportManager

type MisbehaviorReportManager_Done_Call added in v0.46.0 

type MisbehaviorReportManager_Done_Call struct {
	*mock.Call
}

MisbehaviorReportManager_Done_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Done'

func (*MisbehaviorReportManager_Done_Call) Return added in v0.46.0 

func (_c *MisbehaviorReportManager_Done_Call) Return(valCh <-chan struct{}) *MisbehaviorReportManager_Done_Call

func (*MisbehaviorReportManager_Done_Call) Run added in v0.46.0 

func (_c *MisbehaviorReportManager_Done_Call) Run(run func()) *MisbehaviorReportManager_Done_Call

func (*MisbehaviorReportManager_Done_Call) RunAndReturn added in v0.46.0 

func (_c *MisbehaviorReportManager_Done_Call) RunAndReturn(run func() <-chan struct{}) *MisbehaviorReportManager_Done_Call

type MisbehaviorReportManager_Expecter added in v0.46.0 

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

func (*MisbehaviorReportManager_Expecter) Done added in v0.46.0 

func (_e *MisbehaviorReportManager_Expecter) Done() *MisbehaviorReportManager_Done_Call

Done is a helper method to define mock.On call

func (*MisbehaviorReportManager_Expecter) HandleMisbehaviorReport added in v0.46.0 

func (_e *MisbehaviorReportManager_Expecter) HandleMisbehaviorReport(channel interface{}, misbehaviorReport interface{}) *MisbehaviorReportManager_HandleMisbehaviorReport_Call

HandleMisbehaviorReport is a helper method to define mock.On call

  • channel channels.Channel
  • misbehaviorReport network.MisbehaviorReport

func (*MisbehaviorReportManager_Expecter) Ready added in v0.46.0 

func (_e *MisbehaviorReportManager_Expecter) Ready() *MisbehaviorReportManager_Ready_Call

Ready is a helper method to define mock.On call

func (*MisbehaviorReportManager_Expecter) Start added in v0.46.0 

func (_e *MisbehaviorReportManager_Expecter) Start(signalerContext interface{}) *MisbehaviorReportManager_Start_Call

Start is a helper method to define mock.On call

  • signalerContext irrecoverable.SignalerContext

type MisbehaviorReportManager_HandleMisbehaviorReport_Call added in v0.46.0 

type MisbehaviorReportManager_HandleMisbehaviorReport_Call struct {
	*mock.Call
}

MisbehaviorReportManager_HandleMisbehaviorReport_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'HandleMisbehaviorReport'

func (*MisbehaviorReportManager_HandleMisbehaviorReport_Call) Return added in v0.46.0 

func (_c *MisbehaviorReportManager_HandleMisbehaviorReport_Call) Return() *MisbehaviorReportManager_HandleMisbehaviorReport_Call

func (*MisbehaviorReportManager_HandleMisbehaviorReport_Call) Run added in v0.46.0 

func (_c *MisbehaviorReportManager_HandleMisbehaviorReport_Call) Run(run func(channel channels.Channel, misbehaviorReport network.MisbehaviorReport)) *MisbehaviorReportManager_HandleMisbehaviorReport_Call

func (*MisbehaviorReportManager_HandleMisbehaviorReport_Call) RunAndReturn added in v0.46.0 

func (_c *MisbehaviorReportManager_HandleMisbehaviorReport_Call) RunAndReturn(run func(channel channels.Channel, misbehaviorReport network.MisbehaviorReport)) *MisbehaviorReportManager_HandleMisbehaviorReport_Call

type MisbehaviorReportManager_Ready_Call added in v0.46.0 

type MisbehaviorReportManager_Ready_Call struct {
	*mock.Call
}

MisbehaviorReportManager_Ready_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Ready'

func (*MisbehaviorReportManager_Ready_Call) Return added in v0.46.0 

func (_c *MisbehaviorReportManager_Ready_Call) Return(valCh <-chan struct{}) *MisbehaviorReportManager_Ready_Call

func (*MisbehaviorReportManager_Ready_Call) Run added in v0.46.0 

func (_c *MisbehaviorReportManager_Ready_Call) Run(run func()) *MisbehaviorReportManager_Ready_Call

func (*MisbehaviorReportManager_Ready_Call) RunAndReturn added in v0.46.0 

func (_c *MisbehaviorReportManager_Ready_Call) RunAndReturn(run func() <-chan struct{}) *MisbehaviorReportManager_Ready_Call

type MisbehaviorReportManager_Start_Call added in v0.46.0 

type MisbehaviorReportManager_Start_Call struct {
	*mock.Call
}

MisbehaviorReportManager_Start_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Start'

func (*MisbehaviorReportManager_Start_Call) Return added in v0.46.0 

func (_c *MisbehaviorReportManager_Start_Call) Return() *MisbehaviorReportManager_Start_Call

func (*MisbehaviorReportManager_Start_Call) Run added in v0.46.0 

func (_c *MisbehaviorReportManager_Start_Call) Run(run func(signalerContext irrecoverable.SignalerContext)) *MisbehaviorReportManager_Start_Call

func (*MisbehaviorReportManager_Start_Call) RunAndReturn added in v0.46.0 

func (_c *MisbehaviorReportManager_Start_Call) RunAndReturn(run func(signalerContext irrecoverable.SignalerContext)) *MisbehaviorReportManager_Start_Call

type MisbehaviorReport_Expecter added in v0.46.0 

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

func (*MisbehaviorReport_Expecter) OriginId added in v0.46.0 

func (_e *MisbehaviorReport_Expecter) OriginId() *MisbehaviorReport_OriginId_Call

OriginId is a helper method to define mock.On call

func (*MisbehaviorReport_Expecter) Penalty added in v0.46.0 

func (_e *MisbehaviorReport_Expecter) Penalty() *MisbehaviorReport_Penalty_Call

Penalty is a helper method to define mock.On call

func (*MisbehaviorReport_Expecter) Reason added in v0.46.0 

func (_e *MisbehaviorReport_Expecter) Reason() *MisbehaviorReport_Reason_Call

Reason is a helper method to define mock.On call

type MisbehaviorReport_OriginId_Call added in v0.46.0 

type MisbehaviorReport_OriginId_Call struct {
	*mock.Call
}

MisbehaviorReport_OriginId_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'OriginId'

func (*MisbehaviorReport_OriginId_Call) Return added in v0.46.0 

func (_c *MisbehaviorReport_OriginId_Call) Return(identifier flow.Identifier) *MisbehaviorReport_OriginId_Call

func (*MisbehaviorReport_OriginId_Call) Run added in v0.46.0 

func (_c *MisbehaviorReport_OriginId_Call) Run(run func()) *MisbehaviorReport_OriginId_Call

func (*MisbehaviorReport_OriginId_Call) RunAndReturn added in v0.46.0 

func (_c *MisbehaviorReport_OriginId_Call) RunAndReturn(run func() flow.Identifier) *MisbehaviorReport_OriginId_Call

type MisbehaviorReport_Penalty_Call added in v0.46.0 

type MisbehaviorReport_Penalty_Call struct {
	*mock.Call
}

MisbehaviorReport_Penalty_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Penalty'

func (*MisbehaviorReport_Penalty_Call) Return added in v0.46.0 

func (_c *MisbehaviorReport_Penalty_Call) Return(f float64) *MisbehaviorReport_Penalty_Call

func (*MisbehaviorReport_Penalty_Call) Run added in v0.46.0 

func (_c *MisbehaviorReport_Penalty_Call) Run(run func()) *MisbehaviorReport_Penalty_Call

func (*MisbehaviorReport_Penalty_Call) RunAndReturn added in v0.46.0 

func (_c *MisbehaviorReport_Penalty_Call) RunAndReturn(run func() float64) *MisbehaviorReport_Penalty_Call

type MisbehaviorReport_Reason_Call added in v0.46.0 

type MisbehaviorReport_Reason_Call struct {
	*mock.Call
}

MisbehaviorReport_Reason_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Reason'

func (*MisbehaviorReport_Reason_Call) Return added in v0.46.0 

func (_c *MisbehaviorReport_Reason_Call) Return(misbehavior network.Misbehavior) *MisbehaviorReport_Reason_Call

func (*MisbehaviorReport_Reason_Call) Run added in v0.46.0 

func (_c *MisbehaviorReport_Reason_Call) Run(run func()) *MisbehaviorReport_Reason_Call

func (*MisbehaviorReport_Reason_Call) RunAndReturn added in v0.46.0 

func (_c *MisbehaviorReport_Reason_Call) RunAndReturn(run func() network.Misbehavior) *MisbehaviorReport_Reason_Call

type MisbehaviorReporter added in v0.43.2 

type MisbehaviorReporter struct {
	mock.Mock
}

MisbehaviorReporter is an autogenerated mock type for the MisbehaviorReporter type

func NewMisbehaviorReporter added in v0.43.2 

func NewMisbehaviorReporter(t interface {
	mock.TestingT
	Cleanup(func())
}) *MisbehaviorReporter

NewMisbehaviorReporter creates a new instance of MisbehaviorReporter. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*MisbehaviorReporter) EXPECT added in v0.46.0 

func (_m *MisbehaviorReporter) EXPECT() *MisbehaviorReporter_Expecter

func (*MisbehaviorReporter) ReportMisbehavior added in v0.43.2 

func (_mock *MisbehaviorReporter) ReportMisbehavior(misbehaviorReport network.MisbehaviorReport)

ReportMisbehavior provides a mock function for the type MisbehaviorReporter

type MisbehaviorReporter_Expecter added in v0.46.0 

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

func (*MisbehaviorReporter_Expecter) ReportMisbehavior added in v0.46.0 

func (_e *MisbehaviorReporter_Expecter) ReportMisbehavior(misbehaviorReport interface{}) *MisbehaviorReporter_ReportMisbehavior_Call

ReportMisbehavior is a helper method to define mock.On call

  • misbehaviorReport network.MisbehaviorReport

type MisbehaviorReporter_ReportMisbehavior_Call added in v0.46.0 

type MisbehaviorReporter_ReportMisbehavior_Call struct {
	*mock.Call
}

MisbehaviorReporter_ReportMisbehavior_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ReportMisbehavior'

func (*MisbehaviorReporter_ReportMisbehavior_Call) Return added in v0.46.0 

func (_c *MisbehaviorReporter_ReportMisbehavior_Call) Return() *MisbehaviorReporter_ReportMisbehavior_Call

func (*MisbehaviorReporter_ReportMisbehavior_Call) Run added in v0.46.0 

func (_c *MisbehaviorReporter_ReportMisbehavior_Call) Run(run func(misbehaviorReport network.MisbehaviorReport)) *MisbehaviorReporter_ReportMisbehavior_Call

func (*MisbehaviorReporter_ReportMisbehavior_Call) RunAndReturn added in v0.46.0 

func (_c *MisbehaviorReporter_ReportMisbehavior_Call) RunAndReturn(run func(misbehaviorReport network.MisbehaviorReport)) *MisbehaviorReporter_ReportMisbehavior_Call

type OutgoingMessageScope added in v0.43.2 

type OutgoingMessageScope struct {
	mock.Mock
}

OutgoingMessageScope is an autogenerated mock type for the OutgoingMessageScope type

func NewOutgoingMessageScope added in v0.43.2 

func NewOutgoingMessageScope(t interface {
	mock.TestingT
	Cleanup(func())
}) *OutgoingMessageScope

NewOutgoingMessageScope creates a new instance of OutgoingMessageScope. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*OutgoingMessageScope) EXPECT added in v0.46.0 

func (_m *OutgoingMessageScope) EXPECT() *OutgoingMessageScope_Expecter

func (*OutgoingMessageScope) PayloadType added in v0.43.2 

func (_mock *OutgoingMessageScope) PayloadType() string

PayloadType provides a mock function for the type OutgoingMessageScope

func (*OutgoingMessageScope) Proto added in v0.43.2 

func (_mock *OutgoingMessageScope) Proto() *message.Message

Proto provides a mock function for the type OutgoingMessageScope

func (*OutgoingMessageScope) Size added in v0.43.2 

func (_mock *OutgoingMessageScope) Size() int

Size provides a mock function for the type OutgoingMessageScope

func (*OutgoingMessageScope) TargetIds added in v0.43.2 

func (_mock *OutgoingMessageScope) TargetIds() flow.IdentifierList

TargetIds provides a mock function for the type OutgoingMessageScope

func (*OutgoingMessageScope) Topic added in v0.43.2 

func (_mock *OutgoingMessageScope) Topic() channels.Topic

Topic provides a mock function for the type OutgoingMessageScope

type OutgoingMessageScope_Expecter added in v0.46.0 

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

func (*OutgoingMessageScope_Expecter) PayloadType added in v0.46.0 

func (_e *OutgoingMessageScope_Expecter) PayloadType() *OutgoingMessageScope_PayloadType_Call

PayloadType is a helper method to define mock.On call

func (*OutgoingMessageScope_Expecter) Proto added in v0.46.0 

func (_e *OutgoingMessageScope_Expecter) Proto() *OutgoingMessageScope_Proto_Call

Proto is a helper method to define mock.On call

func (*OutgoingMessageScope_Expecter) Size added in v0.46.0 

func (_e *OutgoingMessageScope_Expecter) Size() *OutgoingMessageScope_Size_Call

Size is a helper method to define mock.On call

func (*OutgoingMessageScope_Expecter) TargetIds added in v0.46.0 

func (_e *OutgoingMessageScope_Expecter) TargetIds() *OutgoingMessageScope_TargetIds_Call

TargetIds is a helper method to define mock.On call

func (*OutgoingMessageScope_Expecter) Topic added in v0.46.0 

func (_e *OutgoingMessageScope_Expecter) Topic() *OutgoingMessageScope_Topic_Call

Topic is a helper method to define mock.On call

type OutgoingMessageScope_PayloadType_Call added in v0.46.0 

type OutgoingMessageScope_PayloadType_Call struct {
	*mock.Call
}

OutgoingMessageScope_PayloadType_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'PayloadType'

func (*OutgoingMessageScope_PayloadType_Call) Return added in v0.46.0 

func (_c *OutgoingMessageScope_PayloadType_Call) Return(s string) *OutgoingMessageScope_PayloadType_Call

func (*OutgoingMessageScope_PayloadType_Call) Run added in v0.46.0 

func (_c *OutgoingMessageScope_PayloadType_Call) Run(run func()) *OutgoingMessageScope_PayloadType_Call

func (*OutgoingMessageScope_PayloadType_Call) RunAndReturn added in v0.46.0 

func (_c *OutgoingMessageScope_PayloadType_Call) RunAndReturn(run func() string) *OutgoingMessageScope_PayloadType_Call

type OutgoingMessageScope_Proto_Call added in v0.46.0 

type OutgoingMessageScope_Proto_Call struct {
	*mock.Call
}

OutgoingMessageScope_Proto_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Proto'

func (*OutgoingMessageScope_Proto_Call) Return added in v0.46.0 

func (_c *OutgoingMessageScope_Proto_Call) Return(message1 *message.Message) *OutgoingMessageScope_Proto_Call

func (*OutgoingMessageScope_Proto_Call) Run added in v0.46.0 

func (_c *OutgoingMessageScope_Proto_Call) Run(run func()) *OutgoingMessageScope_Proto_Call

func (*OutgoingMessageScope_Proto_Call) RunAndReturn added in v0.46.0 

func (_c *OutgoingMessageScope_Proto_Call) RunAndReturn(run func() *message.Message) *OutgoingMessageScope_Proto_Call

type OutgoingMessageScope_Size_Call added in v0.46.0 

type OutgoingMessageScope_Size_Call struct {
	*mock.Call
}

OutgoingMessageScope_Size_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Size'

func (*OutgoingMessageScope_Size_Call) Return added in v0.46.0 

func (_c *OutgoingMessageScope_Size_Call) Return(n int) *OutgoingMessageScope_Size_Call

func (*OutgoingMessageScope_Size_Call) Run added in v0.46.0 

func (_c *OutgoingMessageScope_Size_Call) Run(run func()) *OutgoingMessageScope_Size_Call

func (*OutgoingMessageScope_Size_Call) RunAndReturn added in v0.46.0 

func (_c *OutgoingMessageScope_Size_Call) RunAndReturn(run func() int) *OutgoingMessageScope_Size_Call

type OutgoingMessageScope_TargetIds_Call added in v0.46.0 

type OutgoingMessageScope_TargetIds_Call struct {
	*mock.Call
}

OutgoingMessageScope_TargetIds_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'TargetIds'

func (*OutgoingMessageScope_TargetIds_Call) Return added in v0.46.0 

func (_c *OutgoingMessageScope_TargetIds_Call) Return(identifierList flow.IdentifierList) *OutgoingMessageScope_TargetIds_Call

func (*OutgoingMessageScope_TargetIds_Call) Run added in v0.46.0 

func (_c *OutgoingMessageScope_TargetIds_Call) Run(run func()) *OutgoingMessageScope_TargetIds_Call

func (*OutgoingMessageScope_TargetIds_Call) RunAndReturn added in v0.46.0 

func (_c *OutgoingMessageScope_TargetIds_Call) RunAndReturn(run func() flow.IdentifierList) *OutgoingMessageScope_TargetIds_Call

type OutgoingMessageScope_Topic_Call added in v0.46.0 

type OutgoingMessageScope_Topic_Call struct {
	*mock.Call
}

OutgoingMessageScope_Topic_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Topic'

func (*OutgoingMessageScope_Topic_Call) Return added in v0.46.0 

func (_c *OutgoingMessageScope_Topic_Call) Return(topic channels.Topic) *OutgoingMessageScope_Topic_Call

func (*OutgoingMessageScope_Topic_Call) Run added in v0.46.0 

func (_c *OutgoingMessageScope_Topic_Call) Run(run func()) *OutgoingMessageScope_Topic_Call

func (*OutgoingMessageScope_Topic_Call) RunAndReturn added in v0.46.0 

func (_c *OutgoingMessageScope_Topic_Call) RunAndReturn(run func() channels.Topic) *OutgoingMessageScope_Topic_Call

type PingInfoProvider added in v0.43.2 

type PingInfoProvider struct {
	mock.Mock
}

PingInfoProvider is an autogenerated mock type for the PingInfoProvider type

func NewPingInfoProvider added in v0.43.2 

func NewPingInfoProvider(t interface {
	mock.TestingT
	Cleanup(func())
}) *PingInfoProvider

NewPingInfoProvider creates a new instance of PingInfoProvider. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*PingInfoProvider) EXPECT added in v0.46.0 

func (_m *PingInfoProvider) EXPECT() *PingInfoProvider_Expecter

func (*PingInfoProvider) HotstuffView added in v0.43.2 

func (_mock *PingInfoProvider) HotstuffView() uint64

HotstuffView provides a mock function for the type PingInfoProvider

func (*PingInfoProvider) SealedBlockHeight added in v0.43.2 

func (_mock *PingInfoProvider) SealedBlockHeight() uint64

SealedBlockHeight provides a mock function for the type PingInfoProvider

func (*PingInfoProvider) SoftwareVersion added in v0.43.2 

func (_mock *PingInfoProvider) SoftwareVersion() string

SoftwareVersion provides a mock function for the type PingInfoProvider

type PingInfoProvider_Expecter added in v0.46.0 

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

func (*PingInfoProvider_Expecter) HotstuffView added in v0.46.0 

func (_e *PingInfoProvider_Expecter) HotstuffView() *PingInfoProvider_HotstuffView_Call

HotstuffView is a helper method to define mock.On call

func (*PingInfoProvider_Expecter) SealedBlockHeight added in v0.46.0 

func (_e *PingInfoProvider_Expecter) SealedBlockHeight() *PingInfoProvider_SealedBlockHeight_Call

SealedBlockHeight is a helper method to define mock.On call

func (*PingInfoProvider_Expecter) SoftwareVersion added in v0.46.0 

func (_e *PingInfoProvider_Expecter) SoftwareVersion() *PingInfoProvider_SoftwareVersion_Call

SoftwareVersion is a helper method to define mock.On call

type PingInfoProvider_HotstuffView_Call added in v0.46.0 

type PingInfoProvider_HotstuffView_Call struct {
	*mock.Call
}

PingInfoProvider_HotstuffView_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'HotstuffView'

func (*PingInfoProvider_HotstuffView_Call) Return added in v0.46.0 

func (_c *PingInfoProvider_HotstuffView_Call) Return(v uint64) *PingInfoProvider_HotstuffView_Call

func (*PingInfoProvider_HotstuffView_Call) Run added in v0.46.0 

func (_c *PingInfoProvider_HotstuffView_Call) Run(run func()) *PingInfoProvider_HotstuffView_Call

func (*PingInfoProvider_HotstuffView_Call) RunAndReturn added in v0.46.0 

func (_c *PingInfoProvider_HotstuffView_Call) RunAndReturn(run func() uint64) *PingInfoProvider_HotstuffView_Call

type PingInfoProvider_SealedBlockHeight_Call added in v0.46.0 

type PingInfoProvider_SealedBlockHeight_Call struct {
	*mock.Call
}

PingInfoProvider_SealedBlockHeight_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SealedBlockHeight'

func (*PingInfoProvider_SealedBlockHeight_Call) Return added in v0.46.0 

func (_c *PingInfoProvider_SealedBlockHeight_Call) Return(v uint64) *PingInfoProvider_SealedBlockHeight_Call

func (*PingInfoProvider_SealedBlockHeight_Call) Run added in v0.46.0 

func (_c *PingInfoProvider_SealedBlockHeight_Call) Run(run func()) *PingInfoProvider_SealedBlockHeight_Call

func (*PingInfoProvider_SealedBlockHeight_Call) RunAndReturn added in v0.46.0 

func (_c *PingInfoProvider_SealedBlockHeight_Call) RunAndReturn(run func() uint64) *PingInfoProvider_SealedBlockHeight_Call

type PingInfoProvider_SoftwareVersion_Call added in v0.46.0 

type PingInfoProvider_SoftwareVersion_Call struct {
	*mock.Call
}

PingInfoProvider_SoftwareVersion_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SoftwareVersion'

func (*PingInfoProvider_SoftwareVersion_Call) Return added in v0.46.0 

func (_c *PingInfoProvider_SoftwareVersion_Call) Return(s string) *PingInfoProvider_SoftwareVersion_Call

func (*PingInfoProvider_SoftwareVersion_Call) Run added in v0.46.0 

func (_c *PingInfoProvider_SoftwareVersion_Call) Run(run func()) *PingInfoProvider_SoftwareVersion_Call

func (*PingInfoProvider_SoftwareVersion_Call) RunAndReturn added in v0.46.0 

func (_c *PingInfoProvider_SoftwareVersion_Call) RunAndReturn(run func() string) *PingInfoProvider_SoftwareVersion_Call

type PingService added in v0.43.2 

type PingService struct {
	mock.Mock
}

PingService is an autogenerated mock type for the PingService type

func NewPingService added in v0.43.2 

func NewPingService(t interface {
	mock.TestingT
	Cleanup(func())
}) *PingService

NewPingService creates a new instance of PingService. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*PingService) EXPECT added in v0.46.0 

func (_m *PingService) EXPECT() *PingService_Expecter

func (*PingService) Ping added in v0.43.2 

func (_mock *PingService) Ping(ctx context.Context, peerID peer.ID) (message.PingResponse, time.Duration, error)

Ping provides a mock function for the type PingService

type PingService_Expecter added in v0.46.0 

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

func (*PingService_Expecter) Ping added in v0.46.0 

func (_e *PingService_Expecter) Ping(ctx interface{}, peerID interface{}) *PingService_Ping_Call

Ping is a helper method to define mock.On call

  • ctx context.Context
  • peerID peer.ID

type PingService_Ping_Call added in v0.46.0 

type PingService_Ping_Call struct {
	*mock.Call
}

PingService_Ping_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Ping'

func (*PingService_Ping_Call) Return added in v0.46.0 

func (_c *PingService_Ping_Call) Return(pingResponse message.PingResponse, duration time.Duration, err error) *PingService_Ping_Call

func (*PingService_Ping_Call) Run added in v0.46.0 

func (_c *PingService_Ping_Call) Run(run func(ctx context.Context, peerID peer.ID)) *PingService_Ping_Call

func (*PingService_Ping_Call) RunAndReturn added in v0.46.0 

func (_c *PingService_Ping_Call) RunAndReturn(run func(ctx context.Context, peerID peer.ID) (message.PingResponse, time.Duration, error)) *PingService_Ping_Call

type SubscriptionManager added in v0.43.2 

type SubscriptionManager struct {
	mock.Mock
}

SubscriptionManager is an autogenerated mock type for the SubscriptionManager type

func NewSubscriptionManager added in v0.43.2 

func NewSubscriptionManager(t interface {
	mock.TestingT
	Cleanup(func())
}) *SubscriptionManager

NewSubscriptionManager creates a new instance of SubscriptionManager. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*SubscriptionManager) Channels added in v0.43.2 

func (_mock *SubscriptionManager) Channels() channels.ChannelList

Channels provides a mock function for the type SubscriptionManager

func (*SubscriptionManager) EXPECT added in v0.46.0 

func (_m *SubscriptionManager) EXPECT() *SubscriptionManager_Expecter

func (*SubscriptionManager) GetEngine added in v0.43.2 

func (_mock *SubscriptionManager) GetEngine(channel channels.Channel) (network.MessageProcessor, error)

GetEngine provides a mock function for the type SubscriptionManager

func (*SubscriptionManager) Register added in v0.43.2 

func (_mock *SubscriptionManager) Register(channel channels.Channel, engine network.MessageProcessor) error

Register provides a mock function for the type SubscriptionManager

func (*SubscriptionManager) Unregister added in v0.43.2 

func (_mock *SubscriptionManager) Unregister(channel channels.Channel) error

Unregister provides a mock function for the type SubscriptionManager

type SubscriptionManager_Channels_Call added in v0.46.0 

type SubscriptionManager_Channels_Call struct {
	*mock.Call
}

SubscriptionManager_Channels_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Channels'

func (*SubscriptionManager_Channels_Call) Return added in v0.46.0 

func (_c *SubscriptionManager_Channels_Call) Return(channelList channels.ChannelList) *SubscriptionManager_Channels_Call

func (*SubscriptionManager_Channels_Call) Run added in v0.46.0 

func (_c *SubscriptionManager_Channels_Call) Run(run func()) *SubscriptionManager_Channels_Call

func (*SubscriptionManager_Channels_Call) RunAndReturn added in v0.46.0 

func (_c *SubscriptionManager_Channels_Call) RunAndReturn(run func() channels.ChannelList) *SubscriptionManager_Channels_Call

type SubscriptionManager_Expecter added in v0.46.0 

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

func (*SubscriptionManager_Expecter) Channels added in v0.46.0 

func (_e *SubscriptionManager_Expecter) Channels() *SubscriptionManager_Channels_Call

Channels is a helper method to define mock.On call

func (*SubscriptionManager_Expecter) GetEngine added in v0.46.0 

func (_e *SubscriptionManager_Expecter) GetEngine(channel interface{}) *SubscriptionManager_GetEngine_Call

GetEngine is a helper method to define mock.On call

  • channel channels.Channel

func (*SubscriptionManager_Expecter) Register added in v0.46.0 

func (_e *SubscriptionManager_Expecter) Register(channel interface{}, engine interface{}) *SubscriptionManager_Register_Call

Register is a helper method to define mock.On call

  • channel channels.Channel
  • engine network.MessageProcessor

func (*SubscriptionManager_Expecter) Unregister added in v0.46.0 

func (_e *SubscriptionManager_Expecter) Unregister(channel interface{}) *SubscriptionManager_Unregister_Call

Unregister is a helper method to define mock.On call

  • channel channels.Channel

type SubscriptionManager_GetEngine_Call added in v0.46.0 

type SubscriptionManager_GetEngine_Call struct {
	*mock.Call
}

SubscriptionManager_GetEngine_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetEngine'

func (*SubscriptionManager_GetEngine_Call) Return added in v0.46.0 

func (_c *SubscriptionManager_GetEngine_Call) Return(messageProcessor network.MessageProcessor, err error) *SubscriptionManager_GetEngine_Call

func (*SubscriptionManager_GetEngine_Call) Run added in v0.46.0 

func (_c *SubscriptionManager_GetEngine_Call) Run(run func(channel channels.Channel)) *SubscriptionManager_GetEngine_Call

func (*SubscriptionManager_GetEngine_Call) RunAndReturn added in v0.46.0 

func (_c *SubscriptionManager_GetEngine_Call) RunAndReturn(run func(channel channels.Channel) (network.MessageProcessor, error)) *SubscriptionManager_GetEngine_Call

type SubscriptionManager_Register_Call added in v0.46.0 

type SubscriptionManager_Register_Call struct {
	*mock.Call
}

SubscriptionManager_Register_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Register'

func (*SubscriptionManager_Register_Call) Return added in v0.46.0 

func (_c *SubscriptionManager_Register_Call) Return(err error) *SubscriptionManager_Register_Call

func (*SubscriptionManager_Register_Call) Run added in v0.46.0 

func (_c *SubscriptionManager_Register_Call) Run(run func(channel channels.Channel, engine network.MessageProcessor)) *SubscriptionManager_Register_Call

func (*SubscriptionManager_Register_Call) RunAndReturn added in v0.46.0 

func (_c *SubscriptionManager_Register_Call) RunAndReturn(run func(channel channels.Channel, engine network.MessageProcessor) error) *SubscriptionManager_Register_Call

type SubscriptionManager_Unregister_Call added in v0.46.0 

type SubscriptionManager_Unregister_Call struct {
	*mock.Call
}

SubscriptionManager_Unregister_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Unregister'

func (*SubscriptionManager_Unregister_Call) Return added in v0.46.0 

func (_c *SubscriptionManager_Unregister_Call) Return(err error) *SubscriptionManager_Unregister_Call

func (*SubscriptionManager_Unregister_Call) Run added in v0.46.0 

func (_c *SubscriptionManager_Unregister_Call) Run(run func(channel channels.Channel)) *SubscriptionManager_Unregister_Call

func (*SubscriptionManager_Unregister_Call) RunAndReturn added in v0.46.0 

func (_c *SubscriptionManager_Unregister_Call) RunAndReturn(run func(channel channels.Channel) error) *SubscriptionManager_Unregister_Call

type Topology added in v0.43.2 

type Topology struct {
	mock.Mock
}

Topology is an autogenerated mock type for the Topology type

func NewTopology added in v0.43.2 

func NewTopology(t interface {
	mock.TestingT
	Cleanup(func())
}) *Topology

NewTopology creates a new instance of Topology. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*Topology) EXPECT added in v0.46.0 

func (_m *Topology) EXPECT() *Topology_Expecter

func (*Topology) Fanout added in v0.43.2 

func (_mock *Topology) Fanout(ids flow.IdentityList) flow.IdentityList

Fanout provides a mock function for the type Topology

type Topology_Expecter added in v0.46.0 

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

func (*Topology_Expecter) Fanout added in v0.46.0 

func (_e *Topology_Expecter) Fanout(ids interface{}) *Topology_Fanout_Call

Fanout is a helper method to define mock.On call

  • ids flow.IdentityList

type Topology_Fanout_Call added in v0.46.0 

type Topology_Fanout_Call struct {
	*mock.Call
}

Topology_Fanout_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Fanout'

func (*Topology_Fanout_Call) Return added in v0.46.0 

func (_c *Topology_Fanout_Call) Return(v flow.IdentityList) *Topology_Fanout_Call

func (*Topology_Fanout_Call) Run added in v0.46.0 

func (_c *Topology_Fanout_Call) Run(run func(ids flow.IdentityList)) *Topology_Fanout_Call

func (*Topology_Fanout_Call) RunAndReturn added in v0.46.0 

func (_c *Topology_Fanout_Call) RunAndReturn(run func(ids flow.IdentityList) flow.IdentityList) *Topology_Fanout_Call

type Underlay added in v0.43.2 

type Underlay struct {
	mock.Mock
}

Underlay is an autogenerated mock type for the Underlay type

func NewUnderlay added in v0.43.2 

func NewUnderlay(t interface {
	mock.TestingT
	Cleanup(func())
}) *Underlay

NewUnderlay creates a new instance of Underlay. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*Underlay) Done added in v0.43.2 

func (_mock *Underlay) Done() <-chan struct{}

Done provides a mock function for the type Underlay

func (*Underlay) EXPECT added in v0.46.0 

func (_m *Underlay) EXPECT() *Underlay_Expecter

func (*Underlay) OnAllowListNotification added in v0.43.2 

func (_mock *Underlay) OnAllowListNotification(allowListingUpdate *network.AllowListingUpdate)

OnAllowListNotification provides a mock function for the type Underlay

func (*Underlay) OnDisallowListNotification added in v0.43.2 

func (_mock *Underlay) OnDisallowListNotification(disallowListingUpdate *network.DisallowListingUpdate)

OnDisallowListNotification provides a mock function for the type Underlay

func (*Underlay) Ready added in v0.43.2 

func (_mock *Underlay) Ready() <-chan struct{}

Ready provides a mock function for the type Underlay

func (*Underlay) Subscribe added in v0.43.2 

func (_mock *Underlay) Subscribe(channel channels.Channel) error

Subscribe provides a mock function for the type Underlay

func (*Underlay) Unsubscribe added in v0.43.2 

func (_mock *Underlay) Unsubscribe(channel channels.Channel) error

Unsubscribe provides a mock function for the type Underlay

func (*Underlay) UpdateNodeAddresses added in v0.43.2 

func (_mock *Underlay) UpdateNodeAddresses()

UpdateNodeAddresses provides a mock function for the type Underlay

type Underlay_Done_Call added in v0.46.0 

type Underlay_Done_Call struct {
	*mock.Call
}

Underlay_Done_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Done'

func (*Underlay_Done_Call) Return added in v0.46.0 

func (_c *Underlay_Done_Call) Return(valCh <-chan struct{}) *Underlay_Done_Call

func (*Underlay_Done_Call) Run added in v0.46.0 

func (_c *Underlay_Done_Call) Run(run func()) *Underlay_Done_Call

func (*Underlay_Done_Call) RunAndReturn added in v0.46.0 

func (_c *Underlay_Done_Call) RunAndReturn(run func() <-chan struct{}) *Underlay_Done_Call

type Underlay_Expecter added in v0.46.0 

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

func (*Underlay_Expecter) Done added in v0.46.0 

func (_e *Underlay_Expecter) Done() *Underlay_Done_Call

Done is a helper method to define mock.On call

func (*Underlay_Expecter) OnAllowListNotification added in v0.46.0 

func (_e *Underlay_Expecter) OnAllowListNotification(allowListingUpdate interface{}) *Underlay_OnAllowListNotification_Call

OnAllowListNotification is a helper method to define mock.On call

  • allowListingUpdate *network.AllowListingUpdate

func (*Underlay_Expecter) OnDisallowListNotification added in v0.46.0 

func (_e *Underlay_Expecter) OnDisallowListNotification(disallowListingUpdate interface{}) *Underlay_OnDisallowListNotification_Call

OnDisallowListNotification is a helper method to define mock.On call

  • disallowListingUpdate *network.DisallowListingUpdate

func (*Underlay_Expecter) Ready added in v0.46.0 

func (_e *Underlay_Expecter) Ready() *Underlay_Ready_Call

Ready is a helper method to define mock.On call

func (*Underlay_Expecter) Subscribe added in v0.46.0 

func (_e *Underlay_Expecter) Subscribe(channel interface{}) *Underlay_Subscribe_Call

Subscribe is a helper method to define mock.On call

  • channel channels.Channel

func (*Underlay_Expecter) Unsubscribe added in v0.46.0 

func (_e *Underlay_Expecter) Unsubscribe(channel interface{}) *Underlay_Unsubscribe_Call

Unsubscribe is a helper method to define mock.On call

  • channel channels.Channel

func (*Underlay_Expecter) UpdateNodeAddresses added in v0.46.0 

func (_e *Underlay_Expecter) UpdateNodeAddresses() *Underlay_UpdateNodeAddresses_Call

UpdateNodeAddresses is a helper method to define mock.On call

type Underlay_OnAllowListNotification_Call added in v0.46.0 

type Underlay_OnAllowListNotification_Call struct {
	*mock.Call
}

Underlay_OnAllowListNotification_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'OnAllowListNotification'

func (*Underlay_OnAllowListNotification_Call) Return added in v0.46.0 

func (_c *Underlay_OnAllowListNotification_Call) Return() *Underlay_OnAllowListNotification_Call

func (*Underlay_OnAllowListNotification_Call) Run added in v0.46.0 

func (_c *Underlay_OnAllowListNotification_Call) Run(run func(allowListingUpdate *network.AllowListingUpdate)) *Underlay_OnAllowListNotification_Call

func (*Underlay_OnAllowListNotification_Call) RunAndReturn added in v0.46.0 

func (_c *Underlay_OnAllowListNotification_Call) RunAndReturn(run func(allowListingUpdate *network.AllowListingUpdate)) *Underlay_OnAllowListNotification_Call

type Underlay_OnDisallowListNotification_Call added in v0.46.0 

type Underlay_OnDisallowListNotification_Call struct {
	*mock.Call
}

Underlay_OnDisallowListNotification_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'OnDisallowListNotification'

func (*Underlay_OnDisallowListNotification_Call) Return added in v0.46.0 

func (_c *Underlay_OnDisallowListNotification_Call) Return() *Underlay_OnDisallowListNotification_Call

func (*Underlay_OnDisallowListNotification_Call) Run added in v0.46.0 

func (_c *Underlay_OnDisallowListNotification_Call) Run(run func(disallowListingUpdate *network.DisallowListingUpdate)) *Underlay_OnDisallowListNotification_Call

func (*Underlay_OnDisallowListNotification_Call) RunAndReturn added in v0.46.0 

func (_c *Underlay_OnDisallowListNotification_Call) RunAndReturn(run func(disallowListingUpdate *network.DisallowListingUpdate)) *Underlay_OnDisallowListNotification_Call

type Underlay_Ready_Call added in v0.46.0 

type Underlay_Ready_Call struct {
	*mock.Call
}

Underlay_Ready_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Ready'

func (*Underlay_Ready_Call) Return added in v0.46.0 

func (_c *Underlay_Ready_Call) Return(valCh <-chan struct{}) *Underlay_Ready_Call

func (*Underlay_Ready_Call) Run added in v0.46.0 

func (_c *Underlay_Ready_Call) Run(run func()) *Underlay_Ready_Call

func (*Underlay_Ready_Call) RunAndReturn added in v0.46.0 

func (_c *Underlay_Ready_Call) RunAndReturn(run func() <-chan struct{}) *Underlay_Ready_Call

type Underlay_Subscribe_Call added in v0.46.0 

type Underlay_Subscribe_Call struct {
	*mock.Call
}

Underlay_Subscribe_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Subscribe'

func (*Underlay_Subscribe_Call) Return added in v0.46.0 

func (_c *Underlay_Subscribe_Call) Return(err error) *Underlay_Subscribe_Call

func (*Underlay_Subscribe_Call) Run added in v0.46.0 

func (_c *Underlay_Subscribe_Call) Run(run func(channel channels.Channel)) *Underlay_Subscribe_Call

func (*Underlay_Subscribe_Call) RunAndReturn added in v0.46.0 

func (_c *Underlay_Subscribe_Call) RunAndReturn(run func(channel channels.Channel) error) *Underlay_Subscribe_Call

type Underlay_Unsubscribe_Call added in v0.46.0 

type Underlay_Unsubscribe_Call struct {
	*mock.Call
}

Underlay_Unsubscribe_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Unsubscribe'

func (*Underlay_Unsubscribe_Call) Return added in v0.46.0 

func (_c *Underlay_Unsubscribe_Call) Return(err error) *Underlay_Unsubscribe_Call

func (*Underlay_Unsubscribe_Call) Run added in v0.46.0 

func (_c *Underlay_Unsubscribe_Call) Run(run func(channel channels.Channel)) *Underlay_Unsubscribe_Call

func (*Underlay_Unsubscribe_Call) RunAndReturn added in v0.46.0 

func (_c *Underlay_Unsubscribe_Call) RunAndReturn(run func(channel channels.Channel) error) *Underlay_Unsubscribe_Call

type Underlay_UpdateNodeAddresses_Call added in v0.46.0 

type Underlay_UpdateNodeAddresses_Call struct {
	*mock.Call
}

Underlay_UpdateNodeAddresses_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpdateNodeAddresses'

func (*Underlay_UpdateNodeAddresses_Call) Return added in v0.46.0 

func (_c *Underlay_UpdateNodeAddresses_Call) Return() *Underlay_UpdateNodeAddresses_Call

func (*Underlay_UpdateNodeAddresses_Call) Run added in v0.46.0 

func (_c *Underlay_UpdateNodeAddresses_Call) Run(run func()) *Underlay_UpdateNodeAddresses_Call

func (*Underlay_UpdateNodeAddresses_Call) RunAndReturn added in v0.46.0 

func (_c *Underlay_UpdateNodeAddresses_Call) RunAndReturn(run func()) *Underlay_UpdateNodeAddresses_Call

type ViolationsConsumer added in v0.43.2 

type ViolationsConsumer struct {
	mock.Mock
}

ViolationsConsumer is an autogenerated mock type for the ViolationsConsumer type

func NewViolationsConsumer added in v0.43.2 

func NewViolationsConsumer(t interface {
	mock.TestingT
	Cleanup(func())
}) *ViolationsConsumer

NewViolationsConsumer creates a new instance of ViolationsConsumer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*ViolationsConsumer) EXPECT added in v0.46.0 

func (_m *ViolationsConsumer) EXPECT() *ViolationsConsumer_Expecter

func (*ViolationsConsumer) OnInvalidMsgError added in v0.43.2 

func (_mock *ViolationsConsumer) OnInvalidMsgError(violation *network.Violation)

OnInvalidMsgError provides a mock function for the type ViolationsConsumer

func (*ViolationsConsumer) OnSenderEjectedError added in v0.43.2 

func (_mock *ViolationsConsumer) OnSenderEjectedError(violation *network.Violation)

OnSenderEjectedError provides a mock function for the type ViolationsConsumer

func (*ViolationsConsumer) OnUnAuthorizedSenderError added in v0.43.2 

func (_mock *ViolationsConsumer) OnUnAuthorizedSenderError(violation *network.Violation)

OnUnAuthorizedSenderError provides a mock function for the type ViolationsConsumer

func (*ViolationsConsumer) OnUnauthorizedPublishOnChannel added in v0.43.2 

func (_mock *ViolationsConsumer) OnUnauthorizedPublishOnChannel(violation *network.Violation)

OnUnauthorizedPublishOnChannel provides a mock function for the type ViolationsConsumer

func (*ViolationsConsumer) OnUnauthorizedUnicastOnChannel added in v0.43.2 

func (_mock *ViolationsConsumer) OnUnauthorizedUnicastOnChannel(violation *network.Violation)

OnUnauthorizedUnicastOnChannel provides a mock function for the type ViolationsConsumer

func (*ViolationsConsumer) OnUnexpectedError added in v0.43.2 

func (_mock *ViolationsConsumer) OnUnexpectedError(violation *network.Violation)

OnUnexpectedError provides a mock function for the type ViolationsConsumer

func (*ViolationsConsumer) OnUnknownMsgTypeError added in v0.43.2 

func (_mock *ViolationsConsumer) OnUnknownMsgTypeError(violation *network.Violation)

OnUnknownMsgTypeError provides a mock function for the type ViolationsConsumer

type ViolationsConsumer_Expecter added in v0.46.0 

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

func (*ViolationsConsumer_Expecter) OnInvalidMsgError added in v0.46.0 

func (_e *ViolationsConsumer_Expecter) OnInvalidMsgError(violation interface{}) *ViolationsConsumer_OnInvalidMsgError_Call

OnInvalidMsgError is a helper method to define mock.On call

  • violation *network.Violation

func (*ViolationsConsumer_Expecter) OnSenderEjectedError added in v0.46.0 

func (_e *ViolationsConsumer_Expecter) OnSenderEjectedError(violation interface{}) *ViolationsConsumer_OnSenderEjectedError_Call

OnSenderEjectedError is a helper method to define mock.On call

  • violation *network.Violation

func (*ViolationsConsumer_Expecter) OnUnAuthorizedSenderError added in v0.46.0 

func (_e *ViolationsConsumer_Expecter) OnUnAuthorizedSenderError(violation interface{}) *ViolationsConsumer_OnUnAuthorizedSenderError_Call

OnUnAuthorizedSenderError is a helper method to define mock.On call

  • violation *network.Violation

func (*ViolationsConsumer_Expecter) OnUnauthorizedPublishOnChannel added in v0.46.0 

func (_e *ViolationsConsumer_Expecter) OnUnauthorizedPublishOnChannel(violation interface{}) *ViolationsConsumer_OnUnauthorizedPublishOnChannel_Call

OnUnauthorizedPublishOnChannel is a helper method to define mock.On call

  • violation *network.Violation

func (*ViolationsConsumer_Expecter) OnUnauthorizedUnicastOnChannel added in v0.46.0 

func (_e *ViolationsConsumer_Expecter) OnUnauthorizedUnicastOnChannel(violation interface{}) *ViolationsConsumer_OnUnauthorizedUnicastOnChannel_Call

OnUnauthorizedUnicastOnChannel is a helper method to define mock.On call

  • violation *network.Violation

func (*ViolationsConsumer_Expecter) OnUnexpectedError added in v0.46.0 

func (_e *ViolationsConsumer_Expecter) OnUnexpectedError(violation interface{}) *ViolationsConsumer_OnUnexpectedError_Call

OnUnexpectedError is a helper method to define mock.On call

  • violation *network.Violation

func (*ViolationsConsumer_Expecter) OnUnknownMsgTypeError added in v0.46.0 

func (_e *ViolationsConsumer_Expecter) OnUnknownMsgTypeError(violation interface{}) *ViolationsConsumer_OnUnknownMsgTypeError_Call

OnUnknownMsgTypeError is a helper method to define mock.On call

  • violation *network.Violation

type ViolationsConsumer_OnInvalidMsgError_Call added in v0.46.0 

type ViolationsConsumer_OnInvalidMsgError_Call struct {
	*mock.Call
}

ViolationsConsumer_OnInvalidMsgError_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'OnInvalidMsgError'

func (*ViolationsConsumer_OnInvalidMsgError_Call) Return added in v0.46.0 

func (_c *ViolationsConsumer_OnInvalidMsgError_Call) Return() *ViolationsConsumer_OnInvalidMsgError_Call

func (*ViolationsConsumer_OnInvalidMsgError_Call) Run added in v0.46.0 

func (_c *ViolationsConsumer_OnInvalidMsgError_Call) Run(run func(violation *network.Violation)) *ViolationsConsumer_OnInvalidMsgError_Call

func (*ViolationsConsumer_OnInvalidMsgError_Call) RunAndReturn added in v0.46.0 

func (_c *ViolationsConsumer_OnInvalidMsgError_Call) RunAndReturn(run func(violation *network.Violation)) *ViolationsConsumer_OnInvalidMsgError_Call

type ViolationsConsumer_OnSenderEjectedError_Call added in v0.46.0 

type ViolationsConsumer_OnSenderEjectedError_Call struct {
	*mock.Call
}

ViolationsConsumer_OnSenderEjectedError_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'OnSenderEjectedError'

func (*ViolationsConsumer_OnSenderEjectedError_Call) Return added in v0.46.0 

func (_c *ViolationsConsumer_OnSenderEjectedError_Call) Return() *ViolationsConsumer_OnSenderEjectedError_Call

func (*ViolationsConsumer_OnSenderEjectedError_Call) Run added in v0.46.0 

func (_c *ViolationsConsumer_OnSenderEjectedError_Call) Run(run func(violation *network.Violation)) *ViolationsConsumer_OnSenderEjectedError_Call

func (*ViolationsConsumer_OnSenderEjectedError_Call) RunAndReturn added in v0.46.0 

func (_c *ViolationsConsumer_OnSenderEjectedError_Call) RunAndReturn(run func(violation *network.Violation)) *ViolationsConsumer_OnSenderEjectedError_Call

type ViolationsConsumer_OnUnAuthorizedSenderError_Call added in v0.46.0 

type ViolationsConsumer_OnUnAuthorizedSenderError_Call struct {
	*mock.Call
}

ViolationsConsumer_OnUnAuthorizedSenderError_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'OnUnAuthorizedSenderError'

func (*ViolationsConsumer_OnUnAuthorizedSenderError_Call) Return added in v0.46.0 

func (_c *ViolationsConsumer_OnUnAuthorizedSenderError_Call) Return() *ViolationsConsumer_OnUnAuthorizedSenderError_Call

func (*ViolationsConsumer_OnUnAuthorizedSenderError_Call) Run added in v0.46.0 

func (_c *ViolationsConsumer_OnUnAuthorizedSenderError_Call) Run(run func(violation *network.Violation)) *ViolationsConsumer_OnUnAuthorizedSenderError_Call

func (*ViolationsConsumer_OnUnAuthorizedSenderError_Call) RunAndReturn added in v0.46.0 

func (_c *ViolationsConsumer_OnUnAuthorizedSenderError_Call) RunAndReturn(run func(violation *network.Violation)) *ViolationsConsumer_OnUnAuthorizedSenderError_Call

type ViolationsConsumer_OnUnauthorizedPublishOnChannel_Call added in v0.46.0 

type ViolationsConsumer_OnUnauthorizedPublishOnChannel_Call struct {
	*mock.Call
}

ViolationsConsumer_OnUnauthorizedPublishOnChannel_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'OnUnauthorizedPublishOnChannel'

func (*ViolationsConsumer_OnUnauthorizedPublishOnChannel_Call) Return added in v0.46.0 

func (_c *ViolationsConsumer_OnUnauthorizedPublishOnChannel_Call) Return() *ViolationsConsumer_OnUnauthorizedPublishOnChannel_Call

func (*ViolationsConsumer_OnUnauthorizedPublishOnChannel_Call) Run added in v0.46.0 

func (_c *ViolationsConsumer_OnUnauthorizedPublishOnChannel_Call) Run(run func(violation *network.Violation)) *ViolationsConsumer_OnUnauthorizedPublishOnChannel_Call

func (*ViolationsConsumer_OnUnauthorizedPublishOnChannel_Call) RunAndReturn added in v0.46.0 

func (_c *ViolationsConsumer_OnUnauthorizedPublishOnChannel_Call) RunAndReturn(run func(violation *network.Violation)) *ViolationsConsumer_OnUnauthorizedPublishOnChannel_Call

type ViolationsConsumer_OnUnauthorizedUnicastOnChannel_Call added in v0.46.0 

type ViolationsConsumer_OnUnauthorizedUnicastOnChannel_Call struct {
	*mock.Call
}

ViolationsConsumer_OnUnauthorizedUnicastOnChannel_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'OnUnauthorizedUnicastOnChannel'

func (*ViolationsConsumer_OnUnauthorizedUnicastOnChannel_Call) Return added in v0.46.0 

func (_c *ViolationsConsumer_OnUnauthorizedUnicastOnChannel_Call) Return() *ViolationsConsumer_OnUnauthorizedUnicastOnChannel_Call

func (*ViolationsConsumer_OnUnauthorizedUnicastOnChannel_Call) Run added in v0.46.0 

func (_c *ViolationsConsumer_OnUnauthorizedUnicastOnChannel_Call) Run(run func(violation *network.Violation)) *ViolationsConsumer_OnUnauthorizedUnicastOnChannel_Call

func (*ViolationsConsumer_OnUnauthorizedUnicastOnChannel_Call) RunAndReturn added in v0.46.0 

func (_c *ViolationsConsumer_OnUnauthorizedUnicastOnChannel_Call) RunAndReturn(run func(violation *network.Violation)) *ViolationsConsumer_OnUnauthorizedUnicastOnChannel_Call

type ViolationsConsumer_OnUnexpectedError_Call added in v0.46.0 

type ViolationsConsumer_OnUnexpectedError_Call struct {
	*mock.Call
}

ViolationsConsumer_OnUnexpectedError_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'OnUnexpectedError'

func (*ViolationsConsumer_OnUnexpectedError_Call) Return added in v0.46.0 

func (_c *ViolationsConsumer_OnUnexpectedError_Call) Return() *ViolationsConsumer_OnUnexpectedError_Call

func (*ViolationsConsumer_OnUnexpectedError_Call) Run added in v0.46.0 

func (_c *ViolationsConsumer_OnUnexpectedError_Call) Run(run func(violation *network.Violation)) *ViolationsConsumer_OnUnexpectedError_Call

func (*ViolationsConsumer_OnUnexpectedError_Call) RunAndReturn added in v0.46.0 

func (_c *ViolationsConsumer_OnUnexpectedError_Call) RunAndReturn(run func(violation *network.Violation)) *ViolationsConsumer_OnUnexpectedError_Call

type ViolationsConsumer_OnUnknownMsgTypeError_Call added in v0.46.0 

type ViolationsConsumer_OnUnknownMsgTypeError_Call struct {
	*mock.Call
}

ViolationsConsumer_OnUnknownMsgTypeError_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'OnUnknownMsgTypeError'

func (*ViolationsConsumer_OnUnknownMsgTypeError_Call) Return added in v0.46.0 

func (_c *ViolationsConsumer_OnUnknownMsgTypeError_Call) Return() *ViolationsConsumer_OnUnknownMsgTypeError_Call

func (*ViolationsConsumer_OnUnknownMsgTypeError_Call) Run added in v0.46.0 

func (_c *ViolationsConsumer_OnUnknownMsgTypeError_Call) Run(run func(violation *network.Violation)) *ViolationsConsumer_OnUnknownMsgTypeError_Call

func (*ViolationsConsumer_OnUnknownMsgTypeError_Call) RunAndReturn added in v0.46.0 

func (_c *ViolationsConsumer_OnUnknownMsgTypeError_Call) RunAndReturn(run func(violation *network.Violation)) *ViolationsConsumer_OnUnknownMsgTypeError_Call

type WriteCloseFlusher added in v0.43.2 

type WriteCloseFlusher struct {
	mock.Mock
}

WriteCloseFlusher is an autogenerated mock type for the WriteCloseFlusher type

func NewWriteCloseFlusher added in v0.43.2 

func NewWriteCloseFlusher(t interface {
	mock.TestingT
	Cleanup(func())
}) *WriteCloseFlusher

NewWriteCloseFlusher creates a new instance of WriteCloseFlusher. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*WriteCloseFlusher) Close added in v0.43.2 

func (_mock *WriteCloseFlusher) Close() error

Close provides a mock function for the type WriteCloseFlusher

func (*WriteCloseFlusher) EXPECT added in v0.46.0 

func (_m *WriteCloseFlusher) EXPECT() *WriteCloseFlusher_Expecter

func (*WriteCloseFlusher) Flush added in v0.43.2 

func (_mock *WriteCloseFlusher) Flush() error

Flush provides a mock function for the type WriteCloseFlusher

func (*WriteCloseFlusher) Write added in v0.43.2 

func (_mock *WriteCloseFlusher) Write(p []byte) (int, error)

Write provides a mock function for the type WriteCloseFlusher

type WriteCloseFlusher_Close_Call added in v0.46.0 

type WriteCloseFlusher_Close_Call struct {
	*mock.Call
}

WriteCloseFlusher_Close_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Close'

func (*WriteCloseFlusher_Close_Call) Return added in v0.46.0 

func (_c *WriteCloseFlusher_Close_Call) Return(err error) *WriteCloseFlusher_Close_Call

func (*WriteCloseFlusher_Close_Call) Run added in v0.46.0 

func (_c *WriteCloseFlusher_Close_Call) Run(run func()) *WriteCloseFlusher_Close_Call

func (*WriteCloseFlusher_Close_Call) RunAndReturn added in v0.46.0 

func (_c *WriteCloseFlusher_Close_Call) RunAndReturn(run func() error) *WriteCloseFlusher_Close_Call

type WriteCloseFlusher_Expecter added in v0.46.0 

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

func (*WriteCloseFlusher_Expecter) Close added in v0.46.0 

func (_e *WriteCloseFlusher_Expecter) Close() *WriteCloseFlusher_Close_Call

Close is a helper method to define mock.On call

func (*WriteCloseFlusher_Expecter) Flush added in v0.46.0 

func (_e *WriteCloseFlusher_Expecter) Flush() *WriteCloseFlusher_Flush_Call

Flush is a helper method to define mock.On call

func (*WriteCloseFlusher_Expecter) Write added in v0.46.0 

func (_e *WriteCloseFlusher_Expecter) Write(p interface{}) *WriteCloseFlusher_Write_Call

Write is a helper method to define mock.On call

  • p []byte

type WriteCloseFlusher_Flush_Call added in v0.46.0 

type WriteCloseFlusher_Flush_Call struct {
	*mock.Call
}

WriteCloseFlusher_Flush_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Flush'

func (*WriteCloseFlusher_Flush_Call) Return added in v0.46.0 

func (_c *WriteCloseFlusher_Flush_Call) Return(err error) *WriteCloseFlusher_Flush_Call

func (*WriteCloseFlusher_Flush_Call) Run added in v0.46.0 

func (_c *WriteCloseFlusher_Flush_Call) Run(run func()) *WriteCloseFlusher_Flush_Call

func (*WriteCloseFlusher_Flush_Call) RunAndReturn added in v0.46.0 

func (_c *WriteCloseFlusher_Flush_Call) RunAndReturn(run func() error) *WriteCloseFlusher_Flush_Call

type WriteCloseFlusher_Write_Call added in v0.46.0 

type WriteCloseFlusher_Write_Call struct {
	*mock.Call
}

WriteCloseFlusher_Write_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Write'

func (*WriteCloseFlusher_Write_Call) Return added in v0.46.0 

func (_c *WriteCloseFlusher_Write_Call) Return(n int, err error) *WriteCloseFlusher_Write_Call

func (*WriteCloseFlusher_Write_Call) Run added in v0.46.0 

func (_c *WriteCloseFlusher_Write_Call) Run(run func(p []byte)) *WriteCloseFlusher_Write_Call

func (*WriteCloseFlusher_Write_Call) RunAndReturn added in v0.46.0 

func (_c *WriteCloseFlusher_Write_Call) RunAndReturn(run func(p []byte) (int, error)) *WriteCloseFlusher_Write_Call

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.