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) Ready() error
  • 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) Ready

func (m MockWSRPCClient) Ready() error

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)