pulsartestutil

package
v0.4.1 Latest Latest
Warning

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

Go to latest
Published: Oct 3, 2018 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

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

MockEntropy generator for pulsar's tests

Functions

This section is empty.

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL