465
466
// GetReplicationStatus mocks base method.
467
>
func (m *MockHistoryServiceClient) GetReplicationStatus(ctx context.Context, in *historyservice.GetReplicationStatusRequest, opts ...grpc.CallOption) (*historyservice.GetReplicationStatusResponse, error) {
service_grpc.pb.mock.go
468
>
m.ctrl.T.Helper()
469
>
varargs := []any{ctx, in}
470
>
for _, a := range opts {
471
varargs = append(varargs, a)
472
}
474
>
ret0, _ := ret[0].(*historyservice.GetReplicationStatusResponse)
475
>
ret1, _ := ret[1].(error)
476
>
return ret0, ret1
477
}
478
479
// GetReplicationStatus indicates an expected call of GetReplicationStatus.
480
>
func (mr *MockHistoryServiceClientMockRecorder) GetReplicationStatus(ctx, in any, opts ...any) *gomock.Call {
service_grpc.pb.mock.go
481
>
mr.mock.ctrl.T.Helper()
482
>
varargs := append([]any{ctx, in}, opts...)
483
>
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetReplicationStatus", reflect.TypeOf((*MockHistoryServiceClient)(nil).GetReplicationStatus), varargs...)
484
>
}
485
486
// GetShard mocks base method.