Versions in this module Expand all Collapse all v0 v0.1.0 Jun 22, 2020 Changes in this version + type MockHealthClient struct + func NewMockHealthClient(ctrl *gomock.Controller) *MockHealthClient + func (m *MockHealthClient) EXPECT() *MockHealthClientMockRecorder + func (m *MockHealthClient) HealthStream(arg0 context.Context, arg1 ...grpc.CallOption) (health.Health_HealthStreamClient, error) + type MockHealthClientMockRecorder struct + func (mr *MockHealthClientMockRecorder) HealthStream(arg0 interface{}, arg1 ...interface{}) *gomock.Call + type MockHealth_HealthStreamClient struct + func NewMockHealth_HealthStreamClient(ctrl *gomock.Controller) *MockHealth_HealthStreamClient + func (m *MockHealth_HealthStreamClient) CloseSend() error + func (m *MockHealth_HealthStreamClient) Context() context.Context + func (m *MockHealth_HealthStreamClient) EXPECT() *MockHealth_HealthStreamClientMockRecorder + func (m *MockHealth_HealthStreamClient) Header() (metadata.MD, error) + func (m *MockHealth_HealthStreamClient) Recv() (*emptypb.Empty, error) + func (m *MockHealth_HealthStreamClient) RecvMsg(arg0 interface{}) error + func (m *MockHealth_HealthStreamClient) Send(arg0 *health.NodeStatus) error + func (m *MockHealth_HealthStreamClient) SendMsg(arg0 interface{}) error + func (m *MockHealth_HealthStreamClient) Trailer() metadata.MD + type MockHealth_HealthStreamClientMockRecorder struct + func (mr *MockHealth_HealthStreamClientMockRecorder) CloseSend() *gomock.Call + func (mr *MockHealth_HealthStreamClientMockRecorder) Context() *gomock.Call + func (mr *MockHealth_HealthStreamClientMockRecorder) Header() *gomock.Call + func (mr *MockHealth_HealthStreamClientMockRecorder) Recv() *gomock.Call + func (mr *MockHealth_HealthStreamClientMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call + func (mr *MockHealth_HealthStreamClientMockRecorder) Send(arg0 interface{}) *gomock.Call + func (mr *MockHealth_HealthStreamClientMockRecorder) SendMsg(arg0 interface{}) *gomock.Call + func (mr *MockHealth_HealthStreamClientMockRecorder) Trailer() *gomock.Call + type MockHealth_HealthStreamServer struct + func NewMockHealth_HealthStreamServer(ctrl *gomock.Controller) *MockHealth_HealthStreamServer + func (m *MockHealth_HealthStreamServer) Context() context.Context + func (m *MockHealth_HealthStreamServer) EXPECT() *MockHealth_HealthStreamServerMockRecorder + func (m *MockHealth_HealthStreamServer) Recv() (*health.NodeStatus, error) + func (m *MockHealth_HealthStreamServer) RecvMsg(arg0 interface{}) error + func (m *MockHealth_HealthStreamServer) Send(arg0 *emptypb.Empty) error + func (m *MockHealth_HealthStreamServer) SendHeader(arg0 metadata.MD) error + func (m *MockHealth_HealthStreamServer) SendMsg(arg0 interface{}) error + func (m *MockHealth_HealthStreamServer) SetHeader(arg0 metadata.MD) error + func (m *MockHealth_HealthStreamServer) SetTrailer(arg0 metadata.MD) + type MockHealth_HealthStreamServerMockRecorder struct + func (mr *MockHealth_HealthStreamServerMockRecorder) Context() *gomock.Call + func (mr *MockHealth_HealthStreamServerMockRecorder) Recv() *gomock.Call + func (mr *MockHealth_HealthStreamServerMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call + func (mr *MockHealth_HealthStreamServerMockRecorder) Send(arg0 interface{}) *gomock.Call + func (mr *MockHealth_HealthStreamServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call + func (mr *MockHealth_HealthStreamServerMockRecorder) SendMsg(arg0 interface{}) *gomock.Call + func (mr *MockHealth_HealthStreamServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call + func (mr *MockHealth_HealthStreamServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call