mocks

Documentation

Index

• type MockConn
  • func (m *MockConn) Close()
  • func (m MockConn) GetState() connectivity.State
  • func (m MockConn) WaitForReady(ctx context.Context) bool
• type MockWSRPCClient
  • func (m *MockWSRPCClient) Close() error
  • func (m *MockWSRPCClient) HealthReport() map[string]error
  • func (m *MockWSRPCClient) LatestReport(ctx context.Context, in *pb.LatestReportRequest) (*pb.LatestReportResponse, error)
  • func (m *MockWSRPCClient) Name() string
  • func (m *MockWSRPCClient) RawClient() pb.MercuryClient
  • func (m *MockWSRPCClient) Ready() error
  • func (m *MockWSRPCClient) ServerURL() string
  • func (m *MockWSRPCClient) Start(context.Context) error
  • func (m *MockWSRPCClient) Transmit(ctx context.Context, in *pb.TransmitRequest) (*pb.TransmitResponse, error)

Types

type MockConn

type MockConn struct {
	State  connectivity.State
	Ready  bool
	Closed bool
}

func (*MockConn) Close

func (m *MockConn) Close()

func (MockConn) GetState

func (m MockConn) GetState() connectivity.State

func (MockConn) WaitForReady

func (m MockConn) WaitForReady(ctx context.Context) bool

type MockWSRPCClient

type MockWSRPCClient struct {
	TransmitF     func(ctx context.Context, in *pb.TransmitRequest) (*pb.TransmitResponse, error)
	LatestReportF func(ctx context.Context, req *pb.LatestReportRequest) (resp *pb.LatestReportResponse, err error)
}

func (*MockWSRPCClient) Close

func (m *MockWSRPCClient) Close() error

func (*MockWSRPCClient) HealthReport

func (m *MockWSRPCClient) HealthReport() map[string]error

func (*MockWSRPCClient) LatestReport

func (m *MockWSRPCClient) LatestReport(ctx context.Context, in *pb.LatestReportRequest) (*pb.LatestReportResponse, error)

func (*MockWSRPCClient) Name

func (m *MockWSRPCClient) Name() string

func (*MockWSRPCClient) RawClient

func (m *MockWSRPCClient) RawClient() pb.MercuryClient

func (*MockWSRPCClient) Ready

func (m *MockWSRPCClient) Ready() error

func (*MockWSRPCClient) ServerURL

func (m *MockWSRPCClient) ServerURL() string

func (*MockWSRPCClient) Start

func (m *MockWSRPCClient) Start(context.Context) error

func (*MockWSRPCClient) Transmit

func (m *MockWSRPCClient) Transmit(ctx context.Context, in *pb.TransmitRequest) (*pb.TransmitResponse, error)