mock

Documentation

Index

• type Codec
  • func (_m *Codec) Decode(data []byte) (interface{}, error)
  • func (_m *Codec) Encode(v interface{}) ([]byte, error)
  • func (_m *Codec) NewDecoder(r io.Reader) network.Decoder
  • func (_m *Codec) NewEncoder(w io.Writer) network.Encoder
• type Conduit
  • func (_m *Conduit) Close() error
  • func (_m *Conduit) Multicast(event interface{}, num uint, targetIDs ...flow.Identifier) error
  • func (_m *Conduit) Publish(event interface{}, targetIDs ...flow.Identifier) error
  • func (_m *Conduit) Submit(event interface{}, targetIDs ...flow.Identifier) error
  • func (_m *Conduit) Unicast(event interface{}, targetID flow.Identifier) error
• type Decoder
  • func (_m *Decoder) Decode() (interface{}, error)
• type Encoder
  • func (_m *Encoder) Encode(v interface{}) error
• type Engine
  • func (_m *Engine) Process(originID flow.Identifier, event interface{}) error
  • func (_m *Engine) ProcessLocal(event interface{}) error
  • func (_m *Engine) Submit(originID flow.Identifier, event interface{})
  • func (_m *Engine) SubmitLocal(event interface{})

Types

type Codec

type Codec struct {
	mock.Mock
}

Codec is an autogenerated mock type for the Codec type

func (*Codec) Decode

func (_m *Codec) Decode(data []byte) (interface{}, error)

Decode provides a mock function with given fields: data

func (*Codec) Encode

func (_m *Codec) Encode(v interface{}) ([]byte, error)

Encode provides a mock function with given fields: v

func (*Codec) NewDecoder

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

NewDecoder provides a mock function with given fields: r

func (*Codec) NewEncoder

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

NewEncoder provides a mock function with given fields: w

type Conduit

type Conduit struct {
	mock.Mock
}

Conduit is an autogenerated mock type for the Conduit type

func (*Conduit) Close

func (_m *Conduit) Close() error

Close provides a mock function with given fields:

func (*Conduit) Multicast

func (_m *Conduit) Multicast(event interface{}, num uint, targetIDs ...flow.Identifier) error

Multicast provides a mock function with given fields: event, num, targetIDs

func (*Conduit) Publish

func (_m *Conduit) Publish(event interface{}, targetIDs ...flow.Identifier) error

Publish provides a mock function with given fields: event, targetIDs

func (*Conduit) Submit

func (_m *Conduit) Submit(event interface{}, targetIDs ...flow.Identifier) error

Submit provides a mock function with given fields: event, targetIDs

func (*Conduit) Unicast

func (_m *Conduit) Unicast(event interface{}, targetID flow.Identifier) error

Unicast provides a mock function with given fields: event, targetID

type Decoder

type Decoder struct {
	mock.Mock
}

Decoder is an autogenerated mock type for the Decoder type

func (*Decoder) Decode

func (_m *Decoder) Decode() (interface{}, error)

Decode provides a mock function with given fields:

type Encoder

type Encoder struct {
	mock.Mock
}

Encoder is an autogenerated mock type for the Encoder type

func (*Encoder) Encode

func (_m *Encoder) Encode(v interface{}) error

Encode provides a mock function with given fields: v

type Engine

type Engine struct {
	mock.Mock
}

Engine is an autogenerated mock type for the Engine type

func (*Engine) Process

func (_m *Engine) Process(originID flow.Identifier, event interface{}) error

Process provides a mock function with given fields: originID, event

func (*Engine) ProcessLocal

func (_m *Engine) ProcessLocal(event interface{}) error

ProcessLocal provides a mock function with given fields: event

func (*Engine) Submit

func (_m *Engine) Submit(originID flow.Identifier, event interface{})

Submit provides a mock function with given fields: originID, event

func (*Engine) SubmitLocal

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

SubmitLocal provides a mock function with given fields: event