mock

package
v0.46.0 Latest Latest
Warning

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

 Go to latest Published: Feb 6, 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 interface{}) ([]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 interface{})) *Codec_Encode_Call

func (*Codec_Encode_Call) RunAndReturn added in v0.46.0 

func (_c *Codec_Encode_Call) RunAndReturn(run func(v interface{}) ([]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 interface{}

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 interface{}, num uint, targetIDs ...flow.Identifier) error

Multicast provides a mock function for the type Conduit

func (*Conduit) Publish 

func (_mock *Conduit) Publish(event interface{}, 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 interface{}, 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, ifaceVal interface{}, v 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, ifaceVal interface{}, 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, ifaceVal interface{}, 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{}, ifaceVal interface{}, v interface{}, identifiers ...interface{}) *ConduitAdapter_MulticastOnChannel_Call

MulticastOnChannel is a helper method to define mock.On call

  • channel channels.Channel
  • ifaceVal interface{}
  • v uint
  • identifiers ...flow.Identifier

func (*ConduitAdapter_Expecter) PublishOnChannel added in v0.46.0 

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

PublishOnChannel is a helper method to define mock.On call

  • channel channels.Channel
  • ifaceVal interface{}
  • 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{}, ifaceVal interface{}, identifier interface{}) *ConduitAdapter_UnicastOnChannel_Call

UnicastOnChannel is a helper method to define mock.On call

  • channel channels.Channel
  • ifaceVal interface{}
  • 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, ifaceVal interface{}, v 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, ifaceVal interface{}, v 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, ifaceVal interface{}, 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, ifaceVal interface{}, 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, ifaceVal interface{}, 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, ifaceVal interface{}, 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 interface{}
  • 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 interface{}
  • 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 interface{}
  • 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 interface{}, 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 interface{}, 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 interface{}, 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 interface{}, 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 interface{}, 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 interface{}, 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() (interface{}, error)

Receive provides a mock function for the type Connection

func (*Connection) Send added in v0.43.2 

func (_mock *Connection) Send(msg interface{}) 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 interface{}

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(ifaceVal interface{}, 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() (interface{}, 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 interface{})) *Connection_Send_Call

func (*Connection_Send_Call) RunAndReturn added in v0.46.0 

func (_c *Connection_Send_Call) RunAndReturn(run func(msg interface{}) 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 interface{}) 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 interface{})) *Encoder_Encode_Call

func (*Encoder_Encode_Call) RunAndReturn added in v0.46.0 

func (_c *Encoder_Encode_Call) RunAndReturn(run func(v interface{}) 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 interface{}

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 interface{}) error

Process provides a mock function for the type Engine

func (*Engine) ProcessLocal 

func (_mock *Engine) ProcessLocal(event interface{}) 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 interface{})

Submit provides a mock function for the type Engine

func (*Engine) SubmitLocal 

func (_mock *Engine) SubmitLocal(event interface{})

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 interface{}

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 interface{}

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 interface{}

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 interface{}

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 interface{})) *Engine_ProcessLocal_Call

func (*Engine_ProcessLocal_Call) RunAndReturn added in v0.46.0 

func (_c *Engine_ProcessLocal_Call) RunAndReturn(run func(event interface{}) 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 interface{})) *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 interface{}) 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 interface{})) *Engine_SubmitLocal_Call

func (*Engine_SubmitLocal_Call) RunAndReturn added in v0.46.0 

func (_c *Engine_SubmitLocal_Call) RunAndReturn(run func(event interface{})) *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 interface{})) *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 interface{})) *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() interface{}

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(ifaceVal interface{}) *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() interface{}) *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 interface{}) 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 interface{}

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 interface{})) *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 interface{}) 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 interface{}) 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() interface{}

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 interface{}

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 interface{})) *MessageQueue_Insert_Call

func (*MessageQueue_Insert_Call) RunAndReturn added in v0.46.0 

func (_c *MessageQueue_Insert_Call) RunAndReturn(run func(message interface{}) 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(ifaceVal interface{}) *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() interface{}) *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.