pulsartestutil

Documentation

Index

• Variables
• type CustomRPCWrapperMock
  • func (*CustomRPCWrapperMock) Close() error
  • func (*CustomRPCWrapperMock) CreateConnection(connectionType configuration.ConnectionType, connectionAddress string) error
  • func (impl *CustomRPCWrapperMock) Go(serviceMethod string, args interface{}, reply interface{}, done chan *rpc.Call) *rpc.Call
  • func (*CustomRPCWrapperMock) IsInitialised() bool
  • func (*CustomRPCWrapperMock) Lock()
  • func (*CustomRPCWrapperMock) SetRPCClient(client *rpc.Client)
  • func (*CustomRPCWrapperMock) Unlock()
• type MockEntropyGenerator
  • func (MockEntropyGenerator) GenerateEntropy() core.Entropy
• type MockListener
  • func (mock *MockListener) Accept() (net.Conn, error)
  • func (mock *MockListener) Addr() net.Addr
  • func (mock *MockListener) Close() error
• type MockRPCClientWrapper
  • func (mock *MockRPCClientWrapper) Close() error
  • func (mock *MockRPCClientWrapper) CreateConnection(connectionType configuration.ConnectionType, connectionAddress string) error
  • func (mock *MockRPCClientWrapper) Go(serviceMethod string, args interface{}, reply interface{}, done chan *rpc.Call) *rpc.Call
  • func (mock *MockRPCClientWrapper) IsInitialised() bool
  • func (mock *MockRPCClientWrapper) Lock()
  • func (mock *MockRPCClientWrapper) SetRPCClient(client *rpc.Client)
  • func (mock *MockRPCClientWrapper) Unlock()
• type MockStorage
  • func (*MockStorage) Close() error
  • func (mock *MockStorage) GetLastPulse() (*core.Pulse, error)
  • func (*MockStorage) SavePulse(pulse *core.Pulse) error
  • func (*MockStorage) SetLastPulse(pulse *core.Pulse) error

Variables

var MockEntropy = [64]byte{1, 2, 3, 4, 5, 6, 7, 8}

MockEntropy generator for pulsar's tests

Types

type CustomRPCWrapperMock

type CustomRPCWrapperMock struct {
	Done *rpc.Call
}

func (*CustomRPCWrapperMock) Close

func (*CustomRPCWrapperMock) Close() error

func (*CustomRPCWrapperMock) CreateConnection

func (*CustomRPCWrapperMock) CreateConnection(connectionType configuration.ConnectionType, connectionAddress string) error

func (*CustomRPCWrapperMock) Go

func (impl *CustomRPCWrapperMock) Go(serviceMethod string, args interface{}, reply interface{}, done chan *rpc.Call) *rpc.Call

func (*CustomRPCWrapperMock) IsInitialised

func (*CustomRPCWrapperMock) IsInitialised() bool

func (*CustomRPCWrapperMock) Lock

func (*CustomRPCWrapperMock) Lock()

func (*CustomRPCWrapperMock) SetRPCClient

func (*CustomRPCWrapperMock) SetRPCClient(client *rpc.Client)

func (*CustomRPCWrapperMock) Unlock

func (*CustomRPCWrapperMock) Unlock()

type MockEntropyGenerator

type MockEntropyGenerator struct {
}

func (MockEntropyGenerator) GenerateEntropy

func (MockEntropyGenerator) GenerateEntropy() core.Entropy

type MockListener

type MockListener struct {
	mock.Mock
}

Mock of listener for pulsar's tests

func (*MockListener) Accept

func (mock *MockListener) Accept() (net.Conn, error)

func (*MockListener) Addr

func (mock *MockListener) Addr() net.Addr

func (*MockListener) Close

func (mock *MockListener) Close() error

type MockRPCClientWrapper

type MockRPCClientWrapper struct {
	mock.Mock
}

Mock of RpcClientWrapper

func (*MockRPCClientWrapper) Close

func (mock *MockRPCClientWrapper) Close() error

func (*MockRPCClientWrapper) CreateConnection

func (mock *MockRPCClientWrapper) CreateConnection(connectionType configuration.ConnectionType, connectionAddress string) error

func (*MockRPCClientWrapper) Go

func (mock *MockRPCClientWrapper) Go(serviceMethod string, args interface{}, reply interface{}, done chan *rpc.Call) *rpc.Call

func (*MockRPCClientWrapper) IsInitialised

func (mock *MockRPCClientWrapper) IsInitialised() bool

func (*MockRPCClientWrapper) Lock

func (mock *MockRPCClientWrapper) Lock()

func (*MockRPCClientWrapper) SetRPCClient

func (mock *MockRPCClientWrapper) SetRPCClient(client *rpc.Client)

func (*MockRPCClientWrapper) Unlock

func (mock *MockRPCClientWrapper) Unlock()

type MockStorage

type MockStorage struct {
	mock.Mock
}

Mock of storage for pulsar's tests

func (*MockStorage) Close

func (*MockStorage) Close() error

func (*MockStorage) GetLastPulse

func (mock *MockStorage) GetLastPulse() (*core.Pulse, error)

func (*MockStorage) SavePulse

func (*MockStorage) SavePulse(pulse *core.Pulse) error

func (*MockStorage) SetLastPulse

func (*MockStorage) SetLastPulse(pulse *core.Pulse) error